技术经验分享:DBUtils详解

分类: 365直播网APP下载 📅 2025-09-24 23:44:33 👤 admin 👁️ 2409 ❤️ 419
技术经验分享:DBUtils详解

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

DBUtils三个核心功能:

QueryRunner类,提供对sql语句操作的API;

ResultSetHandler接口,用于定义select操作后,怎样封装结果集;

DbUtils类,它是一个工具类,定义了关闭资源与处理事务的方法。

一、QueryRunner

使用QueryRunner类简化了SQL查询,它与ResultSetHandler组合在一起使用可以完成大部分的数据库操作,能够大大减少编码量。

构造QueryRunner,

QueryRunner中一共有6种方法:

execute(执行SQL语句)

batch(批量处理语句)

insert(执行INSERT语句)

insertBatch(批量处理INSERT语句)

query(SQL中 SELECT 语句)

update(SQL中 INSERT,UPDATE,或 DELETE 语句)

我们主要介绍最后两种(最常用):

1、query方法

query方法的重载形式有很多种,常用的有两种形式:

(1)T query(String sql, ResultSetHandler rsh) 不需要替换参数来执行给定的SELECT语句

(2)T query(String sql, ResultSetHandler rsh, Object... params) 需要一个或多个替换参数来执行给定的SELECT语句,并返回一种对象结果。

2、update方法

(1)int update(Connection conn, String sql) 不需要替换参数来执行INSERT,UPDATE,DELETE语句(参数还需要一个连接)

(2)int update(Connection conn, String sql, Object... params) 需要一个或多个替换参数以及一个数据库连接来执行INSERT,UPDATE,DELETE语句(参数还需要一个连接)

(3)int update(Connection conn, String sql, Object param) 需要一个替换参数,以及一个数据库连接来执行INSERT,UPDATE,DELETE语句(参数还需要一个连接)

(4)int update(String sql) 不需要替换参数来执行给定的INSERT,UPDATE,DELETE语句(参数无需带有连接)

(5)int update(String sql, Object... params) 需要一个或多个替换参数来执行INSERT,UPDATE,DELETE语句(参数无需带有连接)

(6)int update(String sql, Object param) 不需要替换参数来执行INSERT,UPDATE,DELETE语句(参数无需带有连接)

二、ResultSetHandler

对于结果集的处理有以下几个结果集处理器:

1、ScalarHandler

本方法是用于处理单行单列的数据,多用于聚合函数的查询。

但是,有一个点需要注意,就是当聚合函数是涉及到数字类型的时候,一定要注意返回值类型的转换。

有的人会选用Integer,long等类型,这些严格来说都是不合法的。例如,long类型最大只能容纳20的阶乘,21的阶乘就会包异常,所以我们要选用Number(这个是所有数据类型)的父类,并且对外提供的有Number.intValue()和Number.LongValue()等方法。

// 名字的第一个

public void testScalarHandler() throws SQLException {

QueryRunner queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select name from tb_user where id =?";

Object object = queryRunner.query(sql, new ScalarHandler(), 1);

System.out.println(object.toString());

}

// 名字的第一个

public void testScalarHandler1() throws SQLException {

QueryRunner queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select from tb_user where id =?";

Object object = queryRunner.query(sql, new ScalarHandler("name"), 1);

System.out.println(object.toString());

}

// 第二列的第一个

public void testScalarHandler2() throws SQLException {

QueryRunner queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select from tb_user where id =?";

Object object = queryRunner.query(sql, new ScalarHandler(2), 1);

System.out.println(object.toString());

}

// 获取数据库中总共有多少条数据 (单行单列)

public void testCount() throws SQLException {

QueryRunner queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select count() from tb_user";

Number num = (Number) queryRunner.query(sql, new ScalarHandler());

System.out.println(num.intValue());

}

2、BeanHandler

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

本方法多用于在处理把单行结果集封装成JavaBean对象(对象时通过反射完成创建的)

public void testBeanHandler() throws SQLException {

QueryRunner queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select from tb_user where id =?";

User user = queryRunner.query(sql, new BeanHandler(User.class), 1);

System.out.println(user.toString());

}

3、BeanListHandler

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

public void testBeanListHandler() throws SQLException {

QueryRunner queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select from tb_user";

List list = queryRunner.query(sql, new BeanListHandler(User.class));

for (int i = 0; i < list.size(); i++) {

System.out.println(list.get(i).toString());

}

}

4、BeanMapHandler

将结果集中的每一行数据都封装到一个JavaBean里,再把这些JavaBean再存到一个Map里,其key为指定的列。

public void testBeanMapHandler() throws SQLException {

QueryRunner queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select from tb_user";

Map map = queryRunner.query(sql, new BeanMapHandler(User.class, "name"));

for (Map.Entry entry : map.entrySet()) {

System.out.println(entry.getKey() + " : " + entry.getValue());

}

}

5、MapHandler

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

public void testMapHandler() throws SQLException {

QueryRunner //代码效果参考:http://www.jhylw.com.cn/515039889.html

queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select from tb_user where id =?";

// map中键是列名 ,值是列所对应的值

Map map = queryRunner.query(sql, new MapHandler(), 1);

for (Map.Entry m : map.entrySet()) {

System.out.println(m.getKey() + " = " + m.getValue());

}

}

6、MapListHandler

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

public void testMapListHandler() throws SQLException {

QueryRunner queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select from tb_user";

List

for (int i = 0; i < list.size(); i++) {

Map map = list.get(i);

System.out.println(i + "====");

for (Map.Entry m : map.entrySet()) {

//代码效果参考:http://www.jhylw.com.cn/595141839.html

System.out.println(m.getKey() + " = " + m.getValue());

}

}

}

7、ColumnListHandler

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

public void testColumnListHandler1() throws SQLException {

QueryRunner queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select name from tb_user";

List list = queryRunner.query(sql, new ColumnListHandler());

for (int i = 0; i < list.size(); i++) {

System.out.println(list.get(i).toString());

}

}

public void testColumnListHandler2() throws SQLException {

QueryRunner queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select from tb_user";

// 列的index从1开始

List list = queryRunner.query(sql, new ColumnListHandler(2));

for (int i = 0; i < list.size(); i++) {

System.out.println(list.get(i).toString());

}

}

public void testColumnListHandler3() throws SQLException {

QueryRunner queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select from tb_user";

List list = queryRunner.query(sql, new ColumnListHandler("name"));

for (int i = 0; i < list.size(); i++) {

System.out.println(list.get(i).toString());

}

}

8、ArrayHandler

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

public void testArrayHandler() throws SQLException {

QueryRunner queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select from tb_user where id =?";

Object【】 objects = queryRunner.query(sql, new ArrayHandler(), 1);

for (int i = 0; i < objects.length; i++) {

System.out.println(objects【i】.toString());

}

}

9、ArrayListHandler

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

public void testArrayListHandler() throws SQLException {

QueryRunner queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select from tb_user";

List list = queryRunner.query(sql, new ArrayListHandler());

for (int i = 0; i < list.size(); i++) {

Object【】 objects = list.get(i);

System.out.println(i + "===");

for (int j = 0; j < objects.length; j++) {

System.out.println(objects【j】.toString());

}

}

}

10、KeyedHandler

将结果集中的每一行数据都封装到一个Map里,再把这些Map再存到一个Map里,其key为指定的列。

public void KeyedHandler() throws SQLException {

QueryRunner queryRunner = new QueryRunner(C3P0Utils.getDataSource());

String sql = "select * from tb_user";

// 查询结果:把每一条查到的结果封装到map中,把这条数据对应的列名当作map的key存储,把这条数据对应的列的值当作map的value存储,

// 再把每一条的数据的map存入到另一个大map中,把该条数据的唯一标识id当作key存储,这条数据的map当作大map的value存储。

Map

for (Map.Entry

Integer id = m.getKey();

System.out.println(id + ":"); // 每一条数据的id

Map m1 = m.getValue();

for (Map.Entry m2 : m1.entrySet()) {

// key:列名, value:列的值

System.out.println(m2.getKey() + " = " + m2.getValue());

}

}

}

相关文章