Apache—DBUtils框架_ 王少飞的个人总结及案例

O-R Mapping常用O-RMapping映射工具HibernateIbatisCommons DbUtils(只是对JDBC简单封装) Apache—DBUtils框架简介commons-dbutils是 Apache 组织提供的一个开源 JDBC工具类库，它是对JDBC的简单封装，学习成本极低，并且使用dbutils能极大简化jdbc编码的工作量，同时

Fichel

789人浏览 · 2012-11-28 20:06:48

Fichel · 2012-11-28 20:06:48 发布

O-R Mapping

常用O-RMapping映射工具

Hibernate

Ibatis

Commons DbUtils(只是对JDBC简单封装)

Apache—DBUtils框架

简介

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

API介绍：

org.apache.commons.dbutils.QueryRunner--BDManager

org.apache.commons.dbutils.ResultSetHandler—处理结果集

工具类

org.apache.commons.dbutils.DbUtils、。

DbUtils类

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

public static void close(…) throws java.sql.SQLException：　DbUtils类提供了三个重载的关闭方法。这些方法检查所提供的参数是不是NULL，如果不是的话，它们就关闭Connection、Statement和ResultSet。

public static void closeQuietly(…): 这一类方法不仅能在Connection、Statement和ResultSet为NULL情况下避免关闭，还能隐藏一些在程序中抛出的SQLEeception。

public static void commitAndCloseQuietly(Connectionconn)：用来提交连接，然后关闭连接，并且在关闭连接时不抛出SQL异常。

public static booleanloadDriver(java.lang.String driverClassName)：这一方装载并注册JDBC驱动程序，如果成功就返回true。使用该方法，你不需要捕捉这个异常ClassNotFoundException。

QueryRunner类

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

QueryRunner类提供了两个构造方法：

①默认的构造方法

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

QueryRunner类的主要方法

public Object query(Connection conn, Stringsql, Object[] params, ResultSetHandler rsh) throws SQLException：执行一个查询操作，在这个查询中，对象数组中的每个元素值被用来作为查询语句的置换参数。该方法会自行处理 PreparedStatement 和 ResultSet 的创建和关闭。

public Object query(String sql, Object[]params, ResultSetHandler rsh) throws SQLException:　几乎与第一种方法一样；唯一的不同在于它不将数据库连接提供给方法，并且它是从提供给构造方法的数据源(DataSource) 或使用的setDataSource 方法中重新获得 Connection。

public Object query(Connection conn, Stringsql, ResultSetHandler rsh) throws SQLException : 执行一个不需要置换参数的查询操作。

public int update(Connection conn, Stringsql, Object[] params) throws SQLException:用来执行一个更新（插入、更新或删除）操作。

public int update(Connection conn, Stringsql) throws SQLException：用来执行一个不需要置换参数的更新操作。

ResultSetHandler接口

该接口用于处理java.sql.ResultSet，将数据按要求转换为另一种形式。

ResultSetHandler 接口提供了一个单独的方法：Object handle(java.sql.ResultSet .rs)。

ResultSetHandler 接口的实现类

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

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

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

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

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

KeyedHandler(name)：将结果集中的每一行数据都封装到一个Map里，再把这些map再存到一个map里，其key为指定的key。

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

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

例子：

首先导包数据库连接包mysql-connector-java-5.1.5-bin.jar

连接池驱动 commons-dbcp-1.2.2.jar commons-pool.jar（我用的是dbcp）

Apache 组织提供的一个开源 JDBC工具类库 commons-dbutils-1.3.jar

dbcp属性文件-----------------

#连接设置

driverClassName=com.mysql.jdbc.Driver

url=jdbc:mysql://localhost:3306/java

username=root

password=root

#

initialSize=10

#最大连接数量

maxActive=50

#

maxIdle=20

#

minIdle=5

#

maxWait=60000

#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：[属性名=property;]

#注意："user"与 "password"两个属性会被明确地传递，因此这里不需要包含他们。

connectionProperties=useUnicode=true;characterEncoding=gbk

#指定由连接池所创建的连接的自动提交（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_UNCOMMITTED

工具类--------------用来获取连接

package com.hbsi.util;

import java.io.InputStream;

import java.util.Properties;

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSourceFactory;

public class DBManger2 {

private staticDataSource ds;

static {

try {

InputStreamin = DBManger_dbcp.class.getClassLoader()

.getResourceAsStream("dbcpconfig.properties");

Propertiesprop = new Properties();

prop.load(in);

ds= BasicDataSourceFactory.createDataSource(prop);

} catch(Exception e) {

e.printStackTrace();

}

public staticDataSource getDataSource(){

returnds;

}

测试增删改查的类----------------------------------

packagecom.hbsi.demo;

importjava.sql.SQLException;

importjava.util.List;

importorg.apache.commons.dbutils.QueryRunner;

importorg.apache.commons.dbutils.handlers.BeanHandler;

importorg.apache.commons.dbutils.handlers.BeanListHandler;

importorg.junit.Test;

importcom.hbsi.bean.User;

importcom.hbsi.util.DBManger2;

publicclass CRUDTest2 {

@Test

public void insert() {

QueryRunner runner=newQueryRunner(DBManger2.getDataSource());

String sql = "insert intopool(id,name,pass)values(?,?,?)";

Object[] params = { 4,"d", "123" };

try {

runner.update(sql, params);

} catch (SQLException e) {

// TODO Auto-generatedcatch block

e.printStackTrace();

}

@Test

publicvoid delete() {

QueryRunner runner=new QueryRunner(DBManger2.getDataSource());

String sql = "delete frompool where id=?";

Object[] params = { 4};

try {

runner.update(sql, params);

} catch (SQLException e) {

// TODO Auto-generatedcatch block

e.printStackTrace();

}

@Test

public void update() {

QueryRunner runner=newQueryRunner(DBManger2.getDataSource());

String sql = "update pool setname=?,pass=? where id=?";

Object[] params = { "f","123",4 };

try {

runner.update(sql, params);

} catch (SQLException e) {

// TODO Auto-generatedcatch block

e.printStackTrace();

}

@Test

public void find() {

QueryRunner runner=newQueryRunner(DBManger2.getDataSource());

String sql = "select * frompool where id=?";

User user;

try {

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

System.out.println(user.getId()+"--"+user.getName());

} catch (SQLException e) {

// TODO Auto-generatedcatch block

e.printStackTrace();

}

@Test

public void getAll() {

QueryRunner runner=newQueryRunner(DBManger2.getDataSource());

String sql = "select * frompool";

try {

List<User> list =(List<User>) runner.query(sql, new BeanListHandler(User.class));

System.out.println(list.size());

for(Useruser:list){

System.out.println(user.getId()+"--"+user.getName());

}

} catch (SQLException e) {

// TODO Auto-generatedcatch block

e.printStackTrace();

}

测试其他方法的类-------------------------

package com.hbsi.demo;

import java.sql.SQLException;

import java.util.Arrays;

import java.util.List;

import java.util.Map;

import java.util.Map.Entry;

import org.apache.commons.dbutils.QueryRunner;

import org.apache.commons.dbutils.handlers.ArrayHandler;

importorg.apache.commons.dbutils.handlers.ArrayListHandler;

importorg.apache.commons.dbutils.handlers.ColumnListHandler;

import org.apache.commons.dbutils.handlers.KeyedHandler;

import org.apache.commons.dbutils.handlers.MapListHandler;

import org.junit.Test;

import com.hbsi.bean.User;

import com.hbsi.util.DBManger2;

public class DemoQueryRunner {

@Test

public voidtestArrayHandler() {

QueryRunnerrunner = new QueryRunner(DBManger2.getDataSource());

Stringsql = "select * from pool where id=?";

Object[]params = { 1 };

try {

Object[]result = runner.query(sql, params, new ArrayHandler());

System.out.println(Arrays.asList(result));

} catch(SQLException e) {

//TODO Auto-generated catch block

e.printStackTrace();

}

@Test

public voidtestArrayListHandler() {

QueryRunnerrunner = new QueryRunner(DBManger2.getDataSource());

Stringsql = "select * from pool";

try {

List<Object[]>list = (List<Object[]>) runner.query(sql,

newArrayListHandler());

for(Object[] result : list) {

System.out.println(Arrays.asList(result));

}

System.out.println();

} catch(SQLException e) {

//TODO Auto-generated catch block

e.printStackTrace();

}

@Test

public voidtestColumnListHandler() {

QueryRunnerrunner = new QueryRunner(DBManger2.getDataSource());

Stringsql = "select * from pool";

try {

Listlist = runner.query(sql, new ColumnListHandler("name"));

System.out.println(list);

} catch(SQLException e) {

//TODO Auto-generated catch block

e.printStackTrace();

}

@Test

public voidtestKeyedHandler() {

QueryRunnerrunner = new QueryRunner(DBManger2.getDataSource());

Stringsql = "select * from pool";

try {

Map<Object,Map<String, Object>> map = runner.query(sql,

newKeyedHandler("id"));

for(Map.Entry<Object, Map<String, Object>> me : map.entrySet()) {

Map<String,Object> innerme = me.getValue();

for (Map.Entry<String,Object> entry : innerme.entrySet()) {

System.out.println(entry.getKey()+ "---"

+entry.getValue());

}

} catch(SQLException e) {

//TODO Auto-generated catch block

e.printStackTrace();

}

@Test

public voidtestMapListHandler() {

QueryRunnerrunner = new QueryRunner(DBManger2.getDataSource());

Stringsql = "select * from pool";

try {

List<Map<String,Object>> list = (List<Map<String, Object>>) runner

.query(sql,new MapListHandler());

for(Map<String, Object> entry : list) {

for(Map.Entry<String, Object> user : entry.entrySet()) {

System.out.println(user.getKey()+ "---"

+user.getValue());

}

} catch(SQLException e) {

//TODO Auto-generated catch block

e.printStackTrace();

}

开放原子开发者工作坊

开放原子开发者工作坊旨在鼓励更多人参与开源活动，与志同道合的开发者们相互交流开发经验、分享开发心得、获取前沿技术趋势。工作坊有多种形式的开发者活动，如meetup、训练营等，主打技术交流，干货满满，真诚地邀请各位开发者共同参与！

更多推荐

第二届openEuler生态大会（中国·湖南）成功举办

10月30日，第二届openEuler生态大会（中国·湖南）成功举办。

开放原子开发者工作坊

“小满”安全车控操作系统正式在AtomGit开源

10月24日，由中国汽车工业协会指导，普华基础软件股份有限公司主办的“小满”安全车控操作系统开源发布会暨共建计划说明会成功举行。普华基础软件宣布将安全车控操作系统“小满”（简称“小满”）V24.10源代码正式在开放原子开源基金会（简称“基金会”）旗下AtomGit开源协作平台开源，并在AtomGit平