dsconnectionmanager.java

采用JAVA开发

package com.gctech.sms.util;

import java.sql.Connection;
import javax.naming.Context;
import java.util.Hashtable;
import javax.naming.InitialContext;
import org.apache.log4j.Logger;
import java.sql.SQLException;
import java.util.Properties;
import java.io.InputStream;
import java.io.FileInputStream;
import java.io.*;
import com.gctech.sms.SmsException;

/**
 * <p>Title: 数据源连接管理器。</p>
 * <p>Description: 数据源连接管理器，负责基于DataSource的连接管理。</p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author not attributable
 * @version $Id: DSConnectionManager.java,v 1.1 2004/05/09 05:07:36 wanghb Exp $
 */

public class DSConnectionManager extends ConnectionManager{
  static final Logger logger = Logger.getLogger(DSConnectionManager.class);
  public DSConnectionManager() {
  }

  public String getPoolInfo() {
    return "";
  }
  javax.sql.DataSource ds;
  public void init(String fileName) throws SmsException {
    Context ctx = null;
    Properties props = new Properties();
    try {
      InputStream in = new FileInputStream(fileName);
      props.load(in);
      Hashtable ht = new Hashtable();
      ht.put(Context.INITIAL_CONTEXT_FACTORY, props.getProperty("INITIAL_CONTEXT_FACTORY"));
      ht.put(Context.PROVIDER_URL,  props.getProperty("PROVIDER_URL"));
      ctx = new InitialContext(ht);
      ds = (javax.sql.DataSource) ctx.lookup(props.getProperty("DATASOURCE"));
    }
    catch (Exception ex1) {
      logger.error(ex1);
      throw new SmsException(ex1);
    }
  }

  public Connection getConnection(Object o) {
    try {
      return ds.getConnection();
    }
    catch (SQLException ex) {
      logger.error(ex);
      return null;
    }
  }

  public Connection getRealConnection() {
    try {
      return ds.getConnection();
    }
    catch (SQLException ex) {
      logger.error(ex);
      return null;
    }
  }

  public void close() {
  }
}