DbUtils是Javar的一個(gè)為簡(jiǎn)化JDBC操作類(lèi)庫(kù)

commons-dbutils是Apache組織提供的一個(gè)開(kāi)源JDBC工具類(lèi)庫(kù)，它是對(duì)JDBC的簡(jiǎn)單封裝，學(xué)習(xí)成本極低，并且使用dbutils能極大簡(jiǎn)化jdbc編碼的工作量，同時(shí)也不會(huì)影響程序的性能。因此dbutils成為很多不喜歡hibernate的公司的首選。

整個(gè)dbutils總共才3個(gè)包：

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

org.apache.commons.dbutils.handlers（該包中的類(lèi)都是實(shí)現(xiàn)org.apache.commons.dbutils.ResultSetHandler接口的實(shí)現(xiàn)類(lèi)）

org.apache.commons.dbutils.wrappers（該包中的類(lèi)主要是封裝了對(duì)Sql結(jié)果集的操作）

1.DbUtils包的簡(jiǎn)介：

1.1 org.apache.commons.dbutils 包的使用和相關(guān)類(lèi)的簡(jiǎn)介：

接口摘要:

- ResultSetHandler 將ResultSet轉(zhuǎn)換為別的對(duì)象的工具。

- RowProcessor 將ResultSet行轉(zhuǎn)換為別的對(duì)象的工具。

類(lèi)摘要:

BasicRowProcessor RowProcessor接口的基本實(shí)現(xiàn)類(lèi)。

BeanProcessor BeanProcessor匹配列明到Bean屬性名，并轉(zhuǎn)換結(jié)果集列到Bean對(duì)象的屬性中。

DbUtils 一個(gè)JDBC輔助工具集合。

ProxyFactory 產(chǎn)生JDBC接口的代理實(shí)現(xiàn)。

QueryLoader 屬性文件加載器，主要用于加載屬性文件中的 SQL 到內(nèi)存中。

QueryRunner 使用可插拔的策略執(zhí)行SQL查詢并處理結(jié)果集。

ResultSetIterator 包裝結(jié)果集為一個(gè)迭代器。

1.2 org.apache.commons.dbutils.handlers 的使用和相關(guān)類(lèi)的簡(jiǎn)介：

類(lèi)摘要:

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

SqlNullCheckedResultSet 在每個(gè)getXXX方法上檢查SQL NULL值的ResultSet包裝類(lèi)。

StringTrimmedResultSet 取出結(jié)果集中字符串左右空格的ResultSet包裝類(lèi)。

2.使用DBUtils(兩類(lèi)一接口)

只是使用的話，只看兩個(gè)類(lèi)（DbUtils 和QueryRunner）和一個(gè)接口（ResultSethandler）就可以了。

2.1 DbUtils類(lèi)：

DbUtils是一個(gè)為做一些諸如關(guān)閉連接、裝載JDBC驅(qū)動(dòng)程序之類(lèi)的常規(guī)工作提供有用方法的類(lèi)，它里面所有的方法都是靜態(tài)的。

這個(gè)類(lèi)里的重要方法有：

(1)close()：

DbUtils類(lèi)提供了三個(gè)重載的關(guān)閉方法。這些方法檢查所提供的參數(shù)是不是NULL，

如果不是的話，它們就關(guān)閉連接、聲明和結(jié)果集（ResultSet）。

(2)CloseQuietly:

CloseQuietly這一方法不僅能在連接、聲明或者結(jié)果集（ResultSet）為NULL情況下避免關(guān)閉，還能隱藏一些在程序中拋出的SQLEeception。如果你不想捕捉這些異常的話，這對(duì)你是非常有用的。在重載CloseQuietly方法時(shí)，特別有用的一個(gè)方法closeQuietly(Connection conn,Statement stmt,ResultSet rs)，這是因?yàn)樵诖蠖鄶?shù)情況下，連接、聲明和結(jié)果集（ResultSet）是你要用的三樣?xùn)|西，而且在最后的塊你必須關(guān)閉它們。使用這一方法，你最后的塊就可以只需要調(diào)用這一方法即可。

(3)CommitAndCloseQuietly(Connection conn)：

這一方法用來(lái)提交連接，然后關(guān)閉連接，并且在關(guān)閉連接時(shí)不向上拋出在關(guān)閉時(shí)發(fā)生的一些SQL異常,LoadDriver(String driveClassName):這一方法裝載并注冊(cè)JDBC驅(qū)動(dòng)程序，如果成功就返回TRUE。使用這種方法，你不需要去捕捉這個(gè)異常ClassNotFoundException。使用loadDrive方法，編碼就變得更容易理解，你也就得到了一個(gè)很好的Boolean返回值，這個(gè)返回值會(huì)告訴你驅(qū)動(dòng)類(lèi)是不是已經(jīng)加載成功了。

2.2 QureryRunner類(lèi)：

該類(lèi)簡(jiǎn)單化了SQL查詢，它與ResultSetHandler組合在一起使用可以完成大部分的數(shù)據(jù)庫(kù)操作，能夠大大減少編碼量。

QueryRunner類(lèi)提供了兩個(gè)構(gòu)造方法：

（1）一個(gè)是一個(gè)空構(gòu)造器；

（2）另一個(gè)則拿一個(gè) javax.sql.DataSource 來(lái)作為參數(shù)。因此，在你不用為一個(gè)方法提供一個(gè)數(shù)據(jù)庫(kù)連接來(lái)作為參數(shù)的情況下，提供給構(gòu)造器的數(shù)據(jù)源(DataSource) 被用來(lái)獲得一個(gè)新的連接并將繼續(xù)進(jìn)行下去。

主要的方法：

• public Object query(Connection conn, String sql, Object[] params, ResultSetHandler rsh) throws SQLException：執(zhí)行一個(gè)查詢操作，在這個(gè)查詢中，對(duì)象數(shù)組中的每個(gè)元素值被用來(lái)作為查詢語(yǔ)句的置換參數(shù)。該方法會(huì)自行處理 PreparedStatement 和 ResultSet 的創(chuàng)建和關(guān)閉。
• public Object query(String sql, Object[] params, ResultSetHandler rsh) throws SQLException:　幾乎與第一種方法一樣；唯一的不同在于它不將數(shù)據(jù)庫(kù)連接提供給方法，并且它是從提供給構(gòu)造方法的數(shù)據(jù)源(DataSource) 或使用的setDataSource 方法中重新獲得 Connection。
• public Object query(Connection conn, String sql, ResultSetHandler rsh) throws SQLException :執(zhí)行一個(gè)不需要置換參數(shù)的查詢操作。
• public int update(Connection conn, String sql, Object[] params) throws SQLException:用來(lái)執(zhí)行一個(gè)更新（插入、更新或刪除）操作,返回的是受語(yǔ)句影響的行數(shù)
• public int update(Connection conn, String sql) throws SQLException：用來(lái)執(zhí)行一個(gè)不需要置換參數(shù)的更新操作, 返回的是受語(yǔ)句影響的行數(shù)

2.3:ResultSetHandler接口：

該接口用于處理Java.sql.ResultSet，將數(shù)據(jù)按要求轉(zhuǎn)換為另一種形式。ResultSetHandler接口提供了一個(gè)單獨(dú)的方法：Object handle (java.sql.ResultSet rs)。因此任何ResultSetHandler 的執(zhí)行需要一個(gè)結(jié)果集（ResultSet）作為參數(shù)傳入，然后才能處理這個(gè)結(jié)果集，再返回一個(gè)對(duì)象。

因?yàn)榉祷仡?lèi)型是java.lang.Object，所以除了不能返回一個(gè)原始的Java類(lèi)型之外，其它的返回類(lèi)型并沒(méi)有什么限制。如果你發(fā)現(xiàn)這七個(gè)執(zhí)行程序中沒(méi)有任何一個(gè)提供了你想要的服務(wù)，你可以自己寫(xiě)執(zhí)行程序并使用它。這一組件提供了ArrayHandler, ArrayListHandler, BeanHandler, BeanListHandler, MapHandler, MapListHandler, and ScalarHandler等執(zhí)行程序。其方法如下：

3.代碼實(shí)戰(zhàn)：

使用遵從以下步驟：

1．加載JDBC驅(qū)動(dòng)程序類(lèi)，并用DriverManager來(lái)得到一個(gè)數(shù)據(jù)庫(kù)連接conn。

2．實(shí)例化 QueryRunner,得到實(shí)例化對(duì)象qRunner。

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

首先生成以下數(shù)據(jù)庫(kù)表：

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

（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(); 

 } 
 //靜態(tài)方法獲取數(shù)據(jù)庫(kù)鏈接對(duì)象：
 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,"韓國(guó)"}; 
  int i; 
  try { 
   i = qr.update(conn, sql, param); //i是受操作影響的行數(shù)；
   System.out.println("添加成功："+i); 
   DbUtils.closeQuietly(conn); //關(guān)閉鏈接； 
  } 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, sql, 7); i是受操作影響的行數(shù)；
   System.out.println("刪除成功："+i); 
   DbUtils.closeQuietly(conn); //關(guān)閉鏈接；  
  } 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, sql, params); 
   System.out.println("修改成功："+i); // i是受操作影響的行數(shù)；
   DbUtils.closeQuietly(conn); //關(guān)閉鏈接； 
  } 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, sql, new BeanHandler<StuInfo>(StuInfo.class), params); 
   System.out.println("查詢成功："+stuInfo); 
   DbUtils.closeQuietly(conn); //關(guān)閉鏈接； 
  } 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, sql, new BeanListHandler<StuInfo>(StuInfo.class)); 
   for (StuInfo stuInfo : list) { 
    System.out.println(stuInfo); 
   } 
   DbUtils.closeQuietly(conn); //關(guān)閉鏈接； 
  } catch (SQLException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 

 } 
} 

（2）測(cè)試dbutils各種類(lèi)型的處理器：

（1）ArrayHandler：把結(jié)果集中的第一行數(shù)據(jù)轉(zhuǎn)成對(duì)象數(shù)組。測(cè)試代碼如下：

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：把結(jié)果集中的每一行數(shù)據(jù)都轉(zhuǎn)成一個(gè)數(shù)組，再存放到List中。測(cè)試代碼如下：

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：將結(jié)果集中某一列的數(shù)據(jù)存放到List中。測(cè)試代碼如下：

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)：將結(jié)果集中的每一行數(shù)據(jù)都封裝到一個(gè)Map里，再把這些map再存到一個(gè)map里，其key為指定的key：

這話聽(tīng)起來(lái)有些繞口，但我用一張圖來(lái)解釋就很明白了。

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, Map<String, Object>>) runner.query(sql, new KeyedHandler("id"));
  for (Map.Entry<Integer, Map<String, 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數(shù)據(jù)庫(kù)操作庫(kù)DButils類(lèi)的使用方法與實(shí)例更多相關(guān)鏈接請(qǐng)查看下面的相關(guān)鏈接

最新評(píng)論