DbUtils是Javar的一個為簡化JDBC操作類庫

commons-dbutils是Apache組織提供的一個開源JDBC工具類庫，它是對JDBC的簡單封裝，學習成本極低，並且使用dbutils能極大簡化jdbc編碼的工作量，同時也不會影響程式的效能。因此dbutils成為很多不喜歡hibernate的公司的首選。

整個dbutils總共才3個包：

org.apache.commons.dbutils （該包中的類主要幫助我們更便捷的操作JDBC）

org.apache.commons.dbutils.handlers（該包中的類都是實現org.apache.commons.dbutils.ResultSetHandler介面的實現類）

org.apache.commons.dbutils.wrappers（該包中的類主要是封裝了對Sql結果集的操作）

1.DbUtils包的簡介：

1.1 org.apache.commons.dbutils 包的使用和相關類的簡介：

介面摘要:

- ResultSetHandler 將ResultSet轉換為別的物件的工具。

- RowProcessor 將ResultSet行轉換為別的物件的工具。

類摘要:

BasicRowProcessor RowProcessor介面的基本實現類。

BeanProcessor BeanProcessor匹配列明到Bean屬性名，並轉換結果集列到Bean物件的屬性中。

DbUtils 一個JDBC輔助工具集合。

ProxyFactory 產生JDBC介面的代理實現。

QueryLoader 屬性檔案載入器，主要用於載入屬性檔案中的 SQL 到記憶體中。

QueryRunner 使用可插拔的策略執行SQL查詢並處理結果集。

ResultSetIterator 包裝結果集為一個迭代器。

1.2 org.apache.commons.dbutils.handlers 的使用和相關類的簡介：

類摘要:

1.3 org.apache.commons.dbutils.wrappers包的使用

SqlNullCheckedResultSet 在每個getXXX方法上檢查SQL NULL值的ResultSet包裝類。

StringTrimmedResultSet 取出結果集中字串左右空格的ResultSet包裝類。

2.使用DBUtils(兩類一介面)

只是使用的話，只看兩個類（DbUtils 和QueryRunner）和一個介面（ResultSethandler）就可以了。

2.1 DbUtils類：

DbUtils是一個為做一些諸如關閉連線、裝載JDBC驅動程式之類的常規工作提供有用方法的類，它裡面所有的方法都是靜態的。

這個類裡的重要方法有：

(1)close()：

DbUtils類提供了三個過載的關閉方法。這些方法檢查所提供的引數是不是NULL，

如果不是的話，它們就關閉連線、宣告和結果集（ResultSet）。

(2)CloseQuietly:

CloseQuietly這一方法不僅能在連線、宣告或者結果集（ResultSet）為NULL情況下避免關閉，還能隱藏一些在程式中丟擲的SQLEeception。如果你不想捕捉這些異常的話，這對你是非常有用的。在過載CloseQuietly方法時，特別有用的一個方法closeQuietly(Connection conn,Statement stmt,ResultSet rs)，這是因為在大多數情況下，連線、宣告和結果集（ResultSet）是你要用的三樣東西，而且在最後的塊你必須關閉它們。使用這一方法，你最後的塊就可以只需要呼叫這一方法即可。

(3)CommitAndCloseQuietly(Connection conn)：

這一方法用來提交連線，然後關閉連線，並且在關閉連線時不向上丟擲在關閉時發生的一些SQL異常,LoadDriver(String driveClassName):這一方法裝載並註冊JDBC驅動程式，如果成功就返回TRUE。使用這種方法，你不需要去捕捉這個異常ClassNotFoundException。使用loadDrive方法，編碼就變得更容易理解，你也就得到了一個很好的Boolean返回值，這個返回值會告訴你驅動類是不是已經載入成功了。

2.2 QureryRunner類：

該類簡單化了SQL查詢，它與ResultSetHandler組合在一起使用可以完成大部分的資料庫操作，能夠大大減少編碼量。

QueryRunner類提供了兩個構造方法：

（1）一個是一個空構造器；

（2）另一個則拿一個 javax.sql.DataSource 來作為引數。因此，在你不用為一個方法提供一個數據庫連線來作為引數的情況下，提供給構造器的資料來源(DataSource) 被用來獲得一個新的連線並將繼續進行下去。

主要的方法：

• public Object query(Connection conn,String sql,Object[] params,ResultSetHandler rsh) throws SQLException：執行一個查詢操作，在這個查詢中，物件陣列中的每個元素值被用來作為查詢語句的置換引數。該方法會自行處理 PreparedStatement 和 ResultSet 的建立和關閉。
• public Object query(String sql,ResultSetHandler rsh) throws SQLException:　幾乎與第一種方法一樣；唯一的不同在於它不將資料庫連線提供給方法，並且它是從提供給構造方法的資料來源(DataSource) 或使用的setDataSource 方法中重新獲得 Connection。
• public Object query(Connection conn,ResultSetHandler rsh) throws SQLException :執行一個不需要置換引數的查詢操作。
• public int update(Connection conn,Object[] params) throws SQLException:用來執行一個更新（插入、更新或刪除）操作,返回的是受語句影響的行數
• public int update(Connection conn,String sql) throws SQLException：用來執行一個不需要置換引數的更新操作,返回的是受語句影響的行數

2.3:ResultSetHandler介面：

該介面用於處理Java.sql.ResultSet，將資料按要求轉換為另一種形式。ResultSetHandler介面提供了一個單獨的方法：Object handle (java.sql.ResultSet rs)。因此任何ResultSetHandler 的執行需要一個結果集（ResultSet）作為引數傳入，然後才能處理這個結果集，再返回一個物件。

因為返回型別是java.lang.Object，所以除了不能返回一個原始的Java型別之外，其它的返回型別並沒有什麼限制。如果你發現這七個執行程式中沒有任何一個提供了你想要的服務，你可以自己寫執行程式並使用它。這一元件提供了ArrayHandler,ArrayListHandler,BeanHandler,BeanListHandler,MapHandler,MapListHandler,and ScalarHandler等執行程式。其方法如下：

3.程式碼實戰：

使用遵從以下步驟：

1．載入JDBC驅動程式類，並用DriverManager來得到一個數據庫連線conn。

2．例項化 QueryRunner,得到例項化物件qRunner。

3. qRunner.update()方法，執行增改刪的sql命令， qRunner.query()方法，得到結果集。

首先生成以下資料庫表：

  create table stuInfo 
 ( 
  stuNo int primary key identity (1,1),--學號 
  stuName nvarchar(10) not null,--學生姓名 
  stuSex nvarchar(2) not null,--學生性別 
  stuAge int not null,--學生年齡 
  stuSeat int not null,--學生座位 
  stuAddress nvarchar(20) --學生住址  
 )

（1）完成CRUD的操作：

public class QueryRunnerTest { 
 public static void main(String[] args) { 
  QueryRunnerTest test = new QueryRunnerTest(); 
  test.add(); 
  test.delete(); 
  test.update(); 
  test.find(); 
  test.getAll(); 

 } 
 //靜態方法獲取資料庫連結物件：
 private static Connection getConnection() { 
  Connection conn = null; 
  try {   Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver"); conn = DriverManager.getConnection("jdbc:sqlserver://localhost:1433;Database=student","sa","sasa"); 
  } catch (SQLException e) { 
   e.printStackTrace(); 
  } catch (ClassNotFoundException e) { 
   e.printStackTrace(); 
  } 
  System.out.println(conn); 
  return conn; 
 } 

 //新增方法 
 public void add () { 
  Connection conn = getConnection(); 
  QueryRunner qr = new QueryRunner(); 
  String sql = "insert into stuInfo (stuName,stuSex,stuAge,stuSeat,stuAddress) values (?,?,?)"; 
  Object param[] = {"張良","男",20,11,"韓國"}; 
  int i; 
  try { 
   i = qr.update(conn,sql,param); //i是受操作影響的行數；
   System.out.println("新增成功："+i); 
   DbUtils.closeQuietly(conn); //關閉連結； 
  } catch (SQLException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 
 } 
 //刪除方法 
 public void delete() { 
  Connection conn = getConnection(); 
  QueryRunner qr = new QueryRunner(); 
  String sql ="delete from stuInfo where stuNo=?"; 
  try { 
   int i = qr.update(conn,7); i是受操作影響的行數；
   System.out.println("刪除成功："+i); 
   DbUtils.closeQuietly(conn); //關閉連結；  
  } catch (SQLException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 
 } 
 //修改方法 
 public void update() { 
  Connection conn = getConnection(); 
  QueryRunner qr = new QueryRunner(); 
  String sql = "update stuInfo set stuName=? where stuNo=?"; 
  Object params[] = {"胡歌",3}; 
  try { 
   int i = qr.update(conn,params); 
   System.out.println("修改成功："+i); // i是受操作影響的行數；
   DbUtils.closeQuietly(conn); //關閉連結； 
  } catch (SQLException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 
 } 
 //查詢方法 
 public void find() { 
  Connection conn = getConnection(); 
  QueryRunner qr = new QueryRunner(); 
  String sql = "select * from stuInfo where stuNo=?"; 
  Object params[] = {5}; 
  try { 
   StuInfo stuInfo = (StuInfo)qr.query(conn,new BeanHandler<StuInfo>(StuInfo.class),params); 
   System.out.println("查詢成功："+stuInfo); 
   DbUtils.closeQuietly(conn); //關閉連結； 
  } catch (SQLException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 
 }  
 //查詢所有 
 public void getAll() { 
  Connection conn = getConnection(); 
  QueryRunner qr = new QueryRunner(); 
  String sql ="select * from stuInfo"; 
  ArrayList<StuInfo> list; 
  try { 
   list = (ArrayList<StuInfo>) qr.query(conn,new BeanListHandler<StuInfo>(StuInfo.class)); 
   for (StuInfo stuInfo : list) { 
    System.out.println(stuInfo); 
   } 
   DbUtils.closeQuietly(conn); //關閉連結； 
  } catch (SQLException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 

 } 
} 

（2）測試dbutils各種型別的處理器：

（1）ArrayHandler：把結果集中的第一行資料轉成物件陣列。測試程式碼如下：

public class Demo2 {
 @Test
 public void test1() throws SQLException {
  QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
  String sql = "select * from users";
  Object[] result = runner.query(sql,new ArrayHandler());
  System.out.println(result[0]);
  System.out.println(result[1]);
 }
}

（2）ArrayListHandler：把結果集中的每一行資料都轉成一個數組，再存放到List中。測試程式碼如下：

public class Demo2 {
 @Test
 public void test2() throws SQLException {
  QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
  String sql = "select * from users";
  List list = runner.query(sql,new ArrayListHandler());
  System.out.println(list);
 }
}

（3）ColumnListHandler：將結果集中某一列的資料存放到List中。測試程式碼如下：

public class Demo2 {
 @Test
 public void test3() throws SQLException {
  QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
  String sql = "select * from users";
  List list = (List) runner.query(sql,new ColumnListHandler("name"));
  System.out.println(list);
 }
}

（4）KeyedHandler(name)：將結果集中的每一行資料都封裝到一個Map裡，再把這些map再存到一個map裡，其key為指定的key：

這話聽起來有些繞口，但我用一張圖來解釋就很明白了。

public class Demo2 {
 @Test
 public void test4() throws SQLException {
  QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
  String sql = "select * from users";
  Map<Integer,Map<String,Object>> map = (Map<Integer,Object>>) runner.query(sql,new KeyedHandler("id"));
  for (Map.Entry<Integer,Object>> me : map.entrySet()) {
   int id = me.getKey();
   for (Map.Entry<String,Object> entry : me.getValue().entrySet()) {
    String name = entry.getKey();
    Object value = entry.getValue();
    System.out.println(name+"="+value);
   }
  }
 }
}

至此本文介紹了Java資料庫操作庫DButils類的使用方法與例項更多相關連結請檢視下面的相關連結