DBUtils框架的应用（小巧的数据库连接工具）

什么是dbutils，它的作用

DBUtils是java编程中的数据库操作实用工具，小巧简单实用。

DBUtils封装了对JDBC的操作，简化了JDBC操作。可以少写代码。

1.对于数据表的读操作，他可以把结果转换成List，Array，Set等java集合，便于程序员操作；

2.对于数据表的写操作，也变得很简单（只需写sql语句）

3.可以使用数据源，使用JNDI，数据库连接池等技术来优化性能–重用已经构建好的数据库连接对象

需要引入commons-dbutils的jar包。

DBUtils的三个核心对象

QueryRunner类

ResultSetHandler接口

DBUtils类

QueryRunner类

QueryRunner中提供对sql语句操作的API.

它主要有三个方法

query() 用于执行select

update() 用于执行insert update delete

batch() 批处理

ResultSetHandler接口

用于定义select操作后，怎样封装结果集.

DbUtils类

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

DBUtils使用步骤

导入jar包

创建QueryRunner对象

使用query方法执行select语句

使用ResultSetHandler封装结果集

使用DbUtils类释放资源

QueryRunner对象

new QueryRunner(); 它的事务可以手动控制。

也就是说此对象调用的方法（如：query、update、batrch）参数中要有Connection对象。

new QueryRunner(DataSource ds); 它的事务是自动控制的。一个sql一个事务。

此对象调用的方法（如：query、update、batrch）参数中无需Connection对象。

查询方法

@Test
public void test1()
{
//查询
//参数接收的是数据源对象，那么会自动从连接池中取Connection对象，所以不能自己控制事务
QueryRunner qr = new QueryRunner(C3P0Util.getDataSource());

//需要自己指定Connection 对象，可以自己控制事务
QueryRunner qr2 = new QueryRunner();

try {
List<User> list = qr.query(conn,"select * from users where id=? and name=?",new BeanListHandler<User>(User.class),1,"lisi");

for(User u:list)
{
System.out.println(u);
}

} catch (SQLException e) {
e.printStackTrace();
}
}

我们可以使用无参的构造方法，无参的构造方法在调用query方法时，可以传Connection对象。

下面我们看一下自己实现ResultSetHandler接口。

@Test
public void test0() throws SQLException
{
QueryRunner qr = new QueryRunner(C3P0Util.getDataSource());

List<User> jihe = qr.query("select * from users", new ResultSetHandler<List<User>>(){

//查询的结果传给了参数rs
public List<User> handle(ResultSet rs) throws SQLException {
List<User> list = new ArrayList<User>();
User u = null;
while(rs.next()){
u = new User();
u.setId(rs.getInt(1));
u.setName(rs.getString(2));
u.setPassword(rs.getString(3));
u.setEmail(rs.getString(4));
u.setBirthday(rs.getDate(5));
list.add(u);
}
return list;
}

} );
}

更新方法。

@Test
public void test2()
{
try {
QueryRunner qr = new QueryRunner(C3P0Util.getDataSource());

qr.update("update users set email=? where id=?","666@66.com",24);

} catch (SQLException e) {

e.printStackTrace();
}
}

ResultSetHandler接口

ResultSetHandler下的所有结果处理器

//ArrayHandler:适合取1条记录。把该条记录的每列值封装到一个数组中Object[]
//ArrayListHandler:适合取多条记录。把每条记录的每列值封装到一个数组中Object[]，把数组封装到一个List中
//ColumnListHandler:取某一列的数据。封装到List中。
//KeyedHandler:取多条记录，每一条记录封装到一个Map中，再把这个Map封装到另外一个Map中，key为指定的字段值。
//MapHandler:适合取1条记录。把当前记录的列名和列值放到一个Map中
//MapListHandler:适合取多条记录。把每条记录封装到一个Map中，再把Map封装到List中
//ScalarHandler:适合取单行单列数据
BeanHandler
BeanListHandler

演示两个的用法

@Test
public void test1()
{
//ArrayHandler:适合取1条记录。把该条记录的每列值封装到一个数组中Object[]
try {
QueryRunner qr = new QueryRunner(C3P0Util.getDataSource());

Object[] arr = qr.query("select * from users", new ArrayHandler());

for(Object obj:arr)
{
System.out.print(obj+"  ");
}

} catch (SQLException e) {
e.printStackTrace();
}

}

@Test
public void test3()
{
//ColumnListHandler:取某一列的数据。封装到List中。
try {
QueryRunner qr = new QueryRunner(C3P0Util.getDataSource());

List<Object> list= qr.query("select name,password from users", new ColumnListHandler(1));

System.out.println(list);

} catch (SQLException e) {

e.printStackTrace();
}

}

@Test
public void test7()
{
//ScalarHandler:适合取单行单列数据
try {
QueryRunner qr = new QueryRunner(C3P0Util.getDataSource());

Object obj = qr.query("select count(*) from users", new ScalarHandler(1));

System.out.println(obj);

} catch (SQLException e) {

e.printStackTrace();
}

}