JDBC Apache—DBUtils 详解(通俗易懂)

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
云数据库 RDS MySQL,高可用系列 2核4GB
简介: JDBC 第六节 ApacheDBUtils详解!

目录

 

一、前言

二、Apache—DBUtils的引入

       1.传统使用ResultSet的缺点 :

       2.改进方法 :

       3.改进方法的模拟实现 :

三、Apache—DBUtils的使用

       1.基本介绍 :

       2.准备工作 :

       3.DBUtils查询(DQL) :

       4.query方法源码分析 :

       5.DBUtils处理(DML) :

四、总结


一、前言

    • 第六节内容,up打算和大家分享一下JDBC——ApacheDBUtils相关的内容。
    • 注意事项——代码中的注释也很重要;不要眼高手低;点击文章的侧边栏目录或者文章开头的目录可以进行跳转。
    • 良工不示人以朴,所有文章都会适时补充完善。大家如果有问题都可以在评论区进行交流或者私信up。 感谢阅读!

    二、Apache—DBUtils的引入

           1.传统使用ResultSet的缺点 :

           返回的结果集ResultSet与Connection是关联的,当调用Connection的close方法关闭连接后(放回连接池),ResultSet对象就不能用了。那么,如果出现“要求结果集复用”的需求,显然是办不到的。PS : 如果在关闭连接后仍调用ResultSet,会报异常,如下图所示 :

    image.gif 编辑

            就算是先用完ResultSet,再关闭Connection,ResultSet也只是使用了一次,这种对结果集的使用方式显然不利于数据的管理(说没就没)。

           传统使用ResultSet结果集的过程中,也让人感到不爽,如下图所示:

    image.gif 编辑

           我们只能使用固定的格式getXxx来获取表中对应的字段,不但容易在传入形参时出纰漏,而且getInt,getString等也不符合我们“见名知意”的原则。

           2.改进方法 :

           之前在JDBC API详解中,我们提到——ResultSet在使用过程中,底层实际是将表中的记录存放在了ArrayLIst集合中。而我们知道,ArrayList底层其实就是一个Object类型的数组elementData。既然如此,我们为什么不把ResultSet结果集中的记录取出来,专门放到一个存放表记录的ArrayList集合中去呢?

           于是,在这种念头的鼓动下,我们想出了以下的牛逼方法(不是我想出来的😂)——

    创造一个Java类用于对应一张表,该类中所有的属性对应表中的所有字段,即该类的每个对象都表示了表中的一条记录查询到表中有几条记录,就创建几个该类的实例,不同实例的属性可以自行设置。这样一来,我们只需要将该类的对象存放在ArrayList集合中,就实现了数据的“迁移”,结果集中的数据也得以复用。

           以上,这样的一个类我们称为POJO, 或者Domain,或者一个你早已听过的名字——JavaBean类。

           Apache—DBUtils就是为实现这种需求而诞生的一个工具类,它可以完美解决以上的问题。

           3.改进方法的模拟实现 :

                   在使用Apache—DBUtils工具类之前,我们先简单模拟一下该方法。遵循上文“改进方法”中的思想。我们试着来查询fruit表,fruit表如下 :

    image.gif编辑

                  Fruit的JavaBean类如下 :

    package apache_dbutils;
    /**
         MySQL的字段类型与JavaBean类属性的对应关系————
         (1) 数值型——>包装类(允许为null)
         (2) 字符串型——>String类
         (3) 日期类型——>Date类
     */
    public class Fruit {
        private Integer id;
        private String name;
        private Integer sweetness;
        public Fruit() {
        }
        public Fruit(Integer id, String name, Integer sweetness) {
            this.id = id;
            this.name = name;
            this.sweetness = sweetness;
        }
        public Integer getId() {
            return id;
        }
        public void setId(Integer id) {
            this.id = id;
        }
        public String getName() {
            return name;
        }
        public void setName(String name) {
            this.name = name;
        }
        public Integer getSweetness() {
            return sweetness;
        }
        public void setSweetness(Integer sweetness) {
            this.sweetness = sweetness;
        }
        @Override
        public String toString() {
            return "Fruit{" +
                    "id=" + id +
                    ", name='" + name + '\'' +
                    ", sweetness=" + sweetness +
                    '}';
        }
    }

    image.gif

                   接着我们在测试类中试着将Fruit类对象封装到ArrayList集合中,up以Advanced_Demo类为演示类,代码如下 :

    package apache_dbutils;
    import connection_pool.druid.JDBCUtilsDruid;
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.util.ArrayList;
    /**
     * @author : Cyan_RA9
     * @version : 21.0
     */
    public class Advanced_Demo {
        public static void main(String[] args) {
    //JDBC核心四部曲
        //1.注册驱动(底层根据druid.properties配置文件自动注册了驱动)
            //Class.forName("com.mysql.cj.jdbc.Driver");
        //2.获取连接
            Connection connection = null;
        //3.执行SQL
            PreparedStatement preparedStatement = null;
            ResultSet resultSet = null;
            ArrayList<Fruit> fruitArrayList = new ArrayList<>();
            String sql = "SELECT * FROM fruit " +
                            "WHERE `id` >= ?;";
            try {
                connection = JDBCUtilsDruid.getConnection();
                preparedStatement = connection.prepareStatement(sql);
                preparedStatement.setInt(1, 0);
                resultSet = preparedStatement.executeQuery();
                while (resultSet.next()) {
                    int id = resultSet.getInt("id");
                    String name = resultSet.getString("name");
                    int sweetness = resultSet.getInt("sweetness");
                    fruitArrayList.add(new Fruit(id, name, sweetness));
                }
            } catch (SQLException e) {
                throw new RuntimeException(e);
            } finally {
        //4.释放资源
                JDBCUtilsDruid.close(resultSet, preparedStatement, connection);
            }
            //关闭Connection后,轻松调用集合
            System.out.println("List = " + fruitArrayList);
            System.out.println("===================================");
            for (int i = 0; i < fruitArrayList.toArray().length; i++) {
                System.out.print("id = " + fruitArrayList.get(i).getId());
                System.out.print("\tname = " + fruitArrayList.get(i).getName());
                System.out.println();
            }
            /*
                在某些情况下,我们甚至可以返回该集合其他调用者使用。
                eg : return fruitArrayList;
             */
        }
    }

    image.gif

                   运行结果 :

    image.gif编辑


    三、Apache—DBUtils的使用

           1.基本介绍 :

            commons-dbutils是Apache组织提供的一个开源的JDBC工具类库,它是对JDBC的封装,使用dbutils能极大简化JDBC编程的工作量。

           dbutils中常用的类和接口如下——

      • QueryRunner类 : 该类封装了SQL的执行,并且是线程安全的;可以实现增删查改,并且支持批处理。
      • ResultSetHandler接口 : 该接口用于处理java.sql.ResultSet,将数据按照要求转换为另一种格式。常见实现类如下 :          
        1. ArrayHandler : 将结果集中的第一行数据转换成对象数组。
        2. ArrayListHandler : 将结果集中的每一行数据转换成对象数组,再存入List中。
        3. BeanHandler : 将结果集中的第一行数据封装到一个对应的JavaBean实例中(适用于返回单条记录的情况)。
        4. BeanListHandler : 将结果集中的每一行数据都封装到对应的JavaBean实例中,再存放到List集合中。
        5. ColumnListHandler : 将结果集中某一列的数据存放到List中。
        6. KeyedHandler(name) : 将结果集中的每行数据都封装到Map里,然后将所有的map再单独存放到一个map中,其key为指定的key。
        7. MapHandler : 将结果集中的第一行数据封装到一个Map里,key是列名,value就是对应的值。
        8. MapListHandler : 将结果集中的每一行数据都封装到Map里,再存入List。
        9. ScalarHandler : 将结果集中的一列映射为一个Object对象,适用于返回单行单列的情况。

                 2.准备工作 :

                         先去谷歌搜一下commons-dbutils-jar,进入官网下载Apache_DBUtils的jar包,如下图所示 :

          image.gif编辑

                         注意要选择Binaries,而不是Source,否则你下载的文件中没有jar包。

                         接着还是老规矩,将jar包复制到IDEA中存放jar包的目录下,然后导入当前项目,如下图所示 :

          image.gif编辑

                 3.DBUtils查询(DQL) :

                         仍然操作fruit表,如下所示 :

          image.gif编辑

                         up以ApacheDBUtils_Demo1类为演示类,代码如下 : (注意看注释)

          package apache_dbutils;
          import connection_pool.druid.JDBCUtilsDruid;
          import org.apache.commons.dbutils.QueryRunner;
          import org.apache.commons.dbutils.handlers.BeanListHandler;
          import java.sql.Connection;
          import java.sql.SQLException;
          import java.util.List;
          /**
           * @author : Cyan_RA9
           * @version : 21.0
           */
          public class ApacheDBUtils_Demo1 {
              public static void main(String[] args) throws SQLException {
              //核心四部曲
                  //1.注册驱动(根据druid.properties配置文件自动注册)
                  //Class.forName("com.mysql.cj.jdbc.Driver");
                  //2.获取连接
                  Connection connection = null;
                  connection = JDBCUtilsDruid.getConnection();
                  //3.执行SQL
                  QueryRunner queryRunner = new QueryRunner();
                  String sql = "SELECT * FROM fruit WHERE `id` >= ?;";
                  List<Fruit> query = queryRunner.query(connection, sql, new BeanListHandler<>(Fruit.class), 2);
                  /*
                      query方法复制执行SQL, 并将得到的结果集封装到ArrayList集合中, 然后返回;
                      PS : 底层得到的ResultSet结果集以及PreparedStatement会在query方法中自动关闭。
                      方法参数解读————
                      (1)connection : 当前使用的连接
                      (2)sql : 需要被执行的SQL
                      (3)new BeanListHandler<>(Fruit.class) : 底层通过反射机制获取到Fruit类的信息;
                          将ResultSet结果集中的每一条记录都封装到一个Fruit对象中,最后将这些对象
                          封装到ArrayList集合中。
                      (4)2 : 可变参数,传给sql中的?
                   */
                  System.out.println("query = " + query);
                  //4.释放资源
                  JDBCUtilsDruid.close(null, null, connection);
              }
          }

          image.gif

                         运行结果 :

          image.gif编辑

                 4.query方法源码分析 :

                         我们在query方法处下一个断点,如下图所示 :

          image.gif编辑

                         接着进入Debug。我们先跳入new BeanListHandler<>(Fruit.class)看看,如下所示 :    

          image.gif编辑

                         一目了然。上文“Apahce—DBUtils”的基本介绍中,我们说过,ResultSetHandler接口用于处理ResultSet结果集,这不,BeanListHandler实现了该接口。

                         并且,我们在query方法的形参列表new一个BeanListHandler时,是传入了一个Fruit类对应的Class对象(Fruit就是fruit表对应的JavaBean类),这个Class对象,最后会传递给BeanListHandler类的type成员变量,这么一来,BeanListHandler就可以通过反射get到了Fruit类的信息了。

                         继续,我们回去,跳入query方法,如下 :

          image.gif编辑

                         首次跳入其实是对我们可变参数中的2进行装箱,不管他。重新跳入query,如下 :

          image.gif编辑

                         经典“包皮”结构,可以看到,我们传入的四个形参都历历在目,并且可以直观的看到最后的可变参数。 但是,这个"this.query(...)",又是在干嘛呢?不着急,我们可以发现,新调用的query方法无非就是多传入了一个false布尔变量而已。直接跳进去看看,如下图所示 :

          image.gif编辑

                         这个query看似复杂,其实逻辑非常清楚,一开始就是一大串判断——连接是不是为空呀?要执行的sql是不是为空呀?传入的ResultSetHandler对象是不是为空呀?

                         只要有一个环节出了问题,就给你抛出一个异常,并打印出相关信息。当然了,眼尖的小伙伴儿还会发现其中有两个if (closeConn)的判断,如果成立会关闭连接(放回连接池),这个"closeConn"其实就是之前多出来的那个false布尔变量,那肯定就不进入if语句了呗。

                         我们继续往下看,最下面的else语句才是真正要完成执行SQL的操作滴。如所示 :

          else {
                      PreparedStatement stmt = null;
                      ResultSet rs = null;
                      T result = null;
                      try {
                          stmt = this.prepareStatement(conn, sql);
                          this.fillStatement(stmt, params);
                          rs = this.wrap(stmt.executeQuery());
                          result = rsh.handle(rs);
                      } catch (SQLException var33) {
                          this.rethrow(var33, sql, params);
                      } finally {
                          try {
                              this.close(rs);
                          } finally {
                              this.close(stmt);
                              if (closeConn) {
                                  this.close(conn);
                              }
                          }
                      }
                      return result;
                  }

          image.gif

                         噢,我们心心念念已久的PreparedStatement和ResultSet总算出现辽。可以看到,源码中也是先将对象置为null,之后才初始化的。值得一提的是这个result,直接告诉你结论,这个result就是query方法最终要返回的ArrayList类型的集合。

                         继续,这里的prepareStatement方法传入了conn和sql两个实参,其实追进去会发现还是原来那一套——通过连接来获取prepareStatement对象,如下图所示 :

          image.gif编辑

                         而fillStatement就是用你传入的可变参数来给sql中的?赋值

          image.gif编辑

                         再往下就是通过PreparedStatement对象来执行sql了,此处返回的是结果集。

          image.gif编辑

                         紧接着是handle方法执行,可以肯定的是,handle方法最终返回的一定是ArrayList类型的对象。 我们追进去handle方法看看,如下图所示 :

          image.gif编辑

                         又是经典包皮结构。别急,我们的目的很明确——找到return ArrayList的语句。继续往下追,如下图所示 :

          image.gif编辑

                         双层包皮结构?再往下追!如下 :

          image.gif编辑

                         诺,总算给我们找到了,的确是new了一个ArrayList类型的对象,并且最后给返回了。那么经过层层返回,最后这个ArrayList对象就会被赋值给query方法中的result,所以query方法最终也是返回了ArrayList类型的对象。

                         最后,query方法的finally语句中自动关闭了ResultSet和PreparedStatement,如下图所示 :

          image.gif编辑

                 5.DBUtils处理(DML) :

                         这次我们来操作学生表stus(id为自增长主键),如下图所示 :

          image.gif编辑

                         现要求——

                         ①向表中新插入一条“id = 6;name = 'Carl';sex = 'male';score=499”的记录;
                         ②修改name = Five的记录,令其score = 433;
                         ③删除id = 5的记录。

                         up以ApacheDBUtils_Demo2类为演示类,代码如下 :

          package apache_dbutils;
          import connection_pool.druid.JDBCUtilsDruid;
          import org.apache.commons.dbutils.QueryRunner;
          import java.sql.Connection;
          import java.sql.SQLException;
          public class ApacheDBUtils_Demo2 {
              public static void main(String[] args) throws SQLException {
              //JDBC核心四部曲
                  //1.注册驱动(底层会根据druid.properties配置文件中的信息自动注册驱动)
                  //Class.forName("com.mysql.cj.jdbc.Driver");
                  //2.获取连接
                  Connection connection = null;
                  connection = JDBCUtilsDruid.getConnection();
                  //3.执行SQL
                  String sql1 = "INSERT INTO stus " +
                                      "VALUES " +
                                      "(NULL,?,?,?);";
                  String sql2 = "UPDATE stus " +
                                      "SET score = ? " +
                                      "WHERE `name` = ?";
                  String sql3 = "DELETE FROM stus " +
                                      "WHERE id = ?";
                  QueryRunner queryRunner = new QueryRunner();
                  int affectedRows1 = queryRunner.update(connection, sql1, "Carl", "male", 499.0);
                  int affectedRows2 = queryRunner.update(connection, sql2, 433.0,"Five");
                  int affectedRows3 = queryRunner.update(connection, sql3, 5);
                  System.out.println("INSERT语句执行成功了吗?" + (affectedRows1 > 0 ? "Yes!" : "No!"));
                  System.out.println("UPDATE语句执行成功了吗?" + (affectedRows2 > 0 ? "Yes!" : "No!"));
                  System.out.println("DELETE语句执行成功了吗?" + (affectedRows3 > 0 ? "Yes!" : "No!"));
                  //4.释放资源
                  JDBCUtilsDruid.close(null,null,connection);
              }
          }

          image.gif

                         运行结果 :

          image.gif编辑

                         查询一下stus表,如下 :

          image.gif编辑

                         修改成功!


          四、总结

            • 🆗,以上就是JDBC系列博文第六节的全部内容了。
            • 总结一下,我们从"数据管理"和“结果复用”两个角度分析了传统使用ResultSet的弊端,从而引出了本节要学习的ApacheDBUtils工具类,该工具类可以将结果集中的数据转移到表对应的JavaBean类的实例中,然后将多个实例封装到集合中,便可以达到“复用结果集”的目的。大家需要掌握QueryRunner中query方法和update方法的使用,以及熟悉ResultSetHandler接口的几个常用实现类。
            • 下一节内容——JDBC BasicDAO,我们不见不散。感谢阅读!

                   System.out.println("END-----------------------------------------------------------------------------");

            相关实践学习
            如何在云端创建MySQL数据库
            开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
            全面了解阿里云能为你做什么
            阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
            目录
            相关文章
            |
            2月前
            |
            Java 大数据 数据库连接
            大数据-163 Apache Kylin 全量增量Cube的构建 手动触发合并 JDBC 操作 Scala
            大数据-163 Apache Kylin 全量增量Cube的构建 手动触发合并 JDBC 操作 Scala
            31 2
            大数据-163 Apache Kylin 全量增量Cube的构建 手动触发合并 JDBC 操作 Scala
            |
            6月前
            |
            监控 Java 数据库连接
            Java一分钟之-JDBC连接池:HikariCP, Apache DBCP, C3P0
            【6月更文挑战第14天】本文介绍了Java中常用的三种JDBC连接池——HikariCP、Apache DBCP和C3P0。HikariCP以其高性能和低延迟领先,适合高并发环境;Apache DBCP稳定易配置;C3P0则提供高度可定制选项。文章讨论了各连接池的常见问题及避免策略,如配置不当、连接泄露等,并给出示例代码以供参考。选择合适的连接池并正确配置能有效提升应用性能。
            143 7
            |
            7月前
            |
            Java 关系型数据库 数据库连接
            实时计算 Flink版操作报错之遇到错误org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'jdbc',该如何解决
            在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
            |
            7月前
            |
            Java 数据库连接 数据库
            Mybatis JDBC No enum constant org.apache.ibatis.type.JdbcType.TEXT异常处理
            Mybatis JDBC No enum constant org.apache.ibatis.type.JdbcType.TEXT异常处理
            331 0
            |
            Java 关系型数据库 MySQL
            [1.2.0新功能系列:二] Apache Doris 1.2.0 JDBC外表 及 Mutil Catalog
            [1.2.0新功能系列:二] Apache Doris 1.2.0 JDBC外表 及 Mutil Catalog
            173 0
            |
            SQL druid Java
            JDBC BasicDAO详解(通俗易懂)
            JDBC 第七节 详解BasicDAO 通俗易懂!
            155 0
            |
            监控 druid Java
            JDBC 连接池 详解(通俗易懂)
            JDBC 第五节 详解连接池 通俗易懂!
            549 0
            |
            SQL Java 关系型数据库
            JDBC 事务和批处理 详解(通俗易懂)
            JDBC 第四节 事务和批处理详解!
            314 0
            |
            SQL Java 数据库连接
            JDBC Utils 详解(通俗易懂)
            JDBC 第三节 Utils工具类详解!
            102 0
            |
            SQL 存储 Java
            JDBC API 万字详解(通俗易懂)
            JDBC 第二节 详解API 通俗易懂!
            396 0

            推荐镜像

            更多