gaozhuang211 xiexie Dbutils 详解（ gaozhuang）
CommonDbutils是操作数据库的组件，对传统操作数据库的类进行二次封装，可以把结果集转化成List。
DBUtils包括3个包：
org.apache.commons.dbutils
org.apache.commons.dbutils.handlers
org.apache.commons.dbutils.wrappers
DBUtils封装了对JDBC的操作，简化了JDBC操作，可以少写代码。
org.apache.commons.dbutils
DbUtils关闭链接等操作
QueryRunner进行查询的操作
org.apache.commons.dbutils.handlers
ArrayHandler：将ResultSet中第一行的数据转化成对象数组
ArrayListHandler将ResultSet中所有的数据转化成List，List中存放的是Object[]
BeanHandler：将ResultSet中第一行的数据转化成类对象
BeanListHandler：将ResultSet中所有的数据转化成List，List中存放的是类对象
ColumnListHandler：将ResultSet中某一列的数据存成List，List中存放的是Object对象
KeyedHandler：将ResultSet中存成映射，key为某一列对应为Map。Map中存放的是数据
MapHandler：将ResultSet中第一行的数据存成Map映射
MapListHandler：将ResultSet中所有的数据存成List。List中存放的是Map
ScalarHandler：将ResultSet中一条记录的其中某一列的数据存成Object
org.apache.commons.dbutils.wrappers
SqlNullCheckedResultSet：对ResultSet进行操作，改版里面的值
StringTrimmedResultSet：去除ResultSet中中字段的左右空格。Trim()
主要方法：
DbUtils类：启动类
ResultSetHandler接口：转换类型接口
MapListHandler类：实现类，把记录转化成List
BeanListHandler类：实现类，把记录转化成List，使记录为JavaBean类型的对象
QreryRunner类：执行SQL语句的类
建立三个Java文件
命名为BeanListExample.java
Guestbook.java
MapListExample.java
源码：
BeanListExample.java
Code
packagecom.sy;
importorg.apache.commons.dbutils.DbUtils;
importorg.apache.commons.dbutils.QueryRunner;
importorg.apache.commons.dbutils.handlers.BeanListHandler;
importjava.sql.Connection;
importjava.sql.DriverManager;
importjava.sql.SQLException;
importjava.util.List;
publicclassBeanListExample{
publicstaticvoidmain(String[]args){
Connectionconn=null;
Stringurl="jdbc:mysql://localhost:3306/people";
StringjdbcDriver="com.mysql.jdbc.Driver";
Stringuser="root";
Stringpassword="hicc";
DbUtils.loadDriver(jdbcDriver);
try{
conn=DriverManager.getConnection(url,user,password);
QueryRunnerqr=newQueryRunner();
Listresults=(List)qr.query(conn,"selectid,namefromguestbook",newBeanListHandler(Guestbook.class));
for(inti=0;i<results.size();i++){
Guestbookgb=(Guestbook)results.get(i);
System.out.println("id:"+gb.getId()+",name:"+gb.getName());
}
}catch(SQLExceptione){
e.printStackTrace();
}finally{
DbUtils.closeQuietly(conn);
}
}
}
Guestbook.java
Code
packagecom.sy;
publicclassGuestbook{
privateIntegerid;
privateStringname;
publicIntegergetId(){
returnid;
}
publicvoidsetId(Integerid){
this.id=id;
}
publicStringgetName(){
returnname;
}
publicvoidsetName(Stringname){
this.name=name;
}
}
MapListExample.java
Code
packagecom.sy;
importorg.apache.commons.dbutils.DbUtils;
importorg.apache.commons.dbutils.QueryRunner;
importorg.apache.commons.dbutils.handlers.MapListHandler;
importjava.sql.Connection;
importjava.sql.DriverManager;
importjava.sql.SQLException;
importjava.util.List;
importjava.util.Map;
publicclassMapListExample{
publicstaticvoidmain(String[]args){
Connectionconn=null;
Stringurl="jdbc:mysql://localhost:3306/people";
StringjdbcDriver="com.mysql.jdbc.Driver";
Stringuser="root";
Stringpassword="hicc";
DbUtils.loadDriver(jdbcDriver);
try{
conn=DriverManager.getConnection(url,user,password);
QueryRunnerqr=newQueryRunner();
Listresults=(List)qr.query(conn,"selectid,namefromguestmessage",newMapListHandler());
for(inti=0;i<results.size();i++){
Mapmap=(Map)results.get(i);
System.out.println("id:"+map.get("id")+",name:"+map.get("name"));
}
}catch(SQLExceptione){
e.printStackTrace();
}finally{
DbUtils.closeQuietly(conn);
}
}
}
使用组建好需要添加commons-dbutils-1.1.jar和mysql-connector-java-5.1.6-bin.jar两个jar包。
配置完毕！！！
//另一种方法
//使用dbutils1.0版本
importjava.util.*;
importjava.util.logging.*;
importjava.sql.*;
importorg.apache.commons.dbutils.*;
importorg.apache.commons.dbutils.handlers.*;
publicclassTestDBUnits{
publicstaticvoidmain(String[]args)throwsException{
TestDBUnitstest=newTestDBUnits();
for(inti=0;i<1;i++){
test.testQuery1();
test.testQuery2();
test.testUpdate();
}
}
publicvoidtestQuery1(){
try{
QueryRunnerqr=newQueryRunner();
ResultSetHandlerrsh=newArrayListHandler();
Stringstrsql="select*fromtest1";
ArrayListresult=(ArrayList)qr.query(getConnection(),strsql,rsh);
//System.out.print("");
}catch(Exceptionex){
ex.printStackTrace(System.out);
}
}
publicvoidtestQuery2(){
try{
QueryRunnerqr=newQueryRunner();
ResultSetHandlerrsh=newMapListHandler();
Stringstrsql="select*fromtest1";
ArrayListresult=(ArrayList)qr.query(getConnection(),strsql,rsh);
for(inti=0;i<result.size();i++){
Mapmap=(Map)result.get(i);
//System.out.println(map);
}
//System.out.print("");
}catch(Exceptionex){
ex.printStackTrace(System.out);
}
}
publicvoidtestUpdate(){
try{
QueryRunnerqr=newQueryRunner();
ResultSetHandlerrsh=newArrayListHandler();
Stringstrsql="inserttest1(page,writable,content)values('ttt','ttt','faskldfjklasdjklfjasdklj')";
qr.update(getConnection(),strsql);
//System.out.print("");
}catch(Exceptionex){
ex.printStackTrace(System.out);
}
}
privateConnectiongetConnection()throwsInstantiationException,
IllegalAccessException,ClassNotFoundException,SQLException{
StringstrDriver="org.gjt.mm.mysql.Driver";
StringstrUrl="jdbc:mysql://localhost:3306/test";
StringstrUser="root";
StringstrPass="";
Class.forName(strDriver).newInstance();
returnDriverManager.getConnection(strUrl,strUser,strPass);
}
}