如何在Java中使用DButils類

這期內容當中小編將會給大家帶來有關如何在Java中使用DButils類，文章內容豐富且以專業的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

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, Object[] params, ResultSetHandler rsh) throws SQLException:　幾乎與第一種方法一樣；唯一的不同在于它不將數據庫連接提供給方法，并且它是從提供給構造方法的數據源(DataSource) 或使用的setDataSource 方法中重新獲得 Connection。

• public Object query(Connection conn, String sql, ResultSetHandler rsh) throws SQLException :執行一個不需要置換參數的查詢操作。

• public int update(Connection conn, String sql, 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, sql, 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, sql, 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, sql, 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, sql, 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, 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中使用DButils類了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關知識，歡迎關注億速云行業資訊頻道。