apache--dbutils的使用

yorknong

　　apache的dbutils是一个开源的JDBC工具类，由于它是对JDBC只进行简单的封装，所以基本上不会影响到程序的性能。
　　对于使用jdbc的程序来说，无疑dbutils能极大地简化jdbc的编码工作量。
　　首先要使用dbutils，就必须引入dbutils的jar包，可以到apache的官网去下载，这里就不多说了。
　　下面对其中比较常用的几个类进行简单的介绍
　　一、DbUtils ---工具类
　　DbUtils提供了关闭连接，装载JDBC驱动程序等常规工作的工具类，通过查看其API可以发现里面的方法都死静态的。
　　eg:
　　1.public static void close(…) throws java.sql.SQLException
　　DbUtils类提供了三个重载的关闭方法
　　2.public static void closeQuietly(…)
　　这一类方法不仅能在Connection、Statement和ResultSet为NULL情况下避免关闭，还能隐藏一些在程序中抛出的SQLException
　　3.public static void commitAndCloseQuietly(Connection conn)
　　用来提交连接，然后关闭连接，并且在关闭连接时不抛出SQL异常
　　4.public static boolean loadDriver(java.lang.String driverClassName)
　　这一方装载并注册JDBC驱动程序，如果成功就返回true。使用该方法，你不需要捕捉这个异常ClassNotFoundException
　　二、QueryRunner类
　　QueryRunner简单化了SQL查询，它与ResultSetHandler组合在一起使用可以完成大部分的数据库操作，能够大大减少编码量
　　eg:
　　1.构造方法
　　a.默认的构造方法  
　　需要控制事务时,使用这组方法
　　b.有参的构造方法：new QueryRunner(javax.sql.DataSource dataSource)
　　不需要控制事务用这组方法
　　2.主要方法
　　a.查询操作
　　public Object query(Connection conn, String sql, ResultSetHandler<T> rsh, Object... params)
　　public Object query(String sql, ResultSetHandler<T> rsh, Object... params)
　　b.更新操作
　　public int update(Connection conn, String sql, Object... params)
　　public int update(String sql, Object... params)
　　3.example demo
　　

<span style="white-space:pre"></span>/**
* DBUtils方式实现增删改
* @throws SQLException
*/
@Test
public void add2() throws SQLException{
QueryRunner runner = new QueryRunner(new ComboPooledDataSource());
runner.update("update account set money=? where name=?", 888,"a");
}
/**
* 古老方法实现增删改功能
* --在进行增删改操作时,每次都不一样的只有sql语句和sql语句中的参数
*/
@Test
public void update1(){
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
ComboPooledDataSource source = new ComboPooledDataSource();
try{
conn = source.getConnection();
ps = conn.prepareStatement("update account set money=? where name=?");
ps.setDouble(1, 999);
ps.setString(2, "a");
ps.executeUpdate();
}catch (Exception e) {
e.printStackTrace();
}finally{
DbUtils.closeQuietly(conn, ps, rs);
}
}

4.模拟QueryRunner写自己的QueryRunner　　

package com.jjyy.dbutils;
import java.sql.Connection;
import java.sql.ParameterMetaData;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.sql.DataSource;
import org.apache.commons.dbutils.DbUtils;
public class SelfQueryRunner {
private DataSource source = null;
public SelfQueryRunner() {
}
public SelfQueryRunner(DataSource source) {
this.source = source;
}
public int update(String sql, Object... params) throws SQLException{
Connection conn = source.getConnection();
PreparedStatement ps = conn.prepareStatement(sql);
//--获取参数元数据,获取参数的个数
ParameterMetaData metaData = ps.getParameterMetaData();
int count = metaData.getParameterCount();
//--循环设置参数的值
for(int i=1;i<=count;i++){
ps.setObject(i, params[i-1]);
}
//--执行update操作
int num = ps.executeUpdate();
DbUtils.closeQuietly(conn, ps, null);
return num;
}
public <T> T query(String sql, MyResultSetHandler<T> rsh, Object... params)throws SQLException{
Connection conn = source.getConnection();
PreparedStatement ps = conn.prepareStatement(sql);
//--获取参数元数据,获知参数个数
ParameterMetaData metaData = ps.getParameterMetaData();
int count = metaData.getParameterCount();
//--循环设置参数
for(int i=1;i<=count;i++){
ps.setObject(i, params[i-1]);
}
//--执行查询获取结果集
ResultSet rs = ps.executeQuery();
//--回调处理结果集的逻辑
T t = rsh.handle(rs);
DbUtils.closeQuietly(conn, ps, rs);
return t;
}
}