dbconnectdatasource.java

数据库连接池源码

package llm.pool.relation;

import java.sql.Connection;
import java.sql.SQLException;

import javax.sql.DataSource;

import org.apache.log4j.Logger;

public class DBConnectDataSource implements DBConnect {
	
	private static Logger log = Logger.getLogger( DBConnectDataSource.class.getName() );

	private static final ThreadLocal<Connection> connectionThreadLocal = new ThreadLocal<Connection>();

	private DBConnectPara dbConnectPara;
	
	private DataSource dataSource;
	
	public void initialize( DBConnectPara dBConnectPara ) throws LlmDBException {
		this.dbConnectPara = dBConnectPara;
		this.dataSource    = DataSourceFactory.getDataSource( dbConnectPara );
	}

	public DBConnectPara getDbConnectPara() {
		return dbConnectPara;
	}
	
	public DataSource getDataSource() {
		return dataSource;
	}
	
	public void release() {
	}

	public Connection getConnection() throws SQLException, LlmDBException {
		Connection connection = dataSource.getConnection();
		connectionThreadLocal.set( connection );
		return connection;	
	}

	public void freeConnection() {
		Connection connection = ( Connection ) connectionThreadLocal.get();
    	connectionThreadLocal.set(null);
		if ( null != connection )
			try {	
				connection.close();	
			} catch ( Exception e ) {
				log.error( "关闭数据库失败！", e );
			}		
	}
	
}