0
0

一起学Java——JDBC

目录

前言

学习Java的对于JDBC肯定不会陌生。Java数据库连接，（Java Database Connectivity，简称JDBC）是Java语言中用来规范客户端程序如何来访问数据库的应用程序接口，提供了诸如查询和更新数据库中数据的方法。JDBC也是Sun Microsystems的商标。我们通常说的JDBC是面向关系型数据库的。

学习内容

测试使用JDBC

相关操作建议参照！！！
参考文章链接

  1. 新建项目结构如下，引入jar包到lib文件下；请添加图片描述
  2. 设置jar包到项目环境；在这里插入图片描述请添加图片描述
  3. 数据库新建study数据库，并在该数据库下新建student表；请添加图片描述
  4. 编写测试类代码如下；
  1. importjava.sql.*;/**
  2.  * Description:
  3.  *
  4.  * @Author: kk(专业bug开发)
  5.  * DateTime: 2022-01-07 16:29
  6.  */publicclassJdbcExample{//    MySQL 8.0 以下版本 - JDBC 驱动名及数据库 URL//    static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";//    static final String DB_URL = "jdbc:mysql://localhost:3306/RUNOOB";//     MySQL 8.0 以上版本 - JDBC 驱动名及数据库 URLstaticfinalString JDBC_DRIVER ="com.mysql.cj.jdbc.Driver";staticfinalString DB_URL ="jdbc:mysql://localhost:3306/study?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC";// 数据库的用户名与密码，需要根据自己的设置staticfinalString USER ="root";staticfinalString PASS ="123456";publicstaticvoidmain(String[] args){Connection conn =null;Statement stmt =null;try{// 注册 JDBC 驱动Class.forName(JDBC_DRIVER);// 打开链接System.out.println("连接数据库...");
  7.             conn =DriverManager.getConnection(DB_URL, USER, PASS);// 执行查询System.out.println(" 实例化Statement对象...");
  8.             stmt = conn.createStatement();ResultSet rs = stmt.executeQuery("SELECT * FROM student");// 展开结果集数据库while(rs.next()){//rs.next()返回布尔值，代表是否存在下一条记录//如果有，返回true。继续提取下一条记录//如果没有，返回false，结束循环// 通过字段检索int id = rs.getInt("id");String name = rs.getString("name");String classname = rs.getString("classname");// 输出数据System.out.print("ID: "+ id);System.out.print(", 姓名: "+ name);System.out.print(", 班级: "+ classname);System.out.print("\n");}// 完成后关闭
  9.             rs.close();
  10.             stmt.close();
  11.             conn.close();}catch(SQLException se){// 处理 JDBC 错误
  12.             se.printStackTrace();}catch(Exception e){// 处理 Class.forName 错误
  13.             e.printStackTrace();}finally{// 关闭资源try{if(stmt !=null) stmt.close();}catch(SQLException se2){}// 什么都不做try{if(conn !=null)
  14.                     conn.close();}catch(SQLException se){
  15.                 se.printStackTrace();}}System.out.println("Goodbye!");}}
  1. 测试代码运行结果如下；请添加图片描述

预编译语句集防止SQL注入

  1. 首先我们明确一下什么是SQL注入。百度百科的解释如下：

SQL注入即是指web应用程序对用户输入数据的合法性没有判断或过滤不严，攻击者可以在web应用程序中事先定义好的查询语句的结尾上添加额外的SQL语句，在管理员不知情的情况下实现非法操作，以此来实现欺骗数据库服务器执行非授权的任意查询，从而进一步得到相应的数据信息。

  1. SQL注入测试，在查询语句后面拼接1=1,例如；
  1. # 原本查询语句SELECT*FROM student where classname ='" + cname + "'# SQL注入后的语句
  2. cname =' or 1=1 or 1='SELECT*FROM student where classname =''or1=1or1=''
  1. 使用预编译语句集防止SQL注入，实现逻辑如下；
  1. import java.sql.*;import java.util.Scanner;/**
  2.  * Description:
  3.  *
  4.  * @Author: kk(专业bug开发)
  5.  * DateTime: 2022-01-07 16:29
  6.  */public class JdbcExample {
  7. //    MySQL 8.0 以下版本 - JDBC 驱动名及数据库 URL//    static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";//    static final String DB_URL = "jdbc:mysql://localhost:3306/RUNOOB";//     MySQL 8.0 以上版本 - JDBC 驱动名及数据库 URL
  8.     static final String JDBC_DRIVER ="com.mysql.cj.jdbc.Driver";
  9.     static final String DB_URL ="jdbc:mysql://localhost:3306/study?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC";// 数据库的用户名与密码，需要根据自己的设置
  10.     static final String USER="root";
  11.     static final String PASS ="123456";public static void main(String[] args) {
  12.         Connection conn =null;//        Statement stmt = null;
  13.         PreparedStatement pstmt =null;
  14.         try {
  15.             // 注册 JDBC 驱动
  16.             Class.forName(JDBC_DRIVER);// 打开链接
  17.             System.out.println("连接数据库...");
  18.             conn = DriverManager.getConnection(DB_URL,USER, PASS);// 执行查询
  19.             System.out.println(" 实例化Statement对象...");
  20.             System.out.println("请输入待查询的班级:");//            仔细看这部分代码，prepareStatement对sql进行了预编译
  21.             Scanner in= new Scanner(System.in);
  22.             String cname =in.next();
  23.             String sql="SELECT * FROM student where classname = ?";
  24.             pstmt= conn.prepareStatement(sql);// 使用setString()设置参数
  25.             pstmt.setString(1, cname);
  26.             ResultSet rs = pstmt.executeQuery();// 展开结果集数据库while(rs.next()) {
  27.                 // 通过字段检索int id = rs.getInt("id");
  28.                 String name = rs.getString("name");
  29.                 String classname = rs.getString("classname");// 输出数据
  30.                 System.out.print("ID: "+ id);
  31.                 System.out.print(", 姓名: "+ name);
  32.                 System.out.print(", 班级: "+ classname);
  33.                 System.out.print("\n");
  34.             }
  35.             // 完成后关闭
  36.             rs.close();
  37.             pstmt.close();
  38.             conn.close();
  39.         } catch (SQLException se) {
  40.             // 处理 JDBC 错误
  41.             se.printStackTrace();
  42.         } catch (Exception e) {
  43.             // 处理 Class.forName 错误
  44.             e.printStackTrace();
  45.         } finally {
  46.             // 关闭资源
  47.             try {
  48.                 if(pstmt !=null) pstmt.close();
  49.             } catch (SQLException se2) {
  50.             }// 什么都不做
  51.             try {
  52.                 if(conn !=null)
  53.                     conn.close();
  54.             } catch (SQLException se) {
  55.                 se.printStackTrace();
  56.             }
  57.         }
  58.         System.out.println("Goodbye!");
  59.     }
  60. }

封装使用DbUtils工具类

  1. 为什么需要封装这么一个类？

观察上面的代码，我们每进行一次数据库的操作就需要进行数据库的五项操作，代码内聚度不够高，当我们对这一段相同作用的代码进行封装，形成一个工具类，就可以完美解决代码多次重复的问题。

  1. 在我们的项目下新建一个包，存放公共类；请添加图片描述
  2. 工具类代码编写如下，详细原理参见注释；
  1. packagecom.five.jdbc.common;importjava.sql.*;/**
  2.  * Description:
  3.  *
  4.  * @Author: kk(专业bug开发)
  5.  * DateTime: 2022-01-08 10:52
  6.  */publicclassDbUtils{//MySQL 8.0 以上版本-JDBC 驱动名及数据库 URLstaticfinalString JDBC_DRIVER ="com.mysql.cj.jdbc.Driver";staticfinalString DB_URL ="jdbc:mysql://localhost:3306/study?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC";//数据库的用户名与密码staticfinalString USER ="root";staticfinalString PASS ="123456";/**
  7.      * @Description: 创建数据库连接
  8.      * @Param:
  9.      * @return: 返回连接
  10.      */publicstaticConnectiongetConnection()throwsClassNotFoundException,SQLException{// 注册 JDBC 驱动Class.forName(JDBC_DRIVER);// 打开链接Connection conn =DriverManager.getConnection(DB_URL, USER, PASS);return conn;}/**
  11.      * @Description: 关闭连接，释放资源
  12.      * @Param: rs-结果集对象， stmt-Statement对象，  conn-Connection对象
  13.      */publicstaticvoidcloseConnection(ResultSet rs,Statement stmt,Connection conn)throwsSQLException{// 关闭rs-结果集对象try{if(rs !=null){
  14.                 rs.close();}}catch(Exception e){
  15.             e.printStackTrace();}// 关闭stmt-Statement对象try{if(stmt !=null){
  16.                 stmt.close();}}catch(Exception e){
  17.             e.printStackTrace();}// 关闭conn-Connection对象try{if(conn !=null&&!conn.isClosed()){
  18.                 conn.close();}}catch(Exception e){
  19.             e.printStackTrace();}}}
  1. 使用工具类操作数据，新建类如下，原理参照注释；请添加图片描述
  • 新增数据
  1. packagecom.five.jdbc.example;importcom.five.jdbc.common.DbUtils;importjava.sql.Connection;importjava.sql.PreparedStatement;importjava.sql.SQLException;importjava.util.Scanner;/**
  2.  * Description:
  3.  *
  4.  * @Author: kk(专业bug开发)
  5.  * DateTime: 2022-01-08 13:06
  6.  */publicclassInsertExample{publicstaticvoidmain(String[] args)throwsSQLException{Scanner in =newScanner(System.in);System.out.println("请输入学生编号：");int id = in.nextInt();System.out.println("请输入学生姓名：");String name = in.next();System.out.println("请输入学生班级：");String cname = in.next();Connection conn =null;PreparedStatement pstmt =null;try{
  7.             conn =DbUtils.getConnection();String sql ="insert into student(id,name,classname) values(?,?,?)";
  8.             pstmt = conn.prepareStatement(sql);
  9.             pstmt.setInt(1, id);
  10.             pstmt.setString(2, name);
  11.             pstmt.setString(3, cname);int cnt  = pstmt.executeUpdate();//写操作影响的行数System.out.println("cnt"+ cnt);System.out.println(name ="添加成功啦！");}catch(ClassNotFoundException|SQLException e){
  12.             e.printStackTrace();}finally{DbUtils.closeConnection(null, pstmt, conn);}}}

请添加图片描述

  • 更新数据
  1. packagecom.five.jdbc.example;importcom.five.jdbc.common.DbUtils;importjava.sql.Connection;importjava.sql.PreparedStatement;importjava.sql.SQLException;importjava.util.Scanner;/**
  2.  * Description:
  3.  *
  4.  * @Author: kk(专业bug开发)
  5.  * DateTime: 2022-01-08 13:27
  6.  */publicclassUpdateExample{publicstaticvoidmain(String[] args)throwsSQLException{Scanner in =newScanner(System.in);System.out.println("请输入学生编号：");int id = in.nextInt();System.out.println("请输入学生班级：");String cname = in.next();Connection conn =null;PreparedStatement pstmt =null;try{
  7.             conn =DbUtils.getConnection();String sql ="update student set classname=? where id=?";
  8.             pstmt = conn.prepareStatement(sql);
  9.             pstmt.setString(1, cname);
  10.             pstmt.setInt(2, id);int cnt  = pstmt.executeUpdate();//写操作影响的行数if(cnt ==1){System.out.println("学生班级调整完毕！");}else{System.out.println("没有找到对应编号学生！");}}catch(ClassNotFoundException|SQLException e){
  11.             e.printStackTrace();}finally{DbUtils.closeConnection(null, pstmt, conn);}}}

请添加图片描述

  • 删除数据
  1. packagecom.five.jdbc.example;importcom.five.jdbc.common.DbUtils;importjava.sql.Connection;importjava.sql.PreparedStatement;importjava.sql.SQLException;importjava.util.Scanner;/**
  2.  * Description:
  3.  *
  4.  * @Author: kk(专业bug开发)
  5.  * DateTime: 2022-01-08 13:37
  6.  */publicclassDeleteExample{publicstaticvoidmain(String[] args)throwsSQLException{Scanner in =newScanner(System.in);System.out.println("请输入学生编号：");int id = in.nextInt();Connection conn =null;PreparedStatement pstmt =null;try{
  7.             conn =DbUtils.getConnection();String sql ="delete from student where id=?";
  8.             pstmt = conn.prepareStatement(sql);
  9.             pstmt.setInt(1, id);int cnt = pstmt.executeUpdate();//写操作影响的行数if(cnt ==1){System.out.println("学生信息删除完毕！");}else{System.out.println("没有找到对应编号学生！");}}catch(ClassNotFoundException|SQLException e){
  10.             e.printStackTrace();}finally{DbUtils.closeConnection(null, pstmt, conn);}}}

请添加图片描述

JDBC事务管理

  1. 什么是事务？

事务是以一种可靠的、一致的方式，访问和操作数据库的程序单元

通俗的说：要么把事情做完，要么什么都不做，不要做一半。

  1. 事务原理图如下；

在这里插入图片描述

在这里插入图片描述

  1. 提交事务模式
  • 自动提交事务

每执行一次写操作，自动提交事务
自动提交开启方法：conn.setAutoCommit(true)
自动事务是JDBC的默认行为，此模式无法保证数据一致性

  • 手动提交事务

显示调用commit()和rollback()方法管理事务
手动提交开启方法：conn.setAutoCommit(false)
保证多数据一致性，但必须手动调用提交/回滚方法

手动调用事务案例：
请添加图片描述

  1. packagecom.five.jdbc.example;importcom.five.jdbc.common.DbUtils;importjava.sql.Connection;importjava.sql.PreparedStatement;importjava.sql.SQLException;/**
  2.  * Description:
  3.  *
  4.  * @Author: kk(专业bug开发)
  5.  * DateTime: 2022-01-08 16:02
  6.  */publicclassTransactionExample{publicstaticvoidmain(String[] args)throwsSQLException{Connection conn =null;PreparedStatement pstmt =null;try{
  7.             conn =DbUtils.getConnection();
  8.             conn.setAutoCommit(false);//关闭自动提交String sql ="insert into student(id,name,classname) values(?,?,?)";for(int i =20; i <40; i++){//                模拟发生异常的情况//                if(i == 35){//                    throw new RuntimeException("添加失败");//                }
  9.                 pstmt = conn.prepareStatement(sql);
  10.                 pstmt.setInt(1, i);
  11.                 pstmt.setString(2,"学生"+ i);
  12.                 pstmt.setString(3,"高三（10）班");
  13.                 pstmt.executeUpdate();//写操作}
  14.             conn.commit();//提交数据}catch(Exception e){
  15.             e.printStackTrace();try{if(conn !=null&&!conn.isClosed()){
  16.                     conn.rollback();//如果发生异常，数据库事务回滚}}catch(SQLException ex){
  17.                 ex.printStackTrace();}}finally{DbUtils.closeConnection(null, pstmt, conn);}}}

实体类实现分页数据封装

设想一下实际的开发，我们查询数据经常是一组数据，这一组数据我们需要统一返回，这时候我们可以利用Java面向对象的特性进行处理。

  1. 新建实体类和测试类；请添加图片描述
  2. 实体类代码；
  1. packagecom.five.jdbc.entity;/**
  2.  * Description:学生信息实体类
  3.  *   1.具备默认构造函数  2.属性私有   3.存在getter和setter
  4.  * @Author: kk(专业bug开发)
  5.  * DateTime: 2022-01-08 16:19
  6.  */publicclassStudent{publicStudent(){}privateInteger id;privateString name;privateString cname;publicIntegergetId(){return id;}publicvoidsetId(Integer id){this.id = id;}publicStringgetName(){return name;}publicvoidsetName(String name){this.name = name;}publicStringgetCname(){return cname;}publicvoidsetCname(String cname){this.cname = cname;}}
  1. 测试类代码，原理参见注释；请添加图片描述
  1. packagecom.five.jdbc.example;importcom.five.jdbc.common.DbUtils;importcom.five.jdbc.entity.Student;importjava.sql.*;importjava.util.ArrayList;importjava.util.List;importjava.util.Scanner;/**
  2.  * Description:分页查询
  3.  *
  4.  * @Author: kk(专业bug开发)
  5.  * DateTime: 2022-01-08 16:28
  6.  */publicclassPaginationExample{publicstaticvoidmain(String[] args){Scanner in =newScanner(System.in);System.out.println("请输入页号：");int page = in.nextInt();Connection conn =null;PreparedStatement pstmt =null;ResultSet rs =null;// 用于存放结果的listList<Student> list =newArrayList<>();try{
  7.             conn =DbUtils.getConnection();String sql ="select * from student limit ?,10";
  8.             pstmt = conn.prepareStatement(sql);
  9.             pstmt.setInt(1,(page-1)*10);
  10.             rs = pstmt.executeQuery();// 展开结果集数据库while(rs.next()){// 通过字段检索int id = rs.getInt("id");String name = rs.getString("name");String classname = rs.getString("classname");// 数据保存到实体类中Student stu =newStudent();
  11.                 stu.setId(id);
  12.                 stu.setName(name);
  13.                 stu.setCname(classname);
  14.                 list.add(stu);}System.out.println(list.size());}catch(ClassNotFoundException|SQLException e){
  15.             e.printStackTrace();}}}

JDBC中Date日期对象的处理

  1. 数据表新增日期字段；请添加图片描述
  2. 获取数据表日期；
  1. //JDBC获取日期的时候使用java.sql.Date,继承于java.util.DateDate sdate = rs.getDate("sdate");
  1. packagecom.five.jdbc.example;importjava.sql.*;importjava.util.Scanner;/**
  2.  * Description:
  3.  *
  4.  * @Author: kk(专业bug开发)
  5.  * DateTime: 2022-01-07 16:29
  6.  */publicclassJdbcExample{//    MySQL 8.0 以下版本 - JDBC 驱动名及数据库 URL//    static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";//    static final String DB_URL = "jdbc:mysql://localhost:3306/RUNOOB";//     MySQL 8.0 以上版本 - JDBC 驱动名及数据库 URLstaticfinalString JDBC_DRIVER ="com.mysql.cj.jdbc.Driver";staticfinalString DB_URL ="jdbc:mysql://localhost:3306/study?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC";// 数据库的用户名与密码，需要根据自己的设置staticfinalString USER ="root";staticfinalString PASS ="123456";publicstaticvoidmain(String[] args){Connection conn =null;//        Statement stmt = null;PreparedStatement pstmt =null;try{// 注册 JDBC 驱动Class.forName(JDBC_DRIVER);// 打开链接System.out.println("连接数据库...");
  7.             conn =DriverManager.getConnection(DB_URL, USER, PASS);// 执行查询System.out.println(" 实例化Statement对象...");System.out.println("请输入待查询的班级:");//            仔细看这部分代码，prepareStatement对sql进行了预编译Scanner in =newScanner(System.in);String cname = in.next();String sql="SELECT * FROM student where classname = ?";
  8.             pstmt= conn.prepareStatement(sql);
  9.             pstmt.setString(1, cname);ResultSet rs = pstmt.executeQuery();//             展开结果集数据库while(rs.next()){// 通过字段检索int id = rs.getInt("id");String name = rs.getString("name");String classname = rs.getString("classname");//JDBC获取日期的时候使用java.sql.Date,继承于java.util.DateDate sdate = rs.getDate("sdate");// 输出数据System.out.print("ID: "+ id);System.out.print(", 姓名: "+ name);System.out.print(", 班级: "+ classname);System.out.print(", 日期: "+ sdate);System.out.print("\n");}// 完成后关闭
  10.             rs.close();
  11.             pstmt.close();
  12.             conn.close();}catch(SQLException se){// 处理 JDBC 错误
  13.             se.printStackTrace();}catch(Exception e){// 处理 Class.forName 错误
  14.             e.printStackTrace();}finally{// 关闭资源try{if(pstmt !=null) pstmt.close();}catch(SQLException se2){}// 什么都不做try{if(conn !=null)
  15.                     conn.close();}catch(SQLException se){
  16.                 se.printStackTrace();}}System.out.println("Goodbye!");}}

请添加图片描述
3. 向数据表添加日期；

添加日期数据时获取到的是String类型
1.String转化为java.util.Date
2.java.util.Date转化为java.sql.Date

  1. // 1.String转化为java.util.Datejava.util.Date usdate =null;SimpleDateFormat sdf =newSimpleDateFormat("yyyy-MM-dd");try{
  2.       usdate = sdf.parse(sdate);}catch(ParseException e){
  3.        e.printStackTrace();}//2.java.util.Date转化为java.sql.Datelong time = usdate.getTime();//获取自1970年到现在的毫秒数//这个日期就是java.sql.Date格式java.sql.Date lsdate =newjava.sql.Date(time);
  1. packagecom.five.jdbc.example;importcom.five.jdbc.common.DbUtils;importjava.sql.Connection;importjava.sql.PreparedStatement;importjava.sql.SQLException;importjava.text.ParseException;importjava.text.SimpleDateFormat;importjava.util.Scanner;/**
  2.  * Description:
  3.  *
  4.  * @Author: kk(专业bug开发)
  5.  * DateTime: 2022-01-08 13:06
  6.  */publicclassInsertExample{publicstaticvoidmain(String[] args)throwsSQLException{Scanner in =newScanner(System.in);System.out.println("请输入学生编号：");int id = in.nextInt();System.out.println("请输入学生姓名：");String name = in.next();System.out.println("请输入学生班级：");String cname = in.next();System.out.println("请输入日期：");String sdate = in.next();Connection conn =null;PreparedStatement pstmt =null;// 1.String转化为java.util.Datejava.util.Date usdate =null;SimpleDateFormat sdf =newSimpleDateFormat("yyyy-MM-dd");try{
  7.             usdate = sdf.parse(sdate);}catch(ParseException e){
  8.             e.printStackTrace();}//2.java.util.Date转化为java.sql.Datelong time = usdate.getTime();//获取自1970年到现在的毫秒数java.sql.Date lsdate =newjava.sql.Date(time);//这个日期就是java.sql.Date格式try{
  9.             conn =DbUtils.getConnection();String sql ="insert into student(id,name,classname, sdate) values(?,?,?,?)";
  10.             pstmt = conn.prepareStatement(sql);
  11.             pstmt.setInt(1, id);
  12.             pstmt.setString(2, name);
  13.             pstmt.setString(3, cname);
  14.             pstmt.setDate(4, lsdate);int cnt  = pstmt.executeUpdate();//写操作影响的行数System.out.println("cnt"+ cnt);System.out.println(name ="添加成功啦！");}catch(ClassNotFoundException|SQLException e){
  15.             e.printStackTrace();}finally{DbUtils.closeConnection(null, pstmt, conn);}}}

请添加图片描述
请添加图片描述

JDBC批处理

  1. pstmt = conn.prepareStatement(sql);
  2. pstmt.addBatch();//将参数添加到批处理任务里面
  3. pstmt.executeBatch();//执行批处理任务

请添加图片描述
请添加图片描述
请添加图片描述

数据库连接池

数据库每次执行操作都会连接一次数据库，实际使用过程中频繁的连接务必会降低效率，数据库连接池可以在初始的时候进行数据库连接，需要时直接使用。

相关文档参见：参考文章

Druid连接池
  1. 官方地址 ： 官方地址

请添加图片描述
2. 项目引入jar包，新建配置文件；
请添加图片描述
配置文件代码：

  1. driverClassName=com.mysql.cj.jdbc.Driver
  2. url=jdbc:mysql://localhost:3306/study?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC
  3. username=root
  4. password=123456
  1. 使用流程
  • 1.导入jar包 druid-1.0.9.jar
  • 2.定义配置文件：properties形式的
  • 3.加载配置文件。Properties
  • 4.获取数据库连接池对象：通过工厂来来获取 DruidDataSourceFactory
  • 5.获取连接：getConnection
  1. 示例代码；
  1. packagecom.five.jdbc.example;importcom.alibaba.druid.pool.DruidDataSourceFactory;importcom.five.jdbc.common.DbUtils;importjavax.sql.DataSource;importjava.io.FileInputStream;importjava.net.URLDecoder;importjava.sql.Connection;importjava.sql.Date;importjava.sql.PreparedStatement;importjava.sql.ResultSet;importjava.util.Properties;/**
  2.  * Description:
  3.  *
  4.  * @Author: kk(专业bug开发)
  5.  * DateTime: 2022-01-08 18:01
  6.  */publicclassDruidExample{publicstaticvoidmain(String[] args)throwsException{//1.加载属性文件Properties properties =newProperties();String propertyFile =DruidExample.class.getResource("/druid-config.properties").getPath();try{
  7.             propertyFile =URLDecoder.decode(propertyFile,"UTF-8");
  8.             properties.load(newFileInputStream(propertyFile));}catch(Exception e){
  9.             e.printStackTrace();}Connection conn =null;PreparedStatement pstmt =null;ResultSet rs =null;try{//2.获取DataSource数据源对象DataSource dataSource =DruidDataSourceFactory.createDataSource(properties);//3.创建数据库连接
  10.             conn = dataSource.getConnection();
  11.             pstmt = conn.prepareStatement("select * from student limit 0,20");
  12.             rs = pstmt.executeQuery();//  展开结果集数据库while(rs.next()){// 通过字段检索int id = rs.getInt("id");String name = rs.getString("name");String classname = rs.getString("classname");//JDBC获取日期的时候使用java.sql.Date,继承于java.util.DateDate sdate = rs.getDate("sdate");// 输出数据System.out.print("ID: "+ id);System.out.print(", 姓名: "+ name);System.out.print(", 班级: "+ classname);System.out.print(", 日期: "+ sdate);System.out.print("\n");}}catch(Exception e){
  13.             e.printStackTrace();}finally{DbUtils.closeConnection(rs,pstmt,conn);}}}

请添加图片描述

C3P0连接池
  1. 官方地址 ： 官方地址

请添加图片描述

  1. 项目引入jar包，新建配置文件；请添加图片描述

配置文件代码：

  1. <?xml version="1.0" encoding="UTF-8"?><c3p0-config><!-- 使用默认的配置读取连接池对象 --><default-config><!--  连接参数 --><property name="driverClass">com.mysql.cj.jdbc.Driver</property><property name="jdbcUrl">jdbc:mysql://localhost:3306/study?useSSL=false&amp;allowPublicKeyRetrieval=true&amp;serverTimezone=UTC</property><property name="user">root</property><property name="password">123456</property><!-- 连接池参数 --><!--初始化的申请的连接数量--><property name="initialPoolSize">10</property><!--最大的连接数量--><property name="maxPoolSize">20</property><!--连接超时时间--><property name="checkoutTimeout">3000</property></default-config></c3p0-config>
  1. 示例代码；
  1. packagecom.five.jdbc.example;importjavax.sql.DataSource;importcom.five.jdbc.common.DbUtils;importcom.mchange.v2.c3p0.ComboPooledDataSource;importjava.sql.*;/**
  2.  * Description:
  3.  *
  4.  * @Author: kk(专业bug开发)
  5.  * DateTime: 2022-01-08 21:46
  6.  */publicclassC3P0Example{publicstaticvoidmain(String[] args)throwsSQLException{//1.加载配置文件//2.创建DataSourceDataSource dataSource =newComboPooledDataSource();//3.得到数据库连接Connection conn =null;PreparedStatement pstmt =null;ResultSet rs =null;try{
  7.             conn = dataSource.getConnection();
  8.             pstmt = conn.prepareStatement("select * from student limit 0,20");
  9.             rs = pstmt.executeQuery();// 展开结果集数据库while(rs.next()){// 通过字段检索int id = rs.getInt("id");String name = rs.getString("name");String classname = rs.getString("classname");//JDBC获取日期的时候使用java.sql.Date,继承于java.util.DateDate sdate = rs.getDate("sdate");// 输出数据System.out.print("ID: "+ id);System.out.print(", 姓名: "+ name);System.out.print(", 班级: "+ classname);System.out.print(", 日期: "+ sdate);System.out.print("\n");}}catch(Exception e){
  10.             e.printStackTrace();}finally{DbUtils.closeConnection(rs,pstmt,conn);}}}

请添加图片描述

Commons DBUtils使用

Commons DBUtils 是 Apache 组织提供的一个开源 JDBC工具类库，它是对JDBC的简单封装，学习成本极低，并且使用dbutils能极大简化JDBC编码的工作量，同时也不会影响程序的性能。

  1. 官方地址 ： 官方地址请添加图片描述
  2. 项目引入jar包；请添加图片描述
  3. 示例代码，使用时需要仔细看文档，因为操作简单导致内容略显复杂；
  1. packagecom.five.jdbc.example;importcom.alibaba.druid.pool.DruidDataSourceFactory;importcom.five.jdbc.common.DbUtils;importcom.five.jdbc.entity.Student;importorg.apache.commons.dbutils.QueryRunner;importorg.apache.commons.dbutils.handlers.BeanListHandler;importjavax.sql.DataSource;importjava.io.FileInputStream;importjava.net.URLDecoder;importjava.sql.Connection;importjava.sql.Date;importjava.sql.PreparedStatement;importjava.sql.ResultSet;importjava.util.List;importjava.util.Properties;/**
  2.  * Description:    DbUtils联合Druid演示
  3.  *
  4.  * @Author: kk(专业bug开发)
  5.  * DateTime: 2022-01-08 22:13
  6.  */publicclassDbUtilsExample{privatestaticvoidquery(){Properties properties =newProperties();String propertyFile =DbUtilsExample.class.getResource("/druid-config.properties").getPath();try{
  7.             propertyFile =URLDecoder.decode(propertyFile,"UTF-8");
  8.             properties.load(newFileInputStream(propertyFile));//2.获取DataSource数据源对象DataSource dataSource =DruidDataSourceFactory.createDataSource(properties);//关键语句，执行数据库操作QueryRunner qr =newQueryRunner(dataSource);List<Student> list = qr.query("select * from student limit ?,10",newBeanListHandler<>(Student.class),newObject[]{1});for(Student stu : list){System.out.print("ID: "+ stu.getId());System.out.print(", 姓名: "+ stu.getName());System.out.print(", 班级: "+ stu.getCname());System.out.print(", 日期: "+ stu.getSdate());System.out.print("\n");}}catch(Exception e){
  9.             e.printStackTrace();}}publicstaticvoidmain(String[] args){query();}}

总结

这部分内容我们一起学习了基础的JDBC到JDBC的开源工具，包括如何防止SQL注入、如何使用数据库连接池，所有的示例代码都是经过有效性验证的，一方面供给自己复习，另一方面供给一样在学习的小伙伴参考，如有错误欢迎指正~

标签： java 前端 mysql
本文转载自: https://blog.csdn.net/k1507157/article/details/122367217
版权归原作者 专业bug开发 所有， 如有侵权，请联系我们删除。
登录后发布评论

“一起学Java&mdash;&mdash;JDBC”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

网络安全法-网络运行安全

使用selenium/drissionpage时如何阻止chrome自动跳转http到https

docker desktop 里部署的Open WebUI 管理员密码忘记了的处理方法

在ubuntu20.04中搭建onsite比赛运行环境

利用开源的低代码表单设计器FcDesigner高效管理和渲染复杂表单结构

Kafka学习笔记

【前端】浏览器输入url到页面呈现发生了什么？