AI专业者开发社区 1 号成员
  •  0 回帖  •  2 浏览  •  4 个月前
 

|NO.Z.00106|——————————|BigDataEnd|——|Java&MySQL.数据库连接池和DBUtils.V15|——|MySQL.v16|QueryRunner类|结果集处理接口|

一、QueryRunner 实现查询操作
### --- ResultSetHandler 接口简介

——>        ResultSetHandler可以对查询出来的ResultSet结果集进行处理，达到一些业务上的需求。

### --- ResultSetHandler 结果集处理类

——>        本例展示的是使用ResultSetHandler接口的几个常见实现类实现数据库的增删改查，
——>        可以大大减少代码量，优化程序。
——>        每一种实现类都代表了对查询结果集的一种处理方式

ResultSetHandler实现类
 说明
ArrayHandler
将结果集中的第一条记录封装到一个 Object[] 数组中，
数组中的每一个元素就是这条记录中的每一个字段的值
ArrayListHandler
将结果集中的每一条记录都封装到一个 Object[] 数组中，
将这些数组在封装到 List 集合中。
BeanHandler  将结果集中第一条记录封装到一个指定的 javaBean 中.
BeanListHandler
将结果集中每一条记录封装到指定的 javaBean 中，
再将这些 javaBean 在封装到 List 集合中
ColumnListHandler 将结果集中指定的列的字段值，封装到一个 List 集合中
KeyedHandler
将结果集中每一条记录封装到 Map,在将这个 map 集合做为
另一个Map 的 value 另一个 Map 集合的 key 是指定的字段的值。
MapHandler
将结果集中第一条记录封装到了 Map集合中，
key 就是字段名称，value 就是字段值
MapListHandler
将结果集中每一条记录封装到了 Map集合中，
key 就是字段名称，value 就是字段值，在将这些 Map 封装到 List 集合中。
ScalarHandler  它是用于封装单个数据。例如 select count(*) from 表操作。 
### --- ResultSetHandler 常用实现类测试

——>        QueryRunner的查询方法
——>        query方法的返回值都是泛型,具体的返回值类型,会根据结果集的处理方式,发生变化

方法 说明
query(String sql, handler ,Object[] param)  自动模式创建 QueryRunner, 执行查询 <b
query(Connection con,String sql,handler,Object[] param) 手动模式创建 QueryRunner, 执行查询 
### --- 创建一个测试类, 对 ResultSetHandler 接口的几个常见实现类进行测试

——>        查询id为5的记录,封装到数组中
——>        查询所有数据,封装到List集合中
——>        查询id为5的记录,封装到指定JavaBean中
——>        查询薪资大于 3000 的所员工信息,封装到JavaBean中再封装到List集合中
——>        查询姓名是 张百万的员工信息,将结果封装到Map集合中
——>        查询所有员工的薪资总额

二、查询 id 为 5 的记录, 封装到数组中
### --- 查询 id 为 5 的记录, 封装到数组中

/*
* 查询id为5的记录,封装到数组中
 * ArrayHandler 将结果集的第一条数据封装到数组中
  /

@Test
public void testFindById() throws SQLException {

<span class="hljs-comment">//1.创建QueryRunner</span>
<span class="hljs-type">QueryRunner</span> <span class="hljs-variable">qr</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">QueryRunner</span>(DruidUtils.getDataSource());
<span class="hljs-comment">//2.编写SQL</span>
<span class="hljs-type">String</span> <span class="hljs-variable">sql</span> <span class="hljs-operator">=</span> <span class="hljs-string">"select * from employee where eid = ?"</span>;

<span class="hljs-comment">//3.执行查询</span>
Object[] query = qr.query(sql, <span class="hljs-keyword">new</span> <span class="hljs-title class_">ArrayHandler</span>(), <span class="hljs-number">5</span>);

<span class="hljs-comment">//4.获取数据</span>
System.out.println(Arrays.toString(query));



}

三、查询所有数据, 封装到 List 集合中
### --- 查询所有数据, 封装到 List 集合中

/**
* 查询所有数据, 封装到 List 集合中
 ArrayListHandler 可以将每条数据先封装到数组中, 再将数组封装到集合中

*/

@Test
public void testFindAll() throws SQLException {
    //1. 创建 QueryRunner
    QueryRunner qr = new QueryRunner(DruidUtils.getDataSource());

<span class="hljs-comment">//2.编写SQL</span>
<span class="hljs-type">String</span> <span class="hljs-variable">sql</span> <span class="hljs-operator">=</span> <span class="hljs-string">"select * from employee"</span>;

<span class="hljs-comment">//3.执行查询</span>
List&lt;Object[]&gt; query = qr.query(sql, <span class="hljs-keyword">new</span> <span class="hljs-title class_">ArrayListHandler</span>());

<span class="hljs-comment">//4.遍历集合获取数据</span>
<span class="hljs-keyword">for</span> (Object[] objects : query) {
    System.out.println(Arrays.toString(objects));
}



}

四、根据 ID 查询, 封装到指定 JavaBean 中
### --- 根据 ID 查询, 封装到指定 JavaBean 中

/**


    

  • 查询id为 3 的记录, 封装到指定 JavaBean 中
    • 

  • BeanHandler 将结果集的第一条数据封装到 javaBean 中
    • 

  • 



**/

@Test
    public void testFindByIdJavaBean() throws SQLException {
    QueryRunner qr = new QueryRunner(DruidUtils.getDataSource());
    String sql = "select * from employee where eid = ?";
    Employee employee = qr.query(sql, new BeanHandler<Employee>(Employee.class), 3);
    System.out.println(employee);
}
五、查询薪资大于 3000 的所员工信息, 封装到 JavaBean 中再封装到 List 集合中
### --- 查询薪资大于 3000 的所员工信息, 封装到 JavaBean 中再封装到 List 集合中

/*
* 查询薪资大于 3000 的所员工信息,封装到JavaBean中再封装到List集合中
 * BeanListHandler 将结果集的每一条和数据封装到 JavaBean中 再将JavaBean 放到list集合中
  /

@Test
public void testFindBySalary() throws SQLException {
        QueryRunner qr = new QueryRunner(DruidUtils.getDataSource());
        String sql = "select * from employee where salary > ?";
        List<Employee> list = qr.query(sql, new BeanListHandler<Employee>(Employee.class),3000);

    <span class="hljs-keyword">for</span> (Employee employee : list) {
        System.out.println(employee);
    }



}

六、 查询姓名是 张百万的员工信息, 将结果封装到 Map 集合中
### --- 查询姓名是 张百万的员工信息, 将结果封装到 Map 集合中

/*
 查询姓名是 张百万的员工信息, 将结果封装到 Map 集合中
 MapHandler 将结果集的第一条记录封装到 Map<String,Object>中
 key 对应的是 列名 value 对应的是 列的值
 */

@Test
public void testFindByName() throws SQLException {
    QueryRunner qr = new QueryRunner(DruidUtils.getDataSource());
    String sql = "select * from employee where ename = ?";
    Map<String, Object> map = qr.query(sql, new MapHandler(), "张百万");
    Set<Map.Entry<String, Object>> entries = map.entrySet();
    for (Map.Entry<String, Object> entry : entries) {
        // 打印结果
        System.out.println(entry.getKey() +"=" +entry.getValue());
    }
}
七、查询所有员工的薪资总额
### --- 查询所有员工的薪资总额

/*
* 查询所有员工的薪资总额
 * ScalarHandler 用于封装单个的数据
  /

@Test
public void testGetSum() throws SQLException {
    QueryRunner qr = new QueryRunner(DruidUtils.getDataSource());
    String sql = "select sum(salary) from employee";
    Double sum = (Double)qr.query(sql, new ScalarHandler<>());
    System.out.println("员工薪资总额:" + sum);
}
八、sql 语句
package com.yanqi.testDBUtils;

    <span class="hljs-keyword">import</span> com.yanqi.entity.Employee;
    <span class="hljs-keyword">import</span> com.yanqi.utils.DruidUtils;
    <span class="hljs-keyword">import</span> org.apache.commons.dbutils.QueryRunner;
    <span class="hljs-keyword">import</span> org.apache.commons.dbutils.handlers.*;
    <span class="hljs-keyword">import</span> org.junit.Test;

    <span class="hljs-keyword">import</span> java.sql.SQLException;
    <span class="hljs-keyword">import</span> java.util.Arrays;
    <span class="hljs-keyword">import</span> java.util.List;
    <span class="hljs-keyword">import</span> java.util.Map;
    <span class="hljs-keyword">import</span> java.util.Set;



public class DBUtilsDemo03 {


<span class="hljs-comment">/*
 *   查询id为5的记录,封装到数组中
 *   ArrayHandler 将结果集的第一条数据封装到数组中
 * */</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">testFindById</span><span class="hljs-params">()</span> <span class="hljs-keyword">throws</span> SQLException {

    <span class="hljs-comment">//1.创建QueryRunner</span>
    <span class="hljs-type">QueryRunner</span> <span class="hljs-variable">qr</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">QueryRunner</span>(DruidUtils.getDataSource());

    <span class="hljs-comment">//2.编写SQL</span>
    <span class="hljs-type">String</span> <span class="hljs-variable">sql</span> <span class="hljs-operator">=</span> <span class="hljs-string">"select * from employee where eid = ?"</span>;

    <span class="hljs-comment">//3.执行查询</span>
    Object[] query = qr.query(sql, <span class="hljs-keyword">new</span> <span class="hljs-title class_">ArrayHandler</span>(), <span class="hljs-number">5</span>);

    <span class="hljs-comment">//4.获取数据</span>
    System.out.println(Arrays.toString(query));
}

<span class="hljs-comment">/**
 * 查询所有数据,封装到List集合中
 * ArrayListHandler可以将每条数据先封装到数组中, 再将数组封装到集合中
 *
 */</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">testFindAll</span><span class="hljs-params">()</span> <span class="hljs-keyword">throws</span> SQLException {

    <span class="hljs-comment">//1.创建QueryRunner</span>
    <span class="hljs-type">QueryRunner</span> <span class="hljs-variable">qr</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">QueryRunner</span>(DruidUtils.getDataSource());

    <span class="hljs-comment">//2.编写SQL</span>
    <span class="hljs-type">String</span> <span class="hljs-variable">sql</span> <span class="hljs-operator">=</span> <span class="hljs-string">"select * from employee"</span>;

    <span class="hljs-comment">//3.执行查询</span>
    List&lt;Object[]&gt; query = qr.query(sql, <span class="hljs-keyword">new</span> <span class="hljs-title class_">ArrayListHandler</span>());

    <span class="hljs-comment">//4.遍历集合获取数据</span>
    <span class="hljs-keyword">for</span> (Object[] objects : query) {
        System.out.println(Arrays.toString(objects));
    }
}

<span class="hljs-comment">/**
 * 查询id为3的记录,封装到指定JavaBean中
 * BeanHandler 将结果集的第一条数据封装到 javaBean中
 *
 **/</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">testFindByIdJavaBean</span><span class="hljs-params">()</span> <span class="hljs-keyword">throws</span> SQLException {

    <span class="hljs-type">QueryRunner</span> <span class="hljs-variable">qr</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">QueryRunner</span>(DruidUtils.getDataSource());

    <span class="hljs-type">String</span> <span class="hljs-variable">sql</span> <span class="hljs-operator">=</span> <span class="hljs-string">"select * from employee where eid = ?"</span>;

    <span class="hljs-type">Employee</span> <span class="hljs-variable">employee</span> <span class="hljs-operator">=</span> qr.query(sql, <span class="hljs-keyword">new</span> <span class="hljs-title class_">BeanHandler</span>&lt;Employee&gt;(Employee.class), <span class="hljs-number">3</span>);

    System.out.println(employee);
}

<span class="hljs-comment">/*
 * 查询薪资大于 3000 的所员工信息,封装到JavaBean中再封装到List集合中
 * BeanListHandler 将结果集的每一条和数据封装到 JavaBean中 再将JavaBean 放到list集合中
 * */</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">testFindBySalary</span><span class="hljs-params">()</span> <span class="hljs-keyword">throws</span> SQLException {

    <span class="hljs-type">QueryRunner</span> <span class="hljs-variable">qr</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">QueryRunner</span>(DruidUtils.getDataSource());

    <span class="hljs-type">String</span> <span class="hljs-variable">sql</span> <span class="hljs-operator">=</span> <span class="hljs-string">"select * from employee where salary &gt; ?"</span>;

    List&lt;Employee&gt; list = qr.query(sql, <span class="hljs-keyword">new</span> <span class="hljs-title class_">BeanListHandler</span>&lt;Employee&gt;(Employee.class), <span class="hljs-number">3000</span>);

    <span class="hljs-keyword">for</span> (Employee employee : list) {
        System.out.println(employee);
    }
}

<span class="hljs-comment">/*
 * 查询姓名是 张百万的员工信息,将结果封装到Map集合中
 * MapHandler 将结果集的第一条记录封装到 Map&lt;String,Object&gt;中
 * key对应的是 列名 value对应的是 列的值
 * */</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">testFindByName</span><span class="hljs-params">()</span> <span class="hljs-keyword">throws</span> SQLException {

    <span class="hljs-type">QueryRunner</span> <span class="hljs-variable">qr</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">QueryRunner</span>(DruidUtils.getDataSource());

    <span class="hljs-type">String</span> <span class="hljs-variable">sql</span> <span class="hljs-operator">=</span> <span class="hljs-string">"select * from employee where ename = ?"</span>;

    Map&lt;String, Object&gt; map = qr.query(sql, <span class="hljs-keyword">new</span> <span class="hljs-title class_">MapHandler</span>(), <span class="hljs-string">"张百万"</span>);

    Set&lt;Map.Entry&lt;String, Object&gt;&gt; entries = map.entrySet();

    <span class="hljs-keyword">for</span> (Map.Entry&lt;String, Object&gt; entry : entries) {
        <span class="hljs-comment">//打印结果</span>
        System.out.println(entry.getKey() +<span class="hljs-string">" = "</span> +entry.getValue());
    }
}

<span class="hljs-comment">/*
 *  查询所有员工的薪资总额
 *  ScalarHandler 用于封装单个的数据
 * */</span>
<span class="hljs-meta">@Test</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">testGetSum</span><span class="hljs-params">()</span> <span class="hljs-keyword">throws</span> SQLException {

    <span class="hljs-type">QueryRunner</span> <span class="hljs-variable">qr</span> <span class="hljs-operator">=</span> <span class="hljs-keyword">new</span> <span class="hljs-title class_">QueryRunner</span>(DruidUtils.getDataSource());

    <span class="hljs-type">String</span> <span class="hljs-variable">sql</span> <span class="hljs-operator">=</span> <span class="hljs-string">"select sum(salary) from employee"</span>;

    <span class="hljs-type">Double</span> <span class="hljs-variable">sum</span> <span class="hljs-operator">=</span> (Double)qr.query(sql, <span class="hljs-keyword">new</span> <span class="hljs-title class_">ScalarHandler</span>&lt;&gt;());

    System.out.println(<span class="hljs-string">"员工薪资总额: "</span> + sum);
}



}

九、打印输出
D:\JAVA\jdk-11.0.2\bin\java.exe -ea -Didea.test.cyclic.buffer.size=1048576 "-javaagent:D:\IntelliJIDEA\IntelliJ IDEA 2019.3.3\lib\idea_rt.jar=58268:D:\IntelliJIDEA\IntelliJ IDEA 2019.3.3\bin" -Dfile.encoding=UTF-8 -classpath "D:\IntelliJIDEA\IntelliJ IDEA 2019.3.3\lib\idea_rt.jar;D:\IntelliJIDEA\IntelliJ IDEA 2019.3.3\plugins\junit\lib\junit5-rt.jar;D:\IntelliJIDEA\IntelliJ IDEA 2019.3.3\plugins\junit\lib\junit-rt.jar;E:\NO.Z.10000——javaproject\NO.H.00002.mysql\mysql\out\production\mysql.jdbc_task06;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\dom4j-1.6.1.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\druid-1.0.9.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\c3p0-0.9.5.2.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\commons-dbcp-1.4.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\jaxen-1.1-beta-6.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\commons-pool-1.5.6.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\commons-dbutils-1.6.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\mchange-commons-java-0.2.12.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\mysql-connector-java-5.1.37-bin.jar;C:\Users\Administrator\.m2\repository\org\testng\testng\6.14.3\testng-6.14.3.jar;C:\Users\Administrator\.m2\repository\com\beust\jcommander\1.72\jcommander-1.72.jar;C:\Users\Administrator\.m2\repository\org\apache-extras\beanshell\bsh\2.0b6\bsh-2.0b6.jar;C:\Users\Administrator\.m2\repository\org\junit\jupiter\junit-jupiter\5.4.2\junit-jupiter-5.4.2.jar;C:\Users\Administrator\.m2\repository\org\junit\jupiter\junit-jupiter-api\5.4.2\junit-jupiter-api-5.4.2.jar;C:\Users\Administrator\.m2\repository\org\apiguardian\apiguardian-api\1.0.0\apiguardian-api-1.0.0.jar;C:\Users\Administrator\.m2\repository\org\opentest4j\opentest4j\1.1.1\opentest4j-1.1.1.jar;C:\Users\Administrator\.m2\repository\org\junit\platform\junit-platform-commons\1.4.2\junit-platform-commons-1.4.2.jar;C:\Users\Administrator\.m2\repository\org\junit\jupiter\junit-jupiter-params\5.4.2\junit-jupiter-params-5.4.2.jar;C:\Users\Administrator\.m2\repository\org\junit\jupiter\junit-jupiter-engine\5.4.2\junit-jupiter-engine-5.4.2.jar;C:\Users\Administrator\.m2\repository\org\junit\platform\junit-platform-engine\1.4.2\junit-platform-engine-1.4.2.jar;C:\Users\Administrator\.m2\repository\junit\junit\4.12\junit-4.12.jar;C:\Users\Administrator\.m2\repository\org\hamcrest\hamcrest-core\1.3\hamcrest-core-1.3.jar" com.intellij.rt.junit.JUnitStarter -ideVersion5 -junit4 com.yanqi.testDBUtils.DBUtilsDemo03,testFindAll
8月 05, 2021 10:32:46 下午 com.alibaba.druid.pool.DruidDataSource info
信息: {dataSource-1} inited
[2, 林黛玉, 20, 女, 5000.0, 2019-03-14]
[3, 杜甫, 40, 男, 6000.0, 2020-01-01]
[4, 李白, 25, 男, 3000.0, 2017-10-01]
[5, 张百万, 20, 女, 15000.0, 1990-12-26]

Process finished with exit code 0

 
 
 
 
 
 
 
 
 
Walter Savage Landor:strove with none,for none was worth my strife.Nature I loved and, next to Nature, Art:I warm'd both hands before the fire of life.It sinks, and I am ready to depart
                                                                                                                                                   ——W.S.Landor