java idea 连接 mysql 数据库 -- 简单实现

首先你得有个 MysqL 账户，自己设置用户名和密码

顺序，先下载 MysqL 驱动 下载地址
下载完成后将解压后如下所示的 .jar 文件拖入 lib 包再右键添加为库。

再安装 Database Navigator 插件建立与 MysqL 数据库的连接，连接参数（用户名和密码要填正确！）输入完后一定要按 Apply，只按确定成功不了。

如何完成的过程都在代码里，先看代码

这一段是对数据库操作的代码，首先定义一些与 MysqL 相关参数，然后实现了简单的基本插入操作
更多操作可以在上面累加，比较容易

// MysqL.java
package mydatabase;

import java.sql.*;

public class MysqL {
    // 定义数据库连接 url
    private String dburl = null;
    // 定义数据库连接
    private Connection conn = null;
    // 定义数据返回结果集
    private ResultSet rs = null;
    // 定义数据库状态
    private PreparedStatement stmt = null;
    // 定义数据库用户名
    private String username = null;
    // 定义数据库连接密码
    private String password = null;
    // 定义数据库驱动方式
    private String dbdriver = null;
    // 设置数据库连接 url 的方法
    public void setDburl(String dburl){
        this.dburl = dburl;
    }
    // 返回当前实例数据库连接 url
    public String getDburl(){
        return dburl;
    }
    // 设置数据库用户名的方法
    public void setUsername(String username){
        this.username = username;
    }
    // 返回当前实例化数据库用户名
    public String getUsername(){
        return username;
    }
    // 设置数据库连接的方法
    public void setPassword(String password){
        this.password = password;
    }
    // 返回当前实例结果集的方法
    public ResultSet getRs(){
        return rs;
    }
    // 设置当前实例结果集的方法
    public void setRs(ResultSet rs){
        this.rs = rs;
    }
    // 返回当前实例数据库连接密码
    public String getpassword(){
        return password;
    }
    // 设置数据库驱动方式的方法
    public void setDbdriver(String dbdriver){
        this.dbdriver = dbdriver;
    }
    // 返回当前实例数据库驱动方式的方法
    public String getDbdriver(){
        return dbdriver;
    }
    // 创建数据库连接的方法
    Connection CreateConnection(String dburl,String username,String password)throws Exception{
        setDburl(dburl);
        setUsername(username);
        setPassword(password);
        Class.forName(getDbdriver());
        // 根据数据库路径、用户名和密码创建连接并返回该连接
        return DriverManager.getConnection(dburl,username,password);
    }
    // 关闭结果集的方法
    public void CloseRS(){
    	try{
    		rs.close();
    	}catch (sqlException e){
    		System.out.println("关闭结果集时发生错误！");
    	}
    }
    // 关闭状态的方法
    public void CloseStmt(){
        try{
            stmt.close();
        }catch (sqlException e){
            System.out.println("关闭状态时发生错误！");
        }
    }
    // 关闭连接的方法
    public void CloseConnection(){
        try{
            conn.close();
        }catch (sqlException e){
            System.out.println("关闭连接时发生错误！");
        }
    }
    // 根据参数执行插入操作
    void executeInsert(String id,String name)throws Exception {
        try {
            conn = CreateConnection(getDburl(), getUsername(), getpassword());
            stmt = conn.prepareStatement("insert into stu values(?,?)");
            stmt.setString(1, id);
            stmt.setString(2, name);
            stmt.executeUpdate();
        } catch (sqlException ex) {
            System.err.println(ex.getMessage());
        }
    }
}

下面是启动程序对 MysqL 进行插入操作。

// StartMysqL.java
package mydatabase;

import java.sql.sqlException;
import java.util.Scanner;

public class StartMysqL {
    public static void main(String[] args) throws sqlException {
            MysqL db = new MysqL();
            db.setDburl("jdbc:MysqL://localhost:3306/student?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC");
            // MysqL 老版驱动
            //db.setDbdriver("com.MysqL.jdbc.Driver");
            // MysqL 8.0 以上版本驱动
            db.setDbdriver("com.MysqL.cj.jdbc.Driver");
            try {
                Scanner sc = new Scanner(system.in);
                System.out.print("MysqL 用户名：");
                String username;
                username = sc.next();
                db.setUsername(username);
                System.out.print("MysqL 密码：");
                String password;
                password = sc.next();
                db.setPassword(password);
            }
            catch(Exception e){
                System.err.print(e.getMessage());
            }
            String id,name;
            Scanner sc = new Scanner(system.in);
            System.out.print("请输入要插入的id：");
            id = sc.next();
            System.out.print("请输入要插入对应id的name：");
            name = sc.next();
        try {
            db.executeInsert(id,name);
        } catch (Exception e) {
            System.err.println(e.getMessage());
        }
        finally {
        	db.CloseRS();
            db.CloseStmt();
            db.CloseConnection();
        }
    }
}

• 运行程序后输入的用户名和密码要与自己 MysqL 对应，否则会出现异常，导致执行插入命令失败

结果演示：
这是程序结果

你可以很容易地想到，用一个循环就可以实现一次性插入多条记录。

MysqL 结果

插入成功！