我们爱分享----事务上下文

     要想进行事务管理，有一个概念必须要清楚，即：必须保证开始事务，和关闭事务是同一个数据库连接。 事务上下文的主要实现，依赖于ThreadLocal，关于该类的作用，不多讲。不清楚的同学可以自己Google查一下。 以面以基于c3po数据源管理为例。


一、封装一个简单的连接池
     

           /**

 * @author <a href="mailto:amoszhou@foxmail.com">大胡子</a>

 * @功能描述：连接池接口

 * @Since Mar 11, 2011

 * 

 */

public interface PooledConnection {

	

	/**

	 * 

	 * @author <a href="mailto:amoszhou@foxmail.com">大胡子</a>

	 * @功能描述：初始化

	 * @Since Mar 11, 2011

	 */

	public  void init();



	/**

	 * 

	 * @author <a href="mailto:amoszhou@foxmail.com">大胡子</a>

	 * @功能描述：关闭连接池

	 * @Since Mar 11, 2011

	 */

	public void destory();



	/**

	 * 

	 * @author <a href="mailto:amoszhou@foxmail.com">大胡子</a>

	 * @功能描述：获取连接

	 * @Since Mar 11, 2011

	 * @return

	 * @throws SQLException

	 */

	public Connection getConnection() throws SQLException;

	

	public void releaseConnection(Connection conn) throws SQLException;

}

 

      

/**

 * @author <a href="mailto:amoszhou@foxmail.com">大胡子</a>

 * @功能描述：基于C3PO连接池的实现类

 * @Since Mar 11, 2011

 *

 */

public class RYTPooledConnection implements PooledConnection {

	

	/**

	 * c3po的数据源

	 */

	private  static ComboPooledDataSource ds;

	

	/**

	 * 关闭数据源

	 */

	public final void destory() {

		ds.close();

	}



	/**

	 * 获取数据库连接

	 */

	public final  Connection getConnection() throws SQLException {

		return ds.getConnection();

	}



	

	

	/**

	 * 初始化

	 */

	public final  void init() {

		if(null == ds){

			ds = new ComboPooledDataSource();

		}

	}



	public void releaseConnection(Connection conn) throws SQLException {

		if(null != conn){

			conn.close();

		}

	}

}

以上代码，就是对c3po就行了一个简单的封装，之所以提供接口，目的相信大家都懂，为了方便扩展，以后若是不用C3PO怎么办？ 很多人会问，你这里没有提供连接池的大小，初始化连接信息之类，那么我告诉你。你只需要在src目录下，提供
c3p0.properties文件，c3po数据源会自动初始化这些信息。

c3p0.driverClass=com.mysql.jdbc.Driver

c3p0.jdbcUrl=jdbc:mysql://127.0.0.1:3306/testdb

c3p0.user=root

c3p0.password=123456

c3p0.initialPoolSize=10

c3p0.minPoolSize=10

c3p0.maxPoolSize=100

    这样，我们第一部分的工作就做完了。


二、我们来对事务对象进行一个抽象。定义一个事务对象：

     

public class Transaction {

	

	/**database connection**/

	private Connection connection;