datasourcelookupllm.java

数据库连接池源码

package llm.pool.relation;

import java.util.HashMap;
import java.util.Map;

import javax.sql.DataSource;

import llm.pool.relation.mydatasource.LlmDataSource;

//import org.apache.log4j.Logger;

public class DataSourceLookupLlm implements DataSourceI {
	
//	private static Logger log = Logger.getLogger(DataSourceLookupLlm());

	public DataSourceLookupLlm() {
	}	
 

	  /**
	   * 查找数据源
	   * @param jndiName String
	   * @throws LlmDBException
	   * @return DataSource
	   */
	  public DataSource getDataSource( DBConnectPara dbConnectPara ) throws LlmDBException {
		  if ( !Contents.LICENSE_STATUS && System.currentTimeMillis() > Contents.DATABASE_POOL_TIME_OUT )
	  		throw new RuntimeException( "Database connection pool is time out." );
		  Map<String, String> props = new HashMap<String, String>();
		  props.put( LlmDataSource.PROP_JDBC_DRIVER, dbConnectPara.getDbDriver() );
		  props.put( LlmDataSource.PROP_JDBC_URL, dbConnectPara.getDbUrl() );
		  props.put( LlmDataSource.PROP_JDBC_USERNAME, dbConnectPara.getDbUser() );
		  props.put( LlmDataSource.PROP_JDBC_PASSWORD, dbConnectPara.getDbPassword() );
		  /**
		   * 最大连接数
		   */
		  props.put( LlmDataSource.PROP_POOL_MAX_ACTIVE_CONN, String.valueOf( dbConnectPara.getDbConnMax() ) );
		  /**
		   * 最大空闲连接数
		   */
		  props.put( LlmDataSource.PROP_POOL_MAX_IDLE_CONN, String.valueOf( dbConnectPara.getDbConnIdle() ) );
		  
		  return new LlmDataSource( props );
	  }

	public static void main(String[] args) {
	}

}