之前一直覺得ThreadLocal沒用，後來看到別人在資料庫連線中的相關講解後發現這個類真的很實用。

在資料庫連線中為了提高伺服器的響應速度，通常都會採用資料庫連線池的方式來獲取資料庫連線。

C3P0Utils實現

public class C3P0Utils {

	private static DataSource source;//資料來源
	static{
		source = new ComboPooledDataSource("mysql");//根據配置檔案初始化資料來源
	}
	
	/**
	 * 獲取資料庫連線
	 * @return
	 * @throws SQLException
	 */
	public static Connection getConnection() throws SQLException{
		return source.getConnection();
	}
}
 

上面的程式碼是使用C3P0連線池獲取資料庫連線的工具類，其中DataSource是jdk內建的資料庫連線池介面，也可以說是sun公司制定的關於資料庫連線池的一套標準，任何資料庫連線池都要實現該介面。

TransactionThreadLocal 實現

public class TransactionThreadLocal {

	private static ThreadLocal<Connection> tc = new ThreadLocal<>();
	/**
	 * 返回當前執行緒的資料庫連線
	 * @return
	 * @throws SQLException
	 */
	public static Connection getConnection() throws SQLException{
		Connection connection = tc.get();
		if(connection == null){
			connection = C3P0Utils.getConnection();
			tc.set(connection);
		}
		return connection;
	}
	
	/**
	 * 開啟事務
	 * @throws SQLException
	 */
	public static void startTransaction() throws SQLException{
		getConnection().setAutoCommit(false);
	}
	/**
	 * 提交事務
	 * @throws SQLException
	 */
	public static void commit() throws SQLException{
		getConnection().commit();
	}
	
	/**
	 * 事務回滾
	 * @throws SQLException
	 */
	public static void rollback() throws SQLException{
		getConnection().rollback();
	}
	
	/**
	 * 關閉資料庫
	 * @throws SQLException
	 */
	public static void close() throws SQLException{
		getConnection().close();//關閉資料庫
		tc.remove();//將該執行緒的connection物件移除
	}
}
 

這個類是用來操作資料庫連線的一個工具類。

getConnection()方法是獲取當前執行緒Connection物件的一個方法。ThreadLocal類中有一個get()方法，該方法用來獲取當前執行緒的儲存的ThreadLocal中的物件，每個執行緒儲存的是該物件的一個副本，不同執行緒之間不會互相影響，一個執行緒對該物件的修改不會影響其他執行緒中該物件的值。set(T value)方法用來設定當前執行緒的該物件的值。

使用ThreadLocal物件來儲存Connection物件有一個好處，它可以保證當前執行緒中任何地方的Connection資料庫連線都是相同的。我們知道資料庫操作中事務是使用比較頻繁的一個東西，一個事務中包含多個數據庫操作，我們必須保證一個事務中所有操作所使用的Connection物件

public class BookDaoImp implements BookDao{
 @Override
	public void edit(Book book) throws Exception {
		Connection conn = TransactionThreadLocal.getConnection();
		String sql = "update book set name=? where id=?";
		PreparedStatement pst = conn.prepareStatement(sql);
		pst.setString(1, "name");
		pst.setString(2, id);
		pst.execute();
	}
}