采用ThreadLocal维护Connection

        在以前的项目中，也曾经使用过事务的机制，总结说来一共有三种（其实本质都是一样的，只是表现形式不同）：

        第一种：在数据库中直接写在存储过程中（这个最简单，这里不再说明，存在的问题是代码完全不能复用，那里使用要单独写sql语句）

        第二种：采用分层的思想进行设计，在D层进行方法的封装（这个很像直接写在数据库中存在的问题和上面的也一样——复用问题）。

        第三种：在D层只写细粒度的操作方法，在上一层或者其他层开启事务进行组装，这种方法往往涉及到Connection的传递问题，当然在我原来的博客中也有写放在静态变量中D层用的时候直接取得。当然这样做是没有考虑线程安全的问题的。如果进行传递也是一件很麻烦的事。

        我们采用ThreadLocal维护Connection可以避免这种情况。

        ThreadLocal很容易让人望文生义，想当然地认为是一个“本地线程”。其实，ThreadLocal并不是一个Thread，而是Thread的局部变量，也许把它命名为ThreadLocalVariable更容易让人理解一些。

        该类提供了线程局部 (thread-local) 变量。这些变量不同于它们的普通对应物，因为访问某个变量（通过其 get 或set 方法）的每个线程都有自己的局部变量，它独立于变量的初始化副本。

     ThreadLocal 实例通常是类中的 private static 字段，它们希望将状态与某一个线程（例如，用户 ID 或事务 ID）相关联，即在同一个线程，可以共享该资源。

        采用ThreadLocal维护Connection实例

package com.hanyi.drp.util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/**
 * 采用ThreadLocal维护Connection
 * @author hanyi
 *
 */
public class ConnectionManage {
	//用于保存connection
	private static ThreadLocal<Connection> connectionHolder=new ThreadLocal<Connection>();

	/**
	 * 获取连接
	 * @return
	 */
	public static Connection GetConnection()
	{
		Connection conn=connectionHolder.get();
		
		
		if(conn==null)
		{
			try {
				JdbcConfig jdbcConfig=XmlConfigReader.GetInstance().getJdbcConfig();
				Class.forName(jdbcConfig.getDriverName());
				conn=DriverManager.getConnection(jdbcConfig.getUrl(),jdbcConfig.getUserName(),jdbcConfig.getPassword());
			} catch (ClassNotFoundException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			connectionHolder.set(conn);
		}
		
		return conn;
	}

	
    //关闭连接
	public static void closeConnection() {
		Connection conn = connectionHolder.get();
		if (conn != null) {
			try {
				conn.close();
				//从ThreadLocal中清除Connection
				connectionHolder.remove();
			} catch (SQLException e) {
				e.printStackTrace();
			}	
		}
	}
	
	//关闭Statement（用于执行静态 SQL 语句并返回它所生成结果的对象。）
	public static void close(Statement pstmt) {
		if (pstmt != null) {
			try {
				pstmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
	
	//关闭结果集
	public static void close(ResultSet rs ) {
		if (rs != null) {
			try {
				rs.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
	
	//开启事务
	public static void beginTransaction(Connection conn) {
		try {
			if (conn != null) {
				if (conn.getAutoCommit()) {
					conn.setAutoCommit(false); //手动提交
				}
			}
		}catch(SQLException e) {}
	}
	
	
	//提交事务
	public static void commitTransaction(Connection conn) {
		try {
			if (conn != null) {
				if (!conn.getAutoCommit()) {
					conn.commit();
				}
			}
		}catch(SQLException e) {}
	}
	
	//回滚事务
	public static void rollbackTransaction(Connection conn) {
		try {
			if (conn != null) {
				if (!conn.getAutoCommit()) {
					conn.rollback();
				}
			}
		}catch(SQLException e) {}
	}
}

采用ThreadLocal维护Connection

原文：http://blog.csdn.net/hy6688_/article/details/38944297