Java連接MySQL數據庫實例

更新時間：2022年04月09日 09:52:04 作者：景苒

這篇文章介紹了Java連接MySQL數據庫實例的方法，文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下

首先說明，由于是8版本的數據庫，所以配置類的寫法上與5版本的有所區(qū)別，需要注意，同時用idea或eclipse時需要導入jar包，jar包的下載鏈接：

https://dev.mysql.com/get/archives/mysql-connector-java-8.0/mysql-connector-java-8.0.28.zip

如果想要下載8版本不同的jar包只需要修改8.0.28為指定版本即可。

idea導入jar包的方法如下：

然后是代碼部分，首先先建表：

CREATE TABLE `train_message` (
                                 `id` int NOT NULL AUTO_INCREMENT COMMENT '主鍵id',
                                 `train_name` varchar(20) NOT NULL COMMENT '列車名',
                                 `origin` varchar(30) NOT NULL COMMENT '始發(fā)地',
                                 `terminal` varchar(30) NOT NULL COMMENT '終到地',
                                 `departure_time` timestamp NOT NULL COMMENT '出站時間',
                                 `state` varchar(10) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL DEFAULT '正常' COMMENT '列車狀態(tài)',
                                 PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=9 DEFAULT CHARSET=utf8mb3

然后創(chuàng)建連接的配置類DbConfig.java，localhost是本機的ip地址，如果有服務器就填服務器的ip地址，message是數據庫的名字，這里一張圖說下有很多新手誤解的名字

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

/**
 *  數據庫配置類
 *  @author 景苒
 */
public class DbConfig {
    public Connection dbConfig() throws SQLException {
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
        }catch (Exception e) {
            System.out.print("加載驅動失敗!");
            e.printStackTrace();
        }
        String url = "jdbc:mysql://localhost:3306/message?useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT%2B8&allowPublicKeyRetrieval=true";
        String user = "root";
        String password = "123456";
        return DriverManager.getConnection(url, user, password);
    }
}

然后寫下主函數Main.java，這里主函數的函數體可以在最后再寫，需要什么功能就把注釋打開就好，快捷注釋的方法，選中這句話，按ctrl加/，就能全注釋了。

import java.sql.SQLException;

/**
 * 主函數，調用功能
 * @author 景苒
 */
public class Main {
    public static void main(String[] args) throws SQLException {
//        new GetMessage().getMessage();
//        new UpdateTrainState().updateTrainState();
//        new InsertTrain().insertTrain();
//        new GetNumber().getNumber();
    }
}

然后是每個的功能：

1.查詢沈陽到武漢的所有列車信息，按出發(fā)時間先后排序

建GetMessage.java類

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

/**
 * 查詢沈陽到武漢的所有列車信息，按出發(fā)時間先后排序
 * @author 景苒
 */
public class GetMessage {
    public void getMessage() throws SQLException {
        Connection con = new DbConfig().dbConfig();
        String sql = "select * from `train_message` where origin = ? and terminal = ? ORDER BY departure_time ASC";
        String origin = "沈陽";
        String terminal = "武漢";
        PreparedStatement ps = con.prepareStatement(sql);
        ps.setString(1, origin);
        ps.setString(2, terminal);
        ResultSet rs = ps.executeQuery();
        try {
            while (rs.next()) {
                System.out.println("列車名：" + rs.getString("train_name")
                        + " 始發(fā)站：" + rs.getString("origin")
                        + " 終到站：" + rs.getString("terminal")
                        + " 出發(fā)時間：" + rs.getString("departure_time")
                        + " 列車狀態(tài)：" + rs.getString("state"));
            }
        }catch (SQLException e) {
            e.printStackTrace();
        }finally {
            ps.close();
            con.close();
        }
    }
}

2.修改T2255列車的狀態(tài)為停運

建UpdateTrainState.java類

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;

/**
 * 修改T2255列車的狀態(tài)為停運
 * @author 景苒
 */
public class UpdateTrainState {
    public void updateTrainState() throws SQLException {
        Connection con = new DbConfig().dbConfig();
        String sql = "UPDATE `train_message` SET state = '停運' WHERE train_name = 'T2255'";
        Statement statement = con.createStatement();
        try {
            int i = statement.executeUpdate(sql);
            if (i > 0) {
                System.out.println("更新成功");
            }else {
                System.out.println("更新失敗");
            }
        }catch (SQLException e) {
            e.printStackTrace();
        }finally {
            statement.close();
            con.close();
        }
    }
}

3.新增一輛列車信息（自己輸入）

建InsertTrain.java類

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;

/**
 * 新增一輛列車信息（自己輸入）
 * 始發(fā)時間為timestamp類型，輸入時需要確保格式正確，如：2019-01-01 00:00:00
 * @author 景苒
 */
public class InsertTrain {
    public void insertTrain() throws SQLException {
        Connection con = new DbConfig().dbConfig();
        Scanner scanner = new Scanner(System.in);
        String sql = "insert into `train_message` values(null, ?, ?, ?, ?, default)";
        System.out.print("請輸入列車名：");
        String trainName = scanner.nextLine();
        System.out.print("請輸入始發(fā)站：");
        String origin = scanner.nextLine();
        System.out.print("請輸入終到站：");
        String terminal = scanner.nextLine();
        System.out.print("請輸入始發(fā)時間：");
        String departureTime = scanner.nextLine();
        PreparedStatement ps = con.prepareStatement(sql);
        ps.setString(1, trainName);
        ps.setString(2, origin);
        ps.setString(3, terminal);
        ps.setString(4, departureTime);
        try {
            int i = ps.executeUpdate();
            if (i > 0) {
                System.out.println("添加成功");
            }else {
                System.out.println("添加失敗");
            }
        }catch (SQLException e) {
            e.printStackTrace();
        }finally {
            ps.close();
            con.close();
        }
    }
}

4.查詢狀態(tài)為正常的列車數量

建GetNumber.java類

import java.sql.Statement;

/**
 * 查詢狀態(tài)為正常的列車數量
 * @author 景苒
 */
public class GetNumber {
    public void getNumber() throws SQLException {
        Connection con = new DbConfig().dbConfig();
        String sql = "select count(state) from `train_message` where state = '正常'";
        Statement statement = con.createStatement();
        try {
            ResultSet resultSet = statement.executeQuery(sql);
            while (resultSet.next()) {
                System.out.println("狀態(tài)為正常的列車數量為：" + resultSet.getInt(1));
            }
        }catch (SQLException e){
            e.printStackTrace();
        }finally {
            statement.close();
            con.close();
        }
    }
}

最后附上navicat的屬性結構圖和樣例插入的語句