connpoolmgr.java

本人编写的数据库连接池的基本应用

package dbaccess.common;

/**
 * @author 			阙韧杰
 * @Title:			ConnPoolMgr
 * @Description: 	连接池的管理类
 * @Copyright:(c) 	2006-04-10
 * @Company: 		TIREN
 * @version 		1.0
 * @modify by 
 */
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;

public class ConnPoolMgr {
	private String jndiName = "";

	private Connection conn = null;

	private ConnPoolMgr(String strparamJndiName) {
		this.jndiName = strparamJndiName;
	}

	private static ConnPoolMgr instance1 = new ConnPoolMgr("jdbc/myOracle");

	private static ConnPoolMgr instance2 = new ConnPoolMgr("jdbc/myOracle_test");

	public static synchronized ConnPoolMgr getInstance(int intParam) {
		switch (intParam) {
		case 0:
			return instance1;
		case 1:
			return instance2;
		default:
			return instance1;
		}
	}

	/**
	 * @return: 返回数据库连接
	 */
	public Connection getConnection() {
		try {
			Context initCtx = new InitialContext();
			if (initCtx == null)
				throw new Exception("没有匹配的环境");
			Context ctx = (Context) initCtx.lookup("java:comp/env");
			Object obj = (Object) ctx.lookup(jndiName);
			DataSource ds = (DataSource) obj;
			if (ds == null)
				throw new Exception("没有匹配数据库");
			conn = ds.getConnection();
		} catch (Exception ex) {
			ex.printStackTrace();
			System.out.println("无法获取数据库连接!");
		}
		return conn;
	}

	/**
	 * @description 	关闭资源
	 * @param 			rs
	 * @param 			stmt
	 * @param 			conn
	 */
	public void close(ResultSet rs, Statement stmt, Connection conn) {
		try {
			rs.close();
			stmt.close();
			conn.close();
		} catch (Exception ex) {
			ex.printStackTrace();
			System.out.println("关闭连接资源失败！");
		}
	}
	
	/**
	 * @param 			stmt
	 * @param 			conn
	 * @description 	关闭资源
	 */
	public void close(Statement stmt, Connection conn) {
		try {
			stmt.close();
			conn.close();
		} catch (Exception ex) {
			ex.printStackTrace();
			System.out.println("关闭连接资源失败！");
		}
	}
}