2. 程式人生 > >JDBC : 使用DBUtils 工具類

JDBC : 使用DBUtils 工具類

阿新 • • 發佈：2019-01-06

所需jar包 : commons-dbutils-1.6.jar

DbUtils類 

1.DbUtils ：提供如關閉連線、裝載JDBC驅動程式等常規工作的工具類，裡面的所有方法都是靜態的。主要方法如下：
  -public static void close(…) throws java.sql.SQLException：　DbUtils類提供了三個過載的關閉方法。這些方法檢查所提供的引數是不是NULL，如果不是的話，它們就關閉Connection、Statement和ResultSet。
  -public static void closeQuietly(…): 這一類方法不僅能在Connection、Statement和ResultSet為NULL情況下避免關閉，還能隱藏一些在程式中丟擲的SQLEeception。
  -public static void commitAndCloseQuietly(Connection conn)： 用來提交連線，然後關閉連線，並且在關閉連線時不丟擲SQL異常。 
  -public static boolean loadDriver(java.lang.String driverClassName)：這一方裝載並註冊JDBC驅動程式，如果成功就返回true。使用該方法，你不需要捕捉這個異常ClassNotFoundException。

1.1QueryRunner類 

該類簡單化了SQL查詢，它與ResultSetHandler組合在一起使用可以完成大部分的資料庫操作，能夠大大減少編碼量。
QueryRunner類提供了兩個構造方法：
  -預設的構造方法
  -需要一個 javax.sql.DataSource 來作引數的構造方法。

QueryRunner類的主要方法

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：用來執行一個不需要置換引數的更新操作。

<span style="font-size:14px;">/**
	 * 測試 QueryRunner 的 Update 方法
	 * 該方法用於 INSERT , UPDATE , DELETE 
	 */
	@Test
	public void testQueryRunnerUpdate() {
		//1.建立 QueryRunner 的實現類
		QueryRunner queryRunner = new QueryRunner();
		
		//String sql = "delete from temp where id in(?,?)";
		//String sql = "insert into temp(id,name,birth) values(?,?,?)";
		String sql = "update temp set name = ? where id = ?";
		//2.使用 update
		Connection conn = null;
		
		try {
			conn = JDBC_Tools.getConnection();
			queryRunner.update(conn,sql,"OK",1);
		} catch (Exception e) {
			JDBC_Tools.relaseSource(conn, null);
		}	
	}</span>
1.2.ResultSetHandler介面 
該介面用於處理 java.sql.ResultSet，將資料按要求轉換為另一種形式。
ResultSetHandler 介面提供了一個單獨的方法：Object handle (java.sql.ResultSet .rs)。
 
<span style="font-size:14px;">class MyResultSetHandler implements ResultSetHandler<Object>{

		@Override
		public Object handle(ResultSet rs) 
							throws SQLException {
//			System.out.println(" handler is OK!");
//			return "OVER";
			List<Person> persons = new ArrayList<Person>();
			while(rs.next()){
				Integer id = rs.getInt(1);
				String name = rs.getString(2);
				Date birth = rs.getDate(3);
				persons.add(new Person(id,name,birth));
			}
			return persons;
		}
	}
	/**
	 * 測試 QueryRunner 的 Query 方法的返回值取決於ResultSetHandler引數的
	 * handle 方法的返回值
	 */
	@Test
	public void testQueryRunnerQuery(){
		QueryRunner queryRunner = new QueryRunner();
		Connection conn = null;
		try {
			conn = JDBC_Tools.getConnection();
			
			String sql = "select * from temp ";
		@SuppressWarnings("unchecked")
		List<Object> ls = (List<Object>) queryRunner.query(conn, sql, new MyResultSetHandler());
		for(Object p : ls)
			System.out.println(p);
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			JDBC_Tools.relaseSource(conn, null);
		}
		
	}</span>

1.3 ResultSetHandler 介面的實現類

ArrayHandler：把結果集中的第一行資料轉成物件陣列。
ArrayListHandler：把結果集中的每一行資料都轉成一個數組，再存放到List中。
BeanHandler：將結果集中的第一行資料封裝到一個對應的JavaBean例項中。
BeanListHandler：將結果集中的每一行資料都封裝到一個對應的JavaBean例項中，存放到List裡。

ColumnListHandler：將結果集中某一列的資料存放到List中。
KeyedHandler(name)：將結果集中的每一行資料都封裝到一個Map裡，再把這些map再存到一個map裡，其key為指定的key。
MapHandler：將結果集中的第一行資料封裝到一個Map裡，key是列名，value就是對應的值。
MapListHandler：將結果集中的每一行資料都封裝到一個Map裡，然後再存放到List

<span style="font-size:14px;">package xuezaipiao1;


import java.sql.Connection;
import java.sql.Date;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;
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;
/**
 * 測試DbUtils 工具類 
 * @author Kevy
 */
public class testDbUtils {

	/**
	 * ScalarHandler : 把結果集轉為一個數值(可以是任意基本資料型別和字串),
	 */
	@Test
	public void testScalarHandler(){
		Connection conn = null;
		QueryRunner queryRunner = new QueryRunner();
		try {
			conn = JDBC_Tools.getConnection();
			//String sql = "select name from temp where id = ?";
			String sql = "select count(id) from temp";
			Object s = queryRunner.query(conn, sql, 
					new ScalarHandler<Person>());
			
			System.out.println(s);
			
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}finally{
			JDBC_Tools.relaseSource(conn, null);
		}
	}
	/**
	 * MapListHandler : 將結果集轉為一個  Map 的 List (不是繫結Javabean)
	 * 一個 Map 對應一條查詢得到的記錄 鍵:SQL 查詢的列名(不是列的別名), 值:列的值
	 * MapListHandler :返回的是多條記錄對應的Map 集合
	 */
	@Test
	public void testMapListHandler(){
		Connection conn = null;
		QueryRunner queryRunner = new QueryRunner();
		try {
			conn = JDBC_Tools.getConnection();
			String sql = "select * from temp";
			List<Map<String, Object>> ls = queryRunner.query(conn, sql, 
					new MapListHandler());
			
			for(Map<String, Object> map : ls){
				for(Map.Entry<String , Object> m : map.entrySet()){
					System.out.print(m.getKey());
					System.out.println(":"+m.getValue());
				}
			}
			
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}finally{
			JDBC_Tools.relaseSource(conn, null);
		}
	}
	
	/**
	 * MapHandler : 返回 SQL 對應的第一條記錄對應的 Map物件
	 * 鍵:SQL 查詢的列名(不是列的別名), 不是繫結Javabean
	 * 值:列的值
	 */
	@Test
	public void testMapHandler(){
		Connection conn = null;
		QueryRunner queryRunner = new QueryRunner();
		try {
			conn = JDBC_Tools.getConnection();
			String sql = "select id,name,birth from temp";
			Map<String, Object> map = queryRunner.query(conn, sql, 
					new MapHandler());
			
			for(Map.Entry<String , Object> entry : map.entrySet()){
				System.out.print(entry.getKey()+":");
				System.out.println(entry.getValue());
			}
			
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}finally{
			JDBC_Tools.relaseSource(conn, null);
		}
	}
	/**
	 * BeanListHandler : 把結果集轉為List,該List不為null,但可能為空集合(size()==0)
	 * 若SQL語句能夠查詢到記錄,List中存放建立BeanListHandler 傳入的Class 引數對應的物件 
	 * 繫結Javabean，要查詢的列的別名 必須與 對應 java類的屬性值相同
	 */
	@Test
	public void testBeanListHandler(){
		Connection conn = null;
		QueryRunner queryRunner = new QueryRunner();
		try {
			conn = JDBC_Tools.getConnection();
			String sql = "select * from temp";
			List<Person> ls = queryRunner.query(conn, sql, 
					new BeanListHandler<Person>(Person.class));
			for(Person p : ls)
			System.out.println(p);
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}finally{
			JDBC_Tools.relaseSource(conn, null);
		}
	}
	
	/**
	 * BeanHandler 把結果集的第一條記錄轉為建立 BeanHandler 物件時傳入的 Class 引數對應的物件
	 * 只返回一條,繫結Javabean，要查詢的列的別名 必須與 對應 java類的屬性值相同
	 * @param <T>
	 * 
	 */
	@Test
	public <T> void testBeanHandler(){
		
		Connection conn = null;
		QueryRunner queryRunner = new QueryRunner();
		try {
			conn = JDBC_Tools.getConnection();
			String sql = "select * from temp where id = ?";
			//BeanHandler<T> 
			Person p = queryRunner.query(conn, sql, 
					new BeanHandler<Person>(Person.class), 1);
			System.out.println(p);
			
			
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}finally{
			JDBC_Tools.relaseSource(conn, null);
		}
	}
	
	
	class MyResultSetHandler implements ResultSetHandler<Object>{

		@Override
		public Object handle(ResultSet rs) 
							throws SQLException {
//			System.out.println(" handler is OK!");
//			return "OVER";
			List<Person> persons = new ArrayList<Person>();
			while(rs.next()){
				Integer id = rs.getInt(1);
				String name = rs.getString(2);
				Date birth = rs.getDate(3);
				persons.add(new Person(id,name,birth));
			}
			return persons;
		}
	}
	/**
	 * 測試 QueryRunner 的 Query 方法的返回值取決於ResultSetHandler引數的
	 * handle 方法的返回值
	 */
	@Test
	public void testQueryRunnerQuery(){
		QueryRunner queryRunner = new QueryRunner();
		Connection conn = null;
		try {
			conn = JDBC_Tools.getConnection();
			
			String sql = "select * from temp ";
		@SuppressWarnings("unchecked")
		List<Object> ls = (List<Object>) queryRunner.query(conn, sql, new MyResultSetHandler());
		for(Object p : ls)
			System.out.println(p);
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			JDBC_Tools.relaseSource(conn, null);
		}
		
	}
	/**
	 * 測試 QueryRunner 的 Update 方法
	 * 該方法用於 INSERT , UPDATE , DELETE 
	 */
	@Test
	public void testQueryRunnerUpdate() {
		//1.建立 QueryRunner 的實現類
		QueryRunner queryRunner = new QueryRunner();
		
		//String sql = "delete from temp where id in(?,?)";
		//String sql = "insert into temp(id,name,birth) values(?,?,?)";
		String sql = "update temp set name = ? where id = ?";
		//2.使用 update
		Connection conn = null;
		
		try {
			conn = JDBC_Tools.getConnection();
			queryRunner.update(conn,sql,"OK",1);
		} catch (Exception e) {
			JDBC_Tools.relaseSource(conn, null);
		}	
	}
}
</span>

相關推薦

JDBC : 使用DBUtils 工具類

所需jar包 : commons-dbutils-1.6.jar DbUtils類  1.DbUtils ：提供如關閉連線、裝載JDBC驅動程式等常規工作的工具類，裡面的所有方法都是靜態的。主要方法如下：   -public static void close(…) thr

【java基礎：JDBC】基於DBUtils工具類查詢資料庫的8種方式！非常重要！

package cn.itcast.demo2; import java.sql.Connection; import java.sql.SQLException; import java.util.List; import java.util.Map; import

java學習筆記之DBUtils工具類

return on() 變參 ner where 占位符 使用步驟 args user DBUtils工具類 一.介紹 　　DBUtils是Apache組織開源的數據庫工具類。 二.使用步驟 　　①.創建QueryRunner對象 　　②.調用update()方法或者que

Java學習筆記48（DBUtils工具類一）

lex time name span 載器 .sql 定義 ride oot 上一篇的例子可以明顯看出，在增刪改查的時候，很多的代碼都是重復的， 那麽，是否可以將增刪改查封裝成一個類，方便使用者 package demo; /* * 實現JDBC的工具類 *

【資料庫筆記】編寫JDBC的工具類

註冊驅動和資料庫連線是固定操作，何不將這些固定操作封裝成一個類，並且提供靜態方法返回資料庫連線物件，達到程式碼的重複利用： /* * JDBC的工具類 * 用於註冊驅動,連線資料庫 */ import java.sql.Connection; import java.sql.Drive

寫jdbc的工具類 java

為什麼要有工具類 jdbc 連線資料庫中很常用，但程式碼量又多，所以編寫一個工具類是很重要的。 之前我們已經寫了jdbc連線的程式碼 這裡我們就寫 一個工具類並實現 程式碼 public class JDBCUtil { static String driverClass

DBUtils工具類庫的使用

關於Commons-DBUtilsCommons-DBUtils是Apache組織提供的一個開源的JDBC工具類庫，它對JDBC進行了簡單的封裝，學習起來很簡單， 而且大大的簡化了工作量，關於資料庫的操作一般一兩句就可以解決問題了，並且不會影響程式的效能。DBUtils的核心

Java資料庫的操作——DBUtils工具類結果集處理的方式有幾種？

public class QueryRunnerDemo{ private static Connection con=JDBCUtils.getConnection(); public static void main(String[] args) throws SQLException{ QueryRun

jdbc之工具類DBUtil的使用

　　首先回顧一下jdbc的使用方法： 　　1. 註冊驅動 　　2. 建立連線 　　3. 建立statement 　　4. 定義sql語句 　　5. 執行sql語句，如果執行的是查詢需遍歷結果集 　　6. 關閉連線 　　其中建立連線和關閉連線都是可以封裝成工具類的，因此給出DBUtil程式碼如下：

030 DBUtils工具類與DataSource資料庫連線池

1. DButils工具類的介紹個三個核心類 1. DButils工具類的介紹個三個核心類 a: 概述 DBUtils是java程式設計中的資料庫操作實用工具，小巧簡單實用。 DBUtils封裝了對JDBC的操作，簡化了JDBC操作，可以少寫

JAVA-使用連線池的DBUtils工具類及其使用

需要引入四個jar包 /********************************************/ package com.dxm.dbcp; import javax.sql.DataSource; import org.apache.commons.dbcp

JDBC的工具類的抽取

dem trac found eas ger lex next() drive tac 1.1.1 抽取一個JDBC的工具類因為傳統JDBC的開發，註冊驅動，獲得連接，釋放資源這些代碼都是重復編寫的。所以可以將重復的代碼提取到一個類中來完成。 /** * JDBC的工具類

DbUtils，一個替代JDBC的小工具類

在使用之前需要有一些準備，我使用的是mysql資料庫 這裡建立的就是一個測試類，中間使用的註釋@Test就類似於main函式，可以直接右擊run as————》JUnit Test就可以執行，但是提前是你要有 import org.junit.Test這個包 package

jdbc工具類封裝

ram ive while lock ins connect cat stack sys 封裝 package util; import java.sql.Connection; import java.sql.DriverManager; import

JDBC工具類相關

lex ati tac dstat ram stmt 提取 ini .get 第一種（單純提取註冊驅動和獲取連接）： 把註冊驅動，獲取連接一起寫入工具類靜態方法裏，並釋放資源 1 import java.sql.Connection; 2 import java.sq

自定義的jdbc連接工具類JDBCUtils【java 工具類】

tco 成功 val update red source dex imp 添加 JDBCUtils 類： 　　1. 創建私有的屬性*（連接數據庫必要的四個變量）：dreiver url user password 　　2. 將構造函數私有化 　　3.將註冊驅動寫入靜態代碼塊

抽取JDBC工具類並增刪改查

for 文件 import -c auto -a san pac ext 抽取工具類： package demo; /* * 工具類 */ import java.sql.Connection; import java.sql.DriverManager; imp

JDBC【事務、元數據、改造JDBC工具類】

true 出了 簡單 static comm 使用 當前 eat 得到 1.事務 一個SESSION所進行的所有更新操作要麽一起成功，要麽一起失敗 舉個例子:A向B轉賬，轉賬這個流程中如果出現問題，事務可以讓數據恢復成原來一樣【A賬戶的錢沒變，B賬戶的錢也沒變】。 事例

JDBC的配置文件，郵件，密碼加密工具類

協議 登錄驗證 substring mon smtp getc getclass authent protoc 配置文件 url=jdbc:mysql:///sysclassName=com.mysql.jdbc.Driverusername=rootpassword=

jdbc 工具類 封裝數據庫連接

on() mage stream res jdb com statement stack pos 首先，創建一個文件db.properties，用於保存數據庫連接信息。 編寫代碼連接數據庫 package com.jdbc; import java.io.IO