ToB企服应用市场:ToB评测及商务社交产业平台

标题: JDBC [打印本页]

作者: 郭卫东    时间: 2022-9-16 17:22
标题: JDBC
JDBC

一、JDBC概述

什么是JDBC?


JDBC 是使用 Java 语言操作关系型数据库的一套 API。这套 API 是交由不同的数据库厂商实现的。我们利用 JDBC 编写操作数据库的代码,真正执行的是各个数据库的实现类(驱动)。
全称:(Java DataBase Connectivity)Java 数据库连接。
JDBC的好处

二、使用JDBC

环境配置
  1. <dependency>
  2.     <groupId>mysql</groupId>
  3.     <artifactId>mysql-connector-java</artifactId>
  4.     <version>8.0.29</version>
  5. </dependency>
复制代码
编码

步骤

代码实现
  1. public static void demo(){
  2.     Connection conn = null;
  3.     Statement state = null;
  4.     try {
  5.         // 1.注册驱动
  6.         Class.forName("com.mysql.cj.jdbc.Driver");
  7.         // 2.获取连接
  8.         conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "root");
  9.         // 3.定义SQL
  10.         String sql = "select * from user";
  11.         // 4.获取Statement对象
  12.         state = conn.createStatement();
  13.         // 5.执行SQL
  14.         ResultSet resultSet = state.executeQuery(sql);
  15.         // 6.处理返回结果
  16.         System.out.println(resultSet);
  17.     } catch (ClassNotFoundException | SQLException e) {
  18.         e.printStackTrace();
  19.     } finally {
  20.         // 7.关闭资源
  21.         if (state != null) {
  22.             try {
  23.                 state.close();
  24.             } catch (SQLException e) {
  25.                 e.printStackTrace();
  26.             }
  27.         }
  28.         if (conn != null) {
  29.             try {
  30.                 conn.close();
  31.             } catch (SQLException e) {
  32.                 e.printStackTrace();
  33.             }
  34.         }
  35.     }
  36. }
复制代码
注意

三、JDBC API

DriverManager

作用

这两个作用对应着两个方法:
方法作用getConnection(String url, String user, String password)通过给定的URL与数据库建立连接,并返回连接对象registerDriver(Driver driver)注册给定的驱动 DriverMysql 驱动底层通过静态代码块调用了DriverManager的registerDriver方法,所以我们不必去显式的进行驱动的注册,它已经帮我们注册好了。
  1. public class Driver extends NonRegisteringDriver implements java.sql.Driver {
  2.     public Driver() throws SQLException {
  3.     }
  4.     static {
  5.         try {
  6.             DriverManager.registerDriver(new Driver());
  7.         } catch (SQLException var1) {
  8.             throw new RuntimeException("Can't register driver!");
  9.         }
  10.     }
  11. }
复制代码
注意

如果导入 MySQL5 之后的驱动 jar包,可以不用写 Class.forName("com.mysql.cj.jdbc.Driver");,Driver 会自动读取 java.sql.Driver文件中的驱动类全限定名,进行驱动的注册。

Connection

作用

执行SQL的对象

事务管理

方法说明setAutoCommit(boolean)开启事务。true:自动提交事务,false:开启手动提交事务commit()提交事务rollback()回滚事务
  1. try {
  2.     // 开启事务
  3.     conn.setAutoCommit(false);
  4.     // 执行操作一
  5.     int i = state.executeUpdate(sql1);
  6.     System.out.println(i);
  7.     // 制造异常
  8.     int j = 1/0;
  9.     // 执行操作二
  10.     int i1 = state.executeUpdate(sql2);
  11.     System.out.println(i1);
  12.     // 提交事务
  13.     conn.commit();
  14. } catch (Exception e) {
  15.     // 事务回滚
  16.     conn.rollback();
  17.     e.printStackTrace();
  18. }
复制代码
Statement

作用

执行 sql 语句。
方法

方法说明int executeUpdate(String sql)执行给定的SQL语句,这可能是 INSERT , UPDATE ,或 DELETE语句,或者不返回任何内容,如SQL DDL语句的SQL语句。并返回受影响的行数。ResultSet executeQuery(String sql)执行给定的SQL语句,该语句返回单个 ResultSet对象。ResultSet

作用

封装了查询语句的执行结果,Statement 或者 PreparedStatement 通过执行 executeQuery 方法返回 ResultSet 对象。
方法

方法说明getXxx()获取每行中各个数据,可以传入 列号(从1开始) 或者 列名next()向下移动指针,判断该行是否有数据。
  1. // 6.处理返回结果
  2. while (resultSet.next()) {
  3.     String name = resultSet.getString("name");
  4.     System.out.println(name);
  5.     String password = resultSet.getString(3);
  6.     System.out.println(password);
  7. }
复制代码
PerparedStatement

作用

执行 sql 语句,但是它会对 SQl 语句进行预编译,可以防止 SQl 注入攻击。并且 PreparedStatement 继承自 Statement 。
SQl注入

在编译之前利用 SQl 语句的拼接,输入特殊字符串修改定义好的 SQL 语句,改变 SQL 语句的语义。
一个简单的 SQL 注入演示:
(比如是有一个用户登录的场景,在 DAO 层中进行数据库操作)
  1. String sql = "select * from user where username='"+admin+"' and password='"+'or'1'='1+"'";
复制代码
用户密码一看就不正经,但是可以看一下拼接好的 SQL 语句是怎样的:
  1. select * from user where username='admin' and password=''or'1'='1'
复制代码
password 变成了空字符串,在 SQL 语句的尾部 拼接了 or '1'='1' 。username 和 password 查询为false,但是接着又 or 一个恒等式,整体结果就变成了 true,将会查询出所有结果。
预编译

PreparedStatement 的使用步骤:
  1. // 3.定义SQL
  2. String sql = "select * from user where name=? and password=?";
  3. // 4.获取PreparedStatement对象
  4. PreparedStatement statement = conn.prepareStatement(sql);
  5. // 4.5替换占位符
  6. statement.setString(1,"黑夫");
  7. statement.setString(2,"123");
  8. // 5.执行SQL
  9. ResultSet resultSet = statement.executeQuery();
复制代码
在定义 SQL 语句时,SQL 中未知字段使用 ? 进行占位。
可以看到在获取 PreparedStatement 对象的同时,就需要将 SQL 传入,这时会将 SQL 语句发送给 mysql 服务器,进行检查语法、编译等。
为什么能达到防止 SQL 注入的效果?
SQL 语句在执行之前已经进行了编译,它的结构已经被固定下来,当运行时动态地把参数传给 PreprareStatement 时,即使参数里有敏感字符如 or '1=1'数据库会将它作为一个参数一个字段的属性值来处理而不会作为一个 SQL 指令。而且 PreparedStatement 在用具体字段替换占位符时,会对特殊字符进行转义,比如单引号 ' 会转义为 \'。如此,可以有效的防止 SQL 注入。
可以在 url 后面加上命令开启预编译:useServerPrepStmts=true。不写这句,仍会对特殊字符进行转义。
  1. jdbc:mysql://localhost:3306/test?useSSL=false&useServerPrepStmts=true
复制代码
useSSL=false 表示不进行安全连接。
预编译的好处

关于更多 PreparedStatement 的了解,看这篇博文:
预编译语句(Prepared Statements)介绍,以MySQL为例
四、数据库连接池

简介

数据库连接池是负责分配、管理和释放数据库连接的容器,它允许应用程序重复使用一个现有的数据库连接,而不是再重新建立一个。
对于多用户的应用,如果为每一个用户都创建一个数据库连接,毫无疑问是对资源的浪费,同时也浪费时间。我们应当在系统加载的时候就将数据库资源创建好,不推荐运行时再去开启资源。做到对资源的统一管理,从而避免资源浪费,提升响应速度。
使用

SUN 公司提供了数据库连接池的标准接口 DataSource 由第三方组织进行实现。
推荐使用 Druid 数据库连接池技术。
环境搭建
  1. <dependency>
  2.     <groupId>com.alibaba</groupId>
  3.     <artifactId>druid</artifactId>
  4.     <version>1.2.11</version>
  5. </dependency>
复制代码
在resources目录下新建 druid.properties 配置文件
  1. driverClassName = com.mysql.cj.jdbc.Driver
  2. url = jdbc:mysql://localhost:3306/test
  3. username = root
  4. password = root
  5. # 初始化连接数
  6. initialSize = 5
  7. # 最大连接数
  8. maxActive = 10
  9. # 最大等待时间
  10. maxWait = 3000
复制代码
maxWait 表示如果连接池中没有空闲连接的最大等待时间,超过时间则会抛出异常。
更多配置参考:Configuration reference
获取连接
  1. // 1.加载配置文件
  2. Properties properties = new Properties();
  3. properties.load(ClassLoader.getSystemResourceAsStream("druid.properties"));
  4. // 2.获取连接
  5. DataSource dataSource = DruidDataSourceFactory.createDataSource(properties);
  6. conn = dataSource.getConnection();
复制代码
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!




欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4