package llm.pool.relation;

import java.sql.Connection;

import javax.sql.DataSource;

//import org.apache.log4j.Logger;

/**
 * 自建連接池處理
 * @author 李良敏
 *
 */
public class DBConnectCommon implements DBConnect {
	
//	private static Logger log = Logger.getLogger(DBConnectCommon.class.getName());
	
	// private Connection connection;
	
	private static final ThreadLocal<Connection> connectionThreadLocal = new ThreadLocal<Connection>();
	
	private CommonPool commonPool;
	
	private DBConnectPara dbConnectPara;

	public DBConnectCommon() {
	}
	
	public void initialize( DBConnectPara dBConnectPara ) throws LlmDBException {
		this.dbConnectPara = dBConnectPara;
		commonPool = new CommonPoolDefault();
        commonPool.init( dbConnectPara );        
        // 連接初始化
        commonPool.initConnection();		
	}
	
	public DBConnectPara getDbConnectPara() {
		return dbConnectPara;
	}
	
	public Connection getConnection() throws LlmDBException {		
		Connection connection = commonPool.getConnection();
		connectionThreadLocal.set( connection );
		return connection;	
	}
	
	public void freeConnection() {
        if ( commonPool != null ) {
        	Connection connection = ( Connection ) connectionThreadLocal.get();
        	connectionThreadLocal.set(null);
        	if( connection != null )
        		commonPool.freeConnection( connection );
        } 
	}
	
	public void release() {
		commonPool.release();		
	}

	public DataSource getDataSource() {
		return null;
	}

}