DBUtils 框架的中batch批處理使用
阿新 • • 發佈：2019-01-03
一、DBUtils 框架的使用
1、使用 dbutils 做增刪改查，批處理以及大文字操作
2、使用 DBUtils 框架管理事務。 （模擬銀行轉賬）
二、使用 JDBC 操作多個表
1、一對多（部門與員工）
2、多對多（學生和老師 學生與課程）
3、一對一（人和身份證）
三、關於 Oracle 資料對於二進位制資料的存取（面試題）
一、DBUitls 框架的使用
/**
* 使用dbutils做增刪改查 批處理大文字操作
* @author 呂鵬
*
*/
public class Demo01 {
/**建立demo表
+-------+-------------+------+-----+---------+-------+
| Field | Type | Null | Key | Default | Extra |
+-------+-------------+------+-----+---------+-------+
| id | int(11) | YES | | NULL | |
| name | varchar(10) | YES | | NULL | |
+-------+-------------+------+-----+---------+-------+
*/
1、使用 dbutils 做增刪改查，批處理以及大文字操作
package cn.itcast.dbutils.demo;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileReader;
import java.util.List;
import javax.sql.rowset.serial.SerialBlob;
import javax.sql.rowset.serial.SerialClob;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.junit.BeforeClass;
import org.junit.Test;
import cn.itcast.dbutil.JDBCUtils;
static QueryRunner runner;
@BeforeClass
public static void beforeClass(){
//獲取一個QueryRunner物件（構造方法帶資料來源 自動完成連線建立和釋放）
runner = new QueryRunner(C3P0Utils.getDataSource());
}
/**
* 執行插入操作
*/
@Test
public void testInsert()throws Exception{
String sql = "insert into demo values(?,?)";//宣告sql
Object[] params = {2,"insert"};//初始化引數
runner.update(sql, params);
}
/**
* 執行刪除操作
* @throws Exception
*/
@Test
public void testDelete() throws Exception{
String sql = "delete from demo where id = ?";
runner.update(sql, 1);
}
/**
* 執行更新操作
* @throws Exception
*/
@Test
public void testUpdate() throws Exception{
String sql = "update demo set name=? where id=?";
Object[] params = {"update",1};
runner.update(sql, params);
}
/**
* 查詢列表操作
* @throws Exception
*/
@Test
public void testListQuery() throws Exception{
String sql = "select * from demo";
List<Demo> list = (List<Demo>) runner.query(sql, new
BeanListHandler(Demo.class));
for(int i=0;i<list.size();i++){
System.out.println("ID:"+list.get(i).getId()+" 姓名是："+list.get(i).getName());
}
}
/**
* 查詢物件操作
* @throws Exception
*/
@Test
public void testObjectQuery() throws Exception{
String sql = "select * from demo where id = ?";
Demo demo = (Demo) runner.query(sql, 1, new BeanHandler(Demo.class));
System.out.println("ID:"+demo.getId()+" Name:"+demo.getName());
}
/**
* 批處理操作
* @throws Exception
*/
@Test
public void testBatch() throws Exception{
String sql = "insert into demo value (?,?)";
Object[][] params = new Object[10][];
for(int i=0;i<10;i++){
params[i] = new Object[]{i,"batch"};
}
runner.batch(sql, params);
}
/**
* 大文字操作
* @throws Exception
*/
@Test
public void testClob() throws Exception{
String sql = "insert into clob values(?)";
File file = new File("c:/a.txt");
Long l = file.length();
char[] buffer = new char[l.intValue()];
FileReader reader = new FileReader(file);
reader.read(buffer);
SerialClob clob = new SerialClob(buffer);
runner.update(sql, clob);
}
/**
* 二進位制影象操作
* @throws Exception
*/
@Test
public void testBlob() throws Exception{
String sql = "insert into blob values(?)";
File file = new File("c:/a.jpg");
Long l = file.length();
byte[] buffer = new byte[l.intValue()];
FileInputStream input = new FileInputStream(file);
input.read(buffer);
SerialBlob blob = new SerialBlob(buffer);
runner.update(sql,blob);
}
}
以上程式碼是使用 DButils 框架完成的增刪改差批處理以及大文字操作，其中，使用 了
QueryRunner 這個類，這個類是專門負責處理 sql 語句的，有四個構造方法，我們經常使用
到的是一個無參的構造方法和一個有參的， 引數就是資料來源， 當我們給其提供資料來源的時候
就是讓框架為我們自動的建立資料庫連線， 並釋放連線， 當這是處理一般操作的時候， 當我
們要進行事務處理的時候， 那麼連線的釋放就要由我們自己來決定了， 所以我們就不再使用
帶引數的 QueryRunner 構造方法了。具體用法下面詳解。
2、使用 DBUtils 框架管理事務。
剛才我們的增刪改差是為了演示我們的例子， 所以我們忽略了異常也沒有使用事務， 現在我
們使用事務模擬一個銀行轉賬，看一下 DBUtils 框架是如何幫助我們完成事務管理的。
在講解事務之前，需要讓大家理解一件事情就是，我們使用事務就不能使用其 QueryRunner
的有參構造方法了， 因為我們要自己定義事務的開關， 如果使用帶引數的構造就要讓框架幫
助我們關閉資料庫連線了， 所以這裡首先大家要明白。 那麼我們如何將我們的連線傳遞給持
久層呢，有同學說使用構造方法，是挺好的，通過構造方法將我們的 conn 傳遞給持久層，
但是為了降低耦合度， 我們不想在業務層出現持久層的程式碼， 那我們就使用一個類幫助我們
把這個連線傳遞過去， 就相當於使用工廠幫我們生成持久層物件一樣， 那我們使用什麼類呢，
我們使用 ThreadLoacl 這個類
關於 ThreadLocal 這個類， 可以查閱幫助文件瞭解， 在這裡我簡單的說明一下它的作用，
它的作用是在一個執行緒當中記錄我們的變數，這個變數可以是任意變數，包括我們的連線，
就是說我們生成一個連線以後可以放在這個執行緒中， 這樣， 只要是這個執行緒中任何物件都可
以共享這個連線，當這個執行緒結束以後，執行緒要刪除這個連線。
具體使用方法：
//宣告執行緒共享變數
public static ThreadLocal<Connection> container = new ThreadLocal<Connection>();
//獲取共享變數
public static ThreadLocal<Connection> getContainer(){
return container;
}
這樣，那麼我們就可以幫有關事務的操作，這些操作原本應該在業務層出現的程式碼， 現
在我們都把它放在工具類中， 因為不管是事務開啟還是事務提交， 回滾， 都是和連線關聯的，
我們把連線放在了這個共享的執行緒當中，那麼其方法也是共享的：工具類如下：
package cn.itcast.dbutil;
import java.sql.Connection;
import java.sql.SQLException;
import javax.sql.DataSource;
import com.mchange.v2.c3p0.ComboPooledDataSource;
public class JDBCUtils {
//c3p0連線池
public static ComboPooledDataSource ds = new ComboPooledDataSource();
//宣告執行緒共享變數
public static ThreadLocal<Connection> container = new ThreadLocal<Connection>();
//獲取共享變數
public static ThreadLocal<Connection> getContainer(){
return container;
}
/**
* 獲取資料來源
*/
public static DataSource getDataSource(){
return ds;
}
/**
* 獲取當前執行緒上的連線 開啟事務
*/
public static void startTransaction(){
Connection conn = container.get();//首先獲取當前執行緒的連線
if(conn == null){//如果連線為空
conn =getConnection(); //從連線池中獲取連線
container.set(conn);//將此
連線放在當前執行緒上
}
try {
conn.setAutoCommit(false);//開啟事務
} catch (SQLException e) {
throw new RuntimeException(e.getMessage(),e);
}
}
/**
* 提交事務
*/
public static void commit() {
Connection conn = container.get();// 從當前執行緒上獲取連線
if (conn != null) {// 如果連線為空，則不做處理
try {
conn.commit();// 提交事務
} catch (SQLException e) {
throw new RuntimeException(e.getMessage(), e);
}
}
}
/**
*回滾事務
*/
public static void rollback(){
Connection conn = container.get();//檢查當前執行緒是否存在連線
if(conn != null){
try {
conn.rollback();//回滾事務
// container.remove();//如果回滾了，就移除這個連線
} catch (SQLException e) {
throw new RuntimeException(e.getMessage(),e);
}
}
}
/**
* 關閉連線
*/
public static void close(){
Connection conn = container.get();
if(conn != null){
try {
conn.close();
} catch (SQLException e) {
throw new RuntimeException(e.getMessage(),e);
}finally{
container.remove();//從當前執行緒移除連線 切記
}
}
}
/**
* 獲取資料庫連線
* @return 資料庫連線 連線方式（連線池 錯c3p0）
*/
public static Connection getConnection(){
try {
return ds.getConnection();
} catch (Exception e) {
throw new RuntimeException();
}
}
}
在這個工具類裡要特別注意， 在關閉連線方法的裡面， finally 裡需要將這個執行緒的連線
移除，不然這個執行緒的連線得不到釋放。
這個明白了以後再看我們的銀行轉賬的模擬程式：
首先我們在模擬的 DAO 中完成查詢賬戶和修改賬戶的方法：
（1）查詢賬戶和修改賬戶程式碼：