package cn.com.iaspec.workflow.db;

import java.sql.*;
import javax.naming.*;
import javax.sql.*;
import org.apache.log4j.*;

/**
 *
 * <p>Title:業(yè)務(wù)數(shù)據(jù)庫連接池管理</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: IASPEC Technologies</p>
 * @author xiesonglin
 * @version 1.0
 */

public class BusinessDBConnectionManager
    extends DBConnectionManager{
  private static BusinessDBConnectionManager instance=null;
  private DBConnectionPool pool;

  //數(shù)據(jù)庫類型

  private static String DATASOURCE_JNDI_NAME="java:/OracleDS";
  private DataSource dataSource=null;
  private static Logger logger=Logger.getLogger(BusinessDBConnectionManager.class);

  /**
   * Use singleton pattern, only return one instance of DBConnectionManager.
   * @return DBConnectionManager
   */
  public static BusinessDBConnectionManager getInstance(){
    logger.debug("begin getInstance...");
    if(instance==null){
      instance=new BusinessDBConnectionManager();
    }
    return instance;
  }

  /**
   * Get a connection
   * @return Connection
   * @throws SQLException this method
   */
  public synchronized Connection getConnection()
      throws SQLException{
    logger.debug("begin BusinessDBConnectionManager getConnection...");
    Connection conn=null;
    if(this.useJNDIConnection){
      conn=dataSource.getConnection();
    }
    else{
      conn=pool.getConnection();
    }
    this.addConnectCount();
    return conn;
  }

  /**
   * Free a connection
   * @param con connection
   * @throws SQLException this method
   */
  public void freeConnection(Connection con)
      throws SQLException{
    pool.freeConnection(con);
  }

  private BusinessDBConnectionManager(){
    logger.debug("begin BusinessDBConnectionManager...");
    try{
      init();
    }
    catch(Exception ex){
      //ex.printStackTrace();
      logger.info(ex.toString());
    }
  }

  private void init()
      throws DbException{
    ConnectProperties prop=GetConnectionProperty.getBusinessDBProperty();
    String driver="";
    String url="";
    String user="";
    String password="";
    int maxConn=10;
    if(prop!=null){
      driver=prop.getDbDriver();
      url=prop.getDbUrl();
      user=prop.getDbUser();
      password=prop.getDbPassword();
      dataBaseType=prop.getDataBaseType();
      maxConn=10;
      if(prop.getMaxConnect()!=null&&prop.getMaxConnect().length()>0){
        maxConn=Integer.parseInt(prop.getMaxConnect());
      }
      if(prop.getJNDIName()!=null&&prop.getJNDIName().length()>0){
        DATASOURCE_JNDI_NAME=prop.getJNDIName();
      }
      if(prop.getUseJNDI()!=null&&prop.getUseJNDI().equals("false")){
        this.useJNDIConnection=false;
      }
      else{
        this.useJNDIConnection=true;
      }
    }
    if(this.useJNDIConnection){
      try{
        Context ctx=new InitialContext();
        this.dataSource=(DataSource)ctx.lookup(DATASOURCE_JNDI_NAME);
      }
      catch(NamingException ex){
        logger.info("Catch a NamingException: "+ex.toString());
        throw new DbException("can't lookup datasource, jndiname=["+
            this.DATASOURCE_JNDI_NAME+"]");
      }
      catch(Exception ex){
        //ex.printStackTrace();
        logger.info(ex.toString());
        throw new DbException(ex.getMessage());
      }
    }
    else{
      try{
        Class.forName(driver);
        pool=new DBConnectionPool(url,user,password,maxConn);
      }
      catch(ClassNotFoundException ex){
        logger.info(ex.toString());
        //ex.printStackTrace();
      }

    }
  }

}