博客

一、下载mysql驱动的jar包

官方下载链接

：

https://mvnrepository.com/artifact/mysql/mysql-connector-java/8.0.28

*返回上一层，下载和你数据库相对应的版本

1、项目下新建lib文件夹，把驱动jar包放到该文件夹





1.2 右键打开module设置







1.3 找到刚刚的驱动jar包，连续点ok，即配置完成

二、数据库连接

1.1 检测是否连接成功

import java.sql.*;

public class Test {
    public static void main(String[] args) {
        Connection con;
        String driver = "com.mysql.cj.jdbc.Driver";
        //【注意】 数据库名改换成你的
        String url="jdbc:mysql://localhost:3306/数据库名?useUnicode=true&characterEncoding=utf-8&useSSL=false";
        String user="root";     // 数据库账号
        String password="xxxx";   // 密码
        try {
            Class.forName(driver);
            con = DriverManager.getConnection(url, user, password);
            if (!con.isClosed()) {
                System.out.println("数据库连接成功!");
            }
        }catch (Exception e){
            System.out.println(e);
        }

    }
}

三、数据库基本语句使用

【使用示例】

import java.sql.*;

public class Test {
    public static void main(String[] args) {
        Connection con;
        String driver = "com.mysql.cj.jdbc.Driver";
        //【注意】 数据库名改换成你的
        String url="jdbc:mysql://localhost:3306/数据库名?useUnicode=true&characterEncoding=utf-8&useSSL=false";
        String user="root";     // 数据库账号
        String password="xxxx";   // 密码
        try {
            Class.forName(driver);
            con = DriverManager.getConnection(url, user, password);
            if (!con.isClosed()) {
                System.out.println("数据库连接成功!");
            }

            // 创建对象用来执行sql查询语句
            Statement statement = con.createStatement();
            String sql = "select * from mall_user";      // sql 语句
            ResultSet rs = statement.executeQuery(sql);   // 执行 sql
            while(rs.next()){
                String id = rs.getString("id");    // 获取字段id的值
                String name = rs.getString("name");   // 获取字段name的值
                System.out.println(id+" "+name);
            }
            // 查询结束
        }catch (Exception e){
            System.out.println(e);
        }

    }
}

下面代码替换上面【使用示例】的注释里面内容，即可使用

1.1 查询

// 创建对象用来执行sql查询语句
Statement statement = con.createStatement();
String sql = "select * from mall_user";      // sql 语句
ResultSet rs = statement.executeQuery(sql);   // 执行 sql
while(rs.next()){
	String id = rs.getString("id");    // 获取字段id的值
	String name = rs.getString("name");   // 获取字段name的值
	System.out.println(id+" "+name);
}
// 查询结束

1.2 插入

// 创建对象用来执行sql插入语句
PreparedStatement psql = con.prepareStatement("insert into mall_user values(999,'wwe','abc123',9,'2022-1-27');");    // sql插入语句
psql.executeUpdate();
// 插入结束

1.3 修改

// 创建对象用来执行sql修改语句
PreparedStatement psql = con.prepareStatement("update mall_user set password='123456' WHERE name='hqf';");  // 找到name=张三，修改其password
psql.executeUpdate();
// 修改结束

1.4 删除

// 创建对象用来执行sql删除语句
PreparedStatement psql = con.prepareStatement("delete from mall_user where name='张三';");  // 找到 name=张三，将该行删除
psql.executeUpdate();
// 删除结束

总结：除了查询，增删改使用 con.prepareStatement 执行 sql 语句即可