Java Web基础入门第六十一讲 Apache DBUtils框架的学习

commons-dbutils简介commons-dbutils是Apache组织提供的一个开源JDBC工具类库，它是对JDBC的简单封装，学习成本极低，并且使用dbutils能极大简化jdbc编码的工作量，同时也不会影响程序的性能。因此dbutils成为很多不喜欢hibernate的公司的首选。commons-dbutils API介绍：org.apache.commons.dbutils.

李阿昀

14977人浏览 · 2016-08-30 20:27:45

李阿昀 · 2016-08-30 20:27:45 发布

commons-dbutils简介

commons-dbutils是Apache组织提供的一个开源JDBC工具类库，它是对JDBC的简单封装，学习成本极低，并且使用dbutils能极大简化JDBC编码的工作量，同时也不会影响程序的性能，因此dbutils成为很多不喜欢Hibernate框架的公司的首选。
在这里插入图片描述

QueryRunner类使用讲解

该类简单化了SQL查询，它与ResultSetHandler组合在一起使用可以完成大部分的数据库操作，能够大大减少编码量。QueryRunner类提供了两个构造方法：

默认的构造方法；
需要一个javax.sql.DataSource来作参数的构造方法。

QueryRunner类的主要方法

在这里插入图片描述

ResultSetHandler接口使用讲解

该接口用于处理java.sql.ResultSet，将数据按要求转换为另一种形式。ResultSetHandler接口提供了一个单独的方法——Object handle (java.sql.ResultSet .rs)。

ResultSetHandler接口的实现类

在这里插入图片描述

DbUtils类使用讲解

DbUtils是一个提供如关闭连接、装载JDBC驱动程序等常规工作的工具类，里面的所有方法都是静态的。主要方法如下：
在这里插入图片描述

使用DBUtils完成数据库的CRUD

在使用DBUtils完成数据库的CRUD之前，我们先编写测试用的SQL脚本：

create database day17;
use day17;
create table users 
(
    id int primary key,
    name varchar(40),
    password varchar(40),
    email varchar(60),
    birthday date
);

在应用程序中加入DBCP连接池

导入相关jar包：

commons-dbcp-1.4.jar
commons-pool-1.6.jar

然后，在类目录下加入DBCP连接池的配置文件：dbcpconfig.properties。dbcpconfig.properties配置信息文件的内容如下：

#连接设置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/day17
username=root
password=liayun

#<!-- 初始化连接 -->
initialSize=10

#最大连接数量
maxActive=50

#<!-- 最大空闲连接 -->
maxIdle=20

#<!-- 最小空闲连接 -->
minIdle=5

#<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
maxWait=60000


#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：[属性名=property;] 
#注意："user" 与 "password" 两个属性会被明确地传递，因此这里不需要包含他们。
connectionProperties=useUnicode=true;characterEncoding=utf8

#指定由连接池所创建的连接的自动提交（auto-commit）状态。
defaultAutoCommit=true

#driver default 指定由连接池所创建的连接的只读（read-only）状态。
#如果没有设置该值，则“setReadOnly”方法将不被调用。（某些驱动并不支持只读模式，如：Informix）
defaultReadOnly=

#driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。
#可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
defaultTransactionIsolation=READ_COMMITTED

就像下图所示：
在这里插入图片描述

使用QueryRunner类实现CRUD

在cn.liayun.domain包下创建一个封装数据的实体——User.java，对应数据库中的users表。User类的具体代码如下：

package cn.liayun.domain;

import java.util.Date;

public class User {
	
	private int id;
	private String name;
	private String password;
	private String email;
	private Date birthday;
	
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public String getPassword() {
		return password;
	}
	public void setPassword(String password) {
		this.password = password;
	}
	public String getEmail() {
		return email;
	}
	public void setEmail(String email) {
		this.email = email;
	}
	public Date getBirthday() {
		return birthday;
	}
	public void setBirthday(Date birthday) {
		this.birthday = birthday;
	}
	
}

接着，在cn.liayun.utils包下创建一个获取数据库连接的工具类(JdbcUtils)，该工具类(JdbcUtils)的代码为：

package cn.liayun.utils;

import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSourceFactory;

public class JdbcUtils {
	
	private static DataSource ds;
	
	static {
		try {
			Properties prop = new Properties();
			InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");
			prop.load(in);
			
			BasicDataSourceFactory factory = new BasicDataSourceFactory();
			ds = factory.createDataSource(prop);
		} catch (Exception e) {
			throw new ExceptionInInitializerError(e);
		}
	}
	
	public static DataSource getDataSource() {
		return ds;
	}
	
	public static Connection getConnection() throws SQLException {
		return ds.getConnection();
	}

}

温馨提示：工具类里面现在没有必要提供release()方法，因为我们是使用DBUtils操作数据库，即调用DBUtils的update()和query()方法操作数据库，它操作完数据库之后，会自动释放掉连接。
最后，在cn.liayun.dbutils.demo包下新建一个测试类——Demo1.java，Demo1类的具体代码如下：

package cn.liayun.dbutils.demo;

import java.sql.SQLException;
import java.util.Date;
import java.util.List;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.junit.Test;

import cn.liayun.domain.User;
import cn.liayun.utils.JdbcUtils;

public class Demo1 {
	//使用dbutils完成数据库的CRUD
	@Test
	public void insert() throws SQLException {
		QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
		String sql = "insert into users(id,name,password,email,birthday) values(?,?,?,?,?)";
		Object[] params = {2, "yemeimei", "123321", "yemeimei@gmail.com", new Date()};
		runner.update(sql, params);
	}
	
	@Test
	public void update() throws SQLException {
		QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
		String sql = "update users set email=? where id=?";
		Object[] params = {"liayun_10001@gmail.com", 1};
		runner.update(sql, params);
	}
	
	@Test
	public void delete() throws SQLException {
		QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
		String sql = "delete from users where id=?";
		runner.update(sql, 1);
	}
	
	@Test
	public void find() throws SQLException {
		QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
		String sql = "select * from users where id=?";
		User user = runner.query(sql, 1, new BeanHandler<User>(User.class));
		System.out.println(user.getEmail());
	}
	
	@Test
	public void getAll() throws SQLException {
		QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
		String sql = "select * from users";
		List<User> list = runner.query(sql, new BeanListHandler<User>(User.class));
		System.out.println(list);//断点观察
	}
	
	@Test
	public void batch() throws SQLException {
		QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
		String sql = "insert into users(id,name,password,email,birthday) values(?,?,?,?,?)";
		Object[][] params = new Object[3][5];
		for (int i = 0; i < params.length; i++) {//3
			params[i] = new Object[]{i + 1, "zhangyusheng" + i, "123", i + "@163.com", new Date()};
		}
		runner.batch(sql, params);
	}
	
}

测试DBUtils各种类型的处理器

在使用DBUtils完成以上数据库的CRUD操作中，我们就已经测试过BeanHandler和BeanListHandler处理器，现在我们来一个个测试其余的处理器。

ArrayHandler：把结果集中的第一行数据转成对象数组。测试代码如下：
ArrayListHandler：把结果集中的每一行数据都转成一个数组，再存放到List中。测试代码如下：
ColumnListHandler：将结果集中某一列的数据存放到List中。测试代码如下：

其实，我们也可以自己重新写出这样一个ColumnListHandler处理器，如下：

用我们自己编写的ColumnListHandler1处理器来测试，代码为：
KeyedHandler(name)：将结果集中的每一行数据都封装到一个Map里，再把这些Map再存到一个Map里，其key为指定的key。这话听起来有些绕口，但我用下面这张图来解释就很明白了。

明白原理之后，就很容易写测试代码了，测试代码为：
当想要查询某张表中的总记录数时，我们可以用ArrayHandler处理器来处理。作为一个新手，第一次写代码时，可能会这样写：

JUnit测试可发现报如下异常：

原因：查询结果，即总记录数是作为java.lang.Long类型返回的。所以我们应该把代码修改为：

除此之外，我们还可写为：

更加专业一点的方法是使用ScalarHandler处理器，测试代码如下：

AtomGit 开源协作平台测评赛

瓜分20万奖金获得内推名额丰厚实物奖励易参与易上手

更多推荐

ADS1292R 使用过程心电图高精度ADC模块

文章目录1 Fundamentals ofPrecision ADC Noise Analysis 精密模数转换器噪声分析基础1 Fundamentals ofPrecision ADC Noise Analysis 精密模数转换器噪声分析基础https://www.ti.com.cn/cn/lit/wp/slyy192/slyy192.pdf?ts=1600659610730&ref_u

开放原子开发者工作坊

实现一个家庭安防与环境监测系统（一）

开放原子开发者工作坊

【cf】Codeforces Round #774 (Div. 2) 前4题

题目A. Square Counting 简单数学题目大意题解代码B. Quality vs Quantity 排序题目大意题解代码C. Factorials and Powers of Two 状态压缩dp+位运算题目大意题解代码D. Weight the Tree 树形dp+dfs题目大意题解代码E. Power Board 看起来像是数论？许多年没打cf了，偶尔打了一盘，恢复紫名了。A. S