MyDataSourceUtils使用ThreadLocal对象
生活随笔
收集整理的這篇文章主要介紹了
MyDataSourceUtils使用ThreadLocal对象
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
ThreadLocal:實現的是通過線程綁定的方式傳遞參數
package com.learn.utils;import java.sql.Connection; import java.sql.SQLException;import com.mchange.v2.c3p0.ComboPooledDataSource;public class MyDataSourceUtils {//獲得Connection ----- 從連接池中獲取private static ComboPooledDataSource dataSource = new ComboPooledDataSource();//創建ThreadLocalprivate static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();//開啟事務public static void startTransaction() throws SQLException{Connection conn = getCurrentConnection();conn.setAutoCommit(false);}//獲得當前線程上綁定的connpublic static Connection getCurrentConnection() throws SQLException{//從ThreadLocal尋找 當前線程是否有對應ConnectionConnection conn = tl.get();if(conn==null){//獲得新的connectionconn = getConnection();//將conn資源綁定到ThreadLocal(map)上tl.set(conn);}return conn;}public static Connection getConnection() throws SQLException{return dataSource.getConnection();}//回滾事務public static void rollback() throws SQLException {getCurrentConnection().rollback();}//提交事務public static void commit() throws SQLException {Connection conn = getCurrentConnection();conn.commit();//將Connection從ThreadLocal中移除tl.remove();conn.close();}}?
?
超強干貨來襲 云風專訪:近40年碼齡,通宵達旦的技術人生總結
以上是生活随笔為你收集整理的MyDataSourceUtils使用ThreadLocal对象的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: ThreadLocal封装SimpleD
- 下一篇: 使用ThreadLocal来解决问题