Oracle數(shù)據(jù)庫(kù)端測(cè)試環(huán)境見(jiàn)：http://www.cnblogs.com/yshyee/p/4392328.html

package com.mw.utils;import java.sql.Connection; import java.sql.SQLException; import java.util.logging.Level; import java.util.logging.Logger;/*** @author y* @date 2015-4-4 13:33:02* @version V1.0* @desc Connection 事務(wù)管理* 使用方式：* （１）首先從TransactionManager獲取Connection* （２）開(kāi)啟事務(wù)* （）進(jìn)行業(yè)務(wù)處理* （３）提交事務(wù)* （４）異常回滾事務(wù)* （５）關(guān)閉鏈接*/ public final class TransactionManager {/*** 定義局部線程變量,用于保存Connection*/private static final ThreadLocal<Connection> connThreadLocal = new ThreadLocal<Connection>();private TransactionManager(){}/*** 采用內(nèi)部類實(shí)現(xiàn)單例*/private static class TransactionManagerHolder{private static final TransactionManager instance = new TransactionManager();}public static TransactionManager getInstance(){return TransactionManagerHolder.instance;}/*** 1:從當(dāng)前線程局部變量中獲取數(shù)據(jù)庫(kù)連接資源* @return */public Connection get(){Connection conn = connThreadLocal.get();if(null==conn){conn = JdbcUtil.getConnection();connThreadLocal.set(conn);}return conn;}/*** 2:開(kāi)啟事務(wù)* @param conn */public void beginTransaction(Connection conn){try {if(null!=conn){if(conn.getAutoCommit()){conn.setAutoCommit(false);}}}catch (SQLException ex) {Logger.getLogger(TransactionManager.class.getName()).log(Level.SEVERE, null, ex);}}/*** 3:提交事務(wù)* @param conn */public void commitTransaction(Connection conn){try {if(null!=conn){if(!conn.getAutoCommit()){conn.commit();}}}catch (SQLException ex) {Logger.getLogger(TransactionManager.class.getName()).log(Level.SEVERE, null, ex);}}/*** 4:回滾事務(wù)* @param conn*/public void rollbackTransaction(Connection conn){try {if(null!=conn){if(!conn.getAutoCommit()){conn.rollback();}}}catch (SQLException ex) {Logger.getLogger(TransactionManager.class.getName()).log(Level.SEVERE, null, ex);}}/*** 5:關(guān)閉鏈接，將數(shù)據(jù)庫(kù)連接從當(dāng)前線程局部變量中移除* @param conn*/public void close(Connection conn){JdbcUtil.release(conn);connThreadLocal.remove();}}

測(cè)試：

package com.mw.test;import com.mw.utils.TransactionManager; import java.sql.CallableStatement; import java.sql.Connection; import java.sql.SQLException; import java.sql.Types; import java.util.List; import java.util.Map; import java.util.logging.Level; import java.util.logging.Logger; import org.apache.commons.dbutils.QueryRunner; import org.apache.commons.dbutils.handlers.MapHandler; import org.apache.commons.dbutils.handlers.MapListHandler;/*** @author y* @date 2015-4-4 12:34:05* @version 1.0* @desc */ public class Test {public static void main(String[] args) {QueryRunner qr = new QueryRunner();Connection conn = TransactionManager.getInstance().get();TransactionManager.getInstance().beginTransaction(conn);int age = 10;try {CallableStatement cs = conn.prepareCall("{call pack_user.p_user_select(?,?)}");cs.setInt(1, age);cs.registerOutParameter(2, Types.VARCHAR);cs.execute();String succ = cs.getString(2);if("T".equalsIgnoreCase(succ)){String sql = "select * from tmp_yshy";List<Map<String, Object>> list = qr.query(conn, sql, new MapListHandler());for(Map map:list){System.out.println("c1:"+map.get("c1")+",c2:"+map.get("c2"));}}else{System.out.println("succ:"+succ);}TransactionManager.getInstance().commitTransaction(conn);} catch (SQLException ex) {TransactionManager.getInstance().rollbackTransaction(conn);Logger.getLogger(Test.class.getName()).log(Level.SEVERE, null, ex);} finally{TransactionManager.getInstance().close(conn);}}}

?

轉(zhuǎn)載于:https://www.cnblogs.com/yshyee/p/4392377.html

總結(jié)

以上是生活随笔為你收集整理的封装JDBC事务操作，执行存储过程测试的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。