天天看點

DbUtils操作資料庫

1.什麼是O-R  Mapping(對象-關系映射)

常用O-R Mapping映射工具

     Hibernate(全自動架構)

    Ibatis(半自動架構/SQL)

    Commons DbUti ls(隻是對JDBC簡單封裝)

還有JPA等之類的,這個不是特别了解,到目前為止也就接觸了Hibernate和DbUtils,Hiabernate給人的不用寫SQl語句,直接用配置檔案去映射關系,DuUtils仍然要寫sql語句,他隻不過簡化了crud的操作(個人看法)

2.dbutils的介紹

commons-dbutils 是 Apache 組織提供的一個開源 JDBC工具類庫,它是對JDBC的簡單封裝,學習成本極低,并且使用dbutils能極大簡化jdbc編碼的工作量,同時也不會影響程式的性能。DBUtils架構最核心的類,就是QueryRunner類還一個重要的接口ResultSetHandler(接口).

3.QueryRunner類提供了兩個構造方法:

  1>預設的構造方法

  2>需要一個 javax.sql.DataSource 來作參數的構造方法。

  3>public Object query(Connection conn, String sql, Object[] params, ResultSetHandler rsh) throws

 SQLException:執行一個查詢操作,在這個查詢中,對象數組中的每個元素值被用來作為查詢語句的置換參

數。該方法會自行處理 PreparedStatement 和 ResultSet 的建立和關閉。

    4>public Object query(String sql, Object[] params, ResultSetHandler rsh) throws SQLException: 幾乎

與第一種方法一樣;唯一的不同在于它不将資料庫連接配接提供給方法,并且它是從提供給構造方法的資料源

(DataSource) 或使用的setDataSource 方法中重新獲得 Connection。

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

     6>public int update(Connection conn, String sql, Object[] params) throws SQLException:用來執行一個更新(插入、更新或删除)操作。

     7>public int update(Connection conn, String sql) throws SQLException:用來執行一個不需要置換參數的更新操作。

4.ResultSetHandler接口 

    1>該接口用于處理 java.sql.ResultSet,将資料按要求轉換為另一種形式。

    2>ResultSetHandler 接口提供了一個單獨的方法:Object handle (java.sql.ResultSet .rs)。

    3>ResultSetHandler 接口的實作類

       a>BeanHandler:将結果集中的第一行資料封裝到一個對應的JavaBean執行個體中。(這個是針對javabean)

       b>BeanListHandler:将結果集中的每一行資料都封裝到一個對應的JavaBean執行個體中,存放到List裡。(這個是針對javabean)

       c>ArrayHandler:把結果集中的第一行資料轉成對象數組。(這個是針對數組的)

       d>ArrayListHandler:把結果集中的每一行資料都轉成一個對象數組,再存放到List中。(這個是針對數組的)

       e>MapHandler:将結果集中的第一行資料封裝到一個Map裡,key是列名,value就是對應的值。(這個是針對Map)

       f>MapListHandler:将結果集中的每一行資料都封裝到一個Map裡,然後再存放到List。(這個是針對Map)

       h>ScalarHandler:結果集中隻有一行一列資料。(這個是針對Long)

5.DbUtils類 

DbUtils :提供如關閉連接配接、裝載JDBC驅動程式等正常工作的工具類,裡面的所有方法都是靜态的。主要方法如下:

        1>public static void close(…) throws java.sql.SQLException: DbUtils類提供了三個重載的關閉方法。這些方法檢查所提供的參數是不是NULL,如果不是的話,它們就關閉Connection、Statement和ResultSet。

        2>public static void closeQuietly(…): 這一類方法不僅能在Connection、Statement和ResultSet為NULL情況下避免關閉,還能隐藏一些在程式中抛出的SQLException。

        3>public static void commitAndCloseQuietly(Connection conn): 用來送出連接配接,然後關閉連接配接,并且在關閉連接配接時不抛出SQL異常。 

        4>public static boolean loadDriver(java.lang.String driverClassName):這一方裝載并注冊JDBC驅動程式,如果成功就傳回true。使用該方法,你不需要捕捉這個異常ClassNotFoundException。

6.注意:

   1>DBUtils對象的update()方法,内部已經關閉相關的連接配接對象

   2>update(Connection)方法帶有Connection對象的,需要手工關閉,其它對象自動關閉

    update()方法無Connection對象的,DBUtils架構自動關閉

   3>以上這樣做的額原因是:主要考慮了在分層結構中,需要用到同一個Connection的問題

7.代碼練習

package cn.wwh.www.web.jdbc.dao;

import java.sql.SQLException;
import java.util.List;
import java.util.Map;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ArrayHandler;
import org.apache.commons.dbutils.handlers.ArrayListHandler;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.MapHandler;
import org.apache.commons.dbutils.handlers.MapListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;
import org.junit.Test;

import cn.wwh.www.web.jdbc.domain.User;
import cn.wwh.www.web.jdbc.util.JdbcUtils;

/**
 *類的作用: ResultSetHandler接口的各種實作類的簡單用法
 * 
 *@author 一葉扁舟
 *@version 1.0
 *@建立時間: 2014-9-6 下午04:16:43
 */

public class Demo4 {

	@Test
	public void testBeanHandler() throws SQLException {
		QueryRunner run = new QueryRunner(JdbcUtils.getDataSource());
		String sql = "select * from UserInfo";
		User user = run.query(sql, new BeanHandler(User.class));
		System.out.println("beanHandler" + user.toString());

	}

	@Test
	public void testBeanListHandler() throws SQLException {
		QueryRunner run = new QueryRunner(JdbcUtils.getDataSource());
		String sql = "select * from UserInfo";
		List<User> users = run.query(sql, new BeanListHandler(User.class));
		for (User user : users) {
			System.out.println(user.toString());
			System.out.println();

		}

	}

	@Test
	public void testArrayHandler() throws SQLException {
		QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
		String sql = "select * from userInfo";
		Object[] array = (Object[]) runner.query(sql, new ArrayHandler());
		System.out.println("編号 : " + array[0]);
		System.out.println("使用者名 : " + array[1]);
	}

	@Test
	public void testArrayListHandler() throws SQLException {
		QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
		String sql = "select * from userInfo";
		List<Object[]> list = (List<Object[]>) runner.query(sql,
				new ArrayListHandler());
		for (Object[] array : list) {
			System.out.print("編号 : " + array[0] + "\t");
			System.out.println("使用者名 : " + array[1]);
		}
	}

	@Test
	public void testMapHandler() throws SQLException {
		QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
		String sql = "select * from userInfo";
		Map<String, Object> map = runner.query(sql, new MapHandler());
		System.out.println("使用者名:" + map.get("username"));
	}

	@Test
	public void testMapListHandler() throws SQLException {
		QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
		String sql = "select * from userInfo";
		List<Map<String, Object>> list = runner
				.query(sql, new MapListHandler());
		for (Map<String, Object> map : list) {
			System.out.println("使用者名:" + map.get("username"));
			System.out.println("薪水:" + map.get("salary"));
		}
	}

	@Test
	public void testScalarHandler() throws SQLException {
		QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
		String sql = "select count(*) from userInfo";
		Long sum = (Long) runner.query(sql, new ScalarHandler());
		System.out.println("共有" + sum + "人");
	}

}