java原生jdbc操作MySQL 原生jdbc操作数据库流程

学习过java肯定对MySQL都相当的熟悉，大家日常工作中可能用Mybatis、JPA等持久层框架比较多。其实这些持久层框架的底层都是用原生的jdbc来操作MySQL数据库的。下面就给大家介绍一下原生jdbc；

前提：需要安装好MySQL数据库，并且有可操作的数据库表；我的数据库表是一张user表，里面有2个字段：id，name；

1.首先肯定是添加依赖，由于是原生的jdbc，需要原生jdbc驱动的依赖，不可以添加其他框架整合的jdbc。（如springboot的jdbc）

<!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.28</version>
</dependency>

2.编写java代码，连接数据库进行操作。（由于比较原生，所以只需要一个main方法即可，不需要有web工程）

 // 1. 建立连接
// 加载数据库驱动
Class.forName("com.mysql.jdbc.Driver");
// 数据库连接地址 jdbc:mysql://数据库地址:数据库端口/数据库名称
String url = "jdbc:mysql://localhost:3306/test";
// 账号
String username = "root";
// 密码
String password = "123456";
// 利用上述信息获取连接
Connection con = DriverManager.getConnection(url,username,password);

// 2. 对数据库进行操作
// a)增删改
// 插入sql语句
String sql1 = "INSERT INTO user (id, name) VALUES('2022','冰墩墩')";
// 使用连接获取Statement
Statement stat1 = con.createStatement();
// 执行sql，返回结果产生变化的总行数
int row = stat1.executeUpdate(sql1);
System.out.println("返回结果产生变化的总行数row = " + row);

// b)查询
// 查询sql语句
String sql2 = "SELECT * FROM user";
// 使用连接获取Statement
Statement stat2 = con.createStatement();
// 执行sql，返回结果集
ResultSet rs = stat2.executeQuery(sql2);
// 遍历结果集 getString获取的该字段是数据库对应的varchar类型
while(rs.next()){
  System.out.println(rs.getString("id")+"   "+rs.getString("name"));
}

//4.关闭所有连接
rs.close();
stat1.close();
stat2.close();
con.close();
}

控制台打印结果：

返回结果产生变化的总行数row = 1
2022   冰墩墩

注意：上述代码使用了Statement来操作数据库，这种操作会产生SQL注入的风险，因此可以使用下面PreparedStatement的代码来避免该风险：

//防注入解决方案:将Statement换成PreparedStatement
//a)增删改
String sql3 = "UPDATE user SET id=?,name=? WHERE id=?";
// 上面的sql语句有几个问号占位，下面设置占位参数的值，这样可以避免sql注入
PreparedStatement pst = con.prepareStatement(sql3);
// 设置第一个，第二个，第三个参数值
pst.setObject(1, "2023");
pst.setObject(2, "雪容融");
pst.setObject(3, "2022");
// 执行
int row3 = pst.executeUpdate();
System.out.println("返回结果产生变化的总行数row = " + row3);

//b)查询
String id = "2023";
String sql4 = "SELECT * FROM user WHERE id=? ";
PreparedStatement pst4 =  con.prepareStatement(sql4);
pst4.setObject(1, id);
ResultSet rs4 = pst4.executeQuery();
while(rs4.next()){
  System.out.println(rs4.getString("id")+"   "+rs4.getString("name"));
}
//pst.close();

输出结果：

返回结果产生变化的总行数row = 1
2023   雪容融

ok，原生jdbc给大家基本介绍完毕，大家有什么疑惑可以评论区讨论，作者看到都会回复哒[送心]