commons-dbutils数据库工具包的基本使用

古城微笑少年丶 2021-10-19 02:00 511阅读 0赞

**目录**

一、简介：

二、主要类与相关接口介绍

DbUtils类

QueryRunner类

ResultSetHandler接口

三、测试示例：

--------------------

# 一、简介： #

commons-dbutils是Apache开源组织提供的用于操作数据库的工具包。对于数据库的操作无外乎就是【增删改查】，本质上只是SQL语法的不同。

一个普通的查询操作其处理过程如下：

1.  创建Connection连接。
2.  创建Statement。
3.  执行SQL生成ResultSet，历遍ResultSet中的所有行记录提取列数据并转换成所需的对象。
4.  释放资源。

DBUtils是在JDBC的基础上做了一层封装，解决了两个问题：

1.  自动创建和释放连接资源，不再有泄漏问题。
2.  自动将Result转换成对象。填入不同的ResultSetHandler，可将ResultSet转换成不同的对象。

# 二、主要类与相关接口介绍 #

## ***DbUtils**类*** ##

DbUtils主要是提供了一些加载JDBC驱动以及关闭连接的静态方法。

**DbUtils****.loadDriver(****String****driverClassName****)** // 加载并注册数据库驱动

**DbUtils.close(Connection conn) // 关闭连接**

**DbUtils.close(Statement stmt)**

**DbUtils.close(ResultSet rs)**

**DbUtils.closeQuietly(Connection conn) // 关闭连接，并忽略异常**

**DbUtils.closeQuietly(Statement stmt)**

**DbUtils.closeQuietly(ResultSet rs)**

**DbUtils.closeQuietly(Connection conn, Statement stmt, ResultSet rs)**

**DbUtils.commitAndCloseQuietly(Connection conn) // 提交连接，然后关闭连接**

**DbUtils.rollback(Connection conn) // 回滚操作**

## ***Q**ueryRunner**类*** ##

该类简单化了 SQL 查询，它与 ResultSetHandler接口（后面将会介绍） 组合在一起使用可以完成大部分的数据库操作，能够大大减少编码量

**QueryRunner()// 构造方法**

**QueryRunner(DataSource ds)**

**query(String sql, ResultSetHandler<T> rsh) // 查询**

**query(String sql, ResultSetHandler<T> rsh, Object... params)**

**query(Connection conn, String sql, ResultSetHandler<T> rsh)**

**query(Connection conn, String sql, Object param, ResultSetHandler<T> rsh)**

**update(String sql) // 更新**

**update(String sql, Object... params)**

**update(Connection conn, String sql)**

**update(Connection conn, String sql, Object... params)**

**insert(String sql, ResultSetHandler<T> rsh, Object... params) // 插入**

**insert(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params)**

**batch(String sql, Object\[\]\[\] params) // 批处理**

**batch(Connection conn, String sql, Object\[\]\[\] params)**

**execute(String sql, Object... params) // 执行SQL语句（一般不用）**

**execute(String sql, ResultSetHandler<T> rsh, Object... params)**

**execute(Connection conn, String sql, Object... params)**

**execute(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params)**

## ***ResultSetHandler**接口*** ##

这一接口执行处理一个jaca.sql.ResultSet，将数据按要求转换为另一种形式。

该接口仅提供了一个方法：T handle(**ResultSet** rs)

common-dbutils组件包针对这个接口提供了以下实现类：

ArrayHandler：把结果集中的第一行数据转成对象数组。

ArrayListHandler：把结果集中的每一行数据都转成一个对象数组，再存放到List中。

BeanHandler：将结果集中的第一行数据封装到一个对应的JavaBean实例中。

BeanListHandler：将结果集中的每一行数据都封装到一个对应的JavaBean实例中，存放到List里。

BeanMapHandler：用于获取所有结果集，将每行结果集转换为Javabean作为value，并指定某列为key，封装到HashMap中。相当于对每行数据的做BeanHandler一样的处理后，再指定列值为Key封装到HashMap中。（1.5版本之后）

ColumnListHandler：将结果集中某一列的数据存放到List中。

KeyedHandler：将结果集中的每一行数据都封装到一个Map里，然后再根据指定的key把每个Map再存放到一个Map里。

MapHandler：将结果集中的第一行数据封装到一个Map里，key是列名，value就是对应的值。

MapListHandler：将结果集中的每一行数据都封装到一个Map里，然后再存放到List

ScalarHandler：将结果集中第一条记录的其中某一列的数据存成Object

BaseResultSetHandler：如果上面的结果集处理类都不能满足你的要求，可以通过继承这个抽象类定义自己的结果处理类，子类必须实现无参方法handle()（1.6版本之后）

# **三、测试示例：** #

测试数据库:

![2019081414593753.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhY2tidWc_size_16_color_FFFFFF_t_70][]

JavaBean:

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> public class User { &nbsp;&nbsp;&nbsp; private int id; &nbsp;&nbsp;&nbsp; private String username; &nbsp;&nbsp;&nbsp; private String password; &nbsp;&nbsp;&nbsp; private int age; &nbsp; &nbsp;&nbsp;&nbsp; public User() { } </td> 
 </tr> 
 </tbody> 
</table>

(结果出现多条的，只截取了前三条显示)

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.Properties; &nbsp; import org.apache.commons.dbcp2.BasicDataSource; import org.apache.commons.dbcp2.BasicDataSourceFactory; import org.apache.commons.dbutils.BaseResultSetHandler; import org.apache.commons.dbutils.QueryRunner; import org.apache.commons.dbutils.handlers.ArrayHandler; import org.apache.commons.dbutils.handlers.ArrayListHandler; import org.apache.commons.dbutils.handlers.BeanHandler; import org.apache.commons.dbutils.handlers.BeanListHandler; import org.apache.commons.dbutils.handlers.BeanMapHandler; import org.apache.commons.dbutils.handlers.ColumnListHandler; import org.apache.commons.dbutils.handlers.KeyedHandler; import org.apache.commons.dbutils.handlers.MapHandler; import org.apache.commons.dbutils.handlers.MapListHandler; import org.apache.commons.dbutils.handlers.ScalarHandler; import org.apache.commons.lang3.ArrayUtils; import org.junit.Before; import org.junit.Test; &nbsp; import com.zzs.commons.bean.User; &nbsp; public class DBUtilsTest { &nbsp;&nbsp;&nbsp; private QueryRunner qr; &nbsp; &nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp; &nbsp;* 初始化 &nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp; @Before &nbsp;&nbsp;&nbsp; public void init() throws Exception { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Properties p = new Properties(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; p.setProperty("driverClassName", "com.mysql.jdbc.Driver"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; p.setProperty("url", "jdbc:mysql://localhost:3306/test"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; p.setProperty("username", "root"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; p.setProperty("password", "root"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; BasicDataSource ds = BasicDataSourceFactory.createDataSource(p); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; qr = new QueryRunner(ds); &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp; &nbsp;* ArrayHandler测试 &nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp; @Test &nbsp;&nbsp;&nbsp; public void testArrayHandler() throws SQLException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String sql = "select * from user"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Object[] objects = qr.query(sql, new ArrayHandler()); //&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(ArrayUtils.toString(objects)); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (Object object : objects) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; /* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 1001 zhangsan 123 22 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.print(object + "\t"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp; &nbsp;* ArrayListHandler测试 &nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp; @Test &nbsp;&nbsp;&nbsp; public void testArrayListHandler() throws SQLException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String sql = "select * from user"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; List&lt;Object[]&gt; list = qr.query(sql, new ArrayListHandler()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (Object[] objects : list) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; /* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* {1001,zhangsan,123,22} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* {1002,zhangsan_2,8195,70} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* {1003,zhangsan_3,3442,9} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(ArrayUtils.toString(objects)); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp; &nbsp;* BeanHandler测试 &nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp; @Test &nbsp;&nbsp;&nbsp; public void testBeanHandler() throws SQLException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String sql = "select * from user"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // 默认的情况下要保证表的字段和javabean的属性一致（字符一致即可，对大小写不敏感） &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; User user = qr.query(sql, new BeanHandler&lt;User&gt;(User.class)); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; /* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* User [id=1001, username=zhangsan, password=123, age=22] &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(user); &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp; &nbsp;* BeanListHandler测试 &nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp; @Test &nbsp;&nbsp;&nbsp; public void testBeanListHandler() throws SQLException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String sql = "select * from user"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; List&lt;User&gt; list = qr.query(sql, new BeanListHandler&lt;&gt;(User.class)); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (User user : list) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; /* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* User [id=1001, username=zhangsan, password=123, age=22] &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* User [id=1002, username=zhangsan_2, password=8195, age=70] &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* User [id=1003, username=zhangsan_3, password=3442, age=9] &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(user); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp; &nbsp;* BeanMapHandler测试 &nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp; @Test &nbsp;&nbsp;&nbsp; public void testBeanMapHandler() throws SQLException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String sql = "select * from user"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;Object, User&gt; map = qr.query(sql, new BeanMapHandler&lt;&gt;(User.class)); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // 可以指定某列作为key //&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;Object, User&gt; map2 = qr.query(sql, new BeanMapHandler&lt;&gt;(User.class, "username")); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (Entry&lt;Object, User&gt; entry : map.entrySet()) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; /* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 1008 User [id=1008, username=zhangsan_8, password=8809, age=33] &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 1009 User [id=1009, username=zhangsan_9, password=7748, age=33] &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 1010 User [id=1010, username=zhangsan_10, password=3338, age=18] &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(entry.getKey() + "\t" + entry.getValue()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp; &nbsp;* ColumnListHandler测试 &nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp; @Test &nbsp;&nbsp;&nbsp; public void testColumnListHandler() throws SQLException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String sql = "select * from user"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; List&lt;Object&gt; list = qr.query(sql, new ColumnListHandler&lt;&gt;()); //&nbsp;&nbsp;&nbsp;&nbsp; List&lt;Object&gt; list = qr.query(sql, new ColumnListHandler&lt;&gt;("username")); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (Object object : list) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; /* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 1001 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 1002 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 1003 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(object); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp; &nbsp;* KeyedHandler测试 &nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp; @Test &nbsp;&nbsp;&nbsp; public void testKeyedHandler() throws SQLException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String sql = "select * from user"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;Object, Map&lt;String, Object&gt;&gt; query = qr.query(sql, new KeyedHandler&lt;&gt;()); //&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;Object, Map&lt;String, Object&gt;&gt; query = qr.query(sql, new&nbsp; KeyedHandler&lt;&gt;("username")); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (Entry&lt;Object, Map&lt;String, Object&gt;&gt; queryEntry : query.entrySet()) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Object queryKey = queryEntry.getKey(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; queryValue = queryEntry.getValue(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.print(queryKey + "\t"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (Entry&lt;String, Object&gt; entry : queryValue.entrySet()) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; /* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 1008 id=1008 username=zhangsan_8 password=8809 age=33 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 1009 id=1009 username=zhangsan_9 password=7748 age=33 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 1010 id=1010 username=zhangsan_10 password=3338 age=18 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.print(entry.getKey() + "=" + entry.getValue() + "\t"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp; &nbsp;* MapHandler测试 &nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp; @Test &nbsp;&nbsp;&nbsp; public void testMapHandler() throws SQLException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String sql = "select * from user"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; map = qr.query(sql, new MapHandler()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (Entry&lt;String, Object&gt; entry : map.entrySet()) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; /* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* id=1001 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* username=zhangsan &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* password=123 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* age=22 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(entry.getKey() + "=" + entry.getValue()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp; &nbsp;* MapListHandler测试 &nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp; @Test &nbsp;&nbsp;&nbsp; public void testMapListHandler() throws SQLException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String sql = "select * from user"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; List&lt;Map&lt;String, Object&gt;&gt; list = qr.query(sql, new MapListHandler()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (Map&lt;String, Object&gt; map : list) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (Entry&lt;String, Object&gt; entry : map.entrySet()) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; /* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* id=1001 username=zhangsan password=123 age=22 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* id=1002 username=zhangsan_2 password=8195 age=70 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* id=1003 username=zhangsan_3 password=3442 age=9 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.print(entry.getKey() + "=" + entry.getValue() + "\t"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp; &nbsp;* ScalarHandler测试 &nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp; @Test &nbsp;&nbsp;&nbsp; public void testScalarHandler() throws SQLException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String sql = "select * from user"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Object object = qr.query(sql, new ScalarHandler&lt;&gt;()); //&nbsp;&nbsp;&nbsp;&nbsp; Object object = qr.query(sql, new ScalarHandler&lt;&gt;("username")); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; /* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 1001 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(object); &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp; &nbsp;* BaseResultSetHandler测试 &nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp; @Test &nbsp;&nbsp;&nbsp; public void testBaseResultSetHandler() throws SQLException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String sql = "select * from user"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Object object = qr.query(sql, new MyResultHandler("username")); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; /* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* [zhangsan, zhangsan_2, zhangsan_3, zhangsan_4, zhangsan_5, zhangsan_6, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* zhangsan_7, zhangsan_8, zhangsan_9, zhangsan_10] &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(object); &nbsp;&nbsp;&nbsp; } } &nbsp; class MyResultHandler extends BaseResultSetHandler { &nbsp; &nbsp;&nbsp;&nbsp; private final String columnIndex; &nbsp; &nbsp;&nbsp;&nbsp; // 指定要获取值的列 &nbsp;&nbsp;&nbsp; public MyResultHandler(String columnIndex) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.columnIndex = columnIndex; &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; // 重写父类的方法，封装每行数据 &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; protected List&lt;Object&gt; handle() throws SQLException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; List&lt;Object&gt; rows = new ArrayList&lt;&gt;(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; while (this.next()) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; rows.add(this.getObject(this.columnIndex)); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return rows; &nbsp;&nbsp;&nbsp; } } </td> 
 </tr> 
 </tbody> 
</table>

[2019081414593753.png]: /images/20211018/592dfd44a50b4815b38944f20cc1d5e9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhY2tidWc_size_16_color_FFFFFF_t_70]: /images/20211018/5098a365630743cc87470d7ae9ad6dfb.png