jdbcfactorymanager.java~

电信计费项目 该系统在Sun Solaris下开发,运行于Apache Tomcat平台,采用J2EE架构

package com.tarena.util;

import java.sql.Connection;
//import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;

public class JDBCFactoryManager{
	
	private static ThreadLocal<Connection> local = new ThreadLocal<Connection>();
	
//	static {
//		try {
//			String driver = "oracle.jdbc.driver.OracleDriver";
//			Class.forName(driver);
//		} catch (ClassNotFoundException e) {
//			e.printStackTrace();
//		}
//	}
//
//	public synchronized static Connection getConnection() {
//		String url = "jdbc:oracle:thin:@192.168.0.23:1521:tarena";
//		String name = "openlab";
//		String pwd = "open123";
//		Connection con = null;
//		try {
//			con = local.get();
//			if (con == null) {
//				con = DriverManager.getConnection(url, name,
//						pwd);
//				local.set(con);
//			}
//		} catch (SQLException e) {
//			e.printStackTrace();
//		}
//		return con;
//	}
//
	public synchronized static Connection getConnection(){
		Connection con = null;
		con=local.get();
		try {
			if(con==null){
				Context context = new InitialContext();
				DataSource ds = (DataSource)context.lookup("java:comp/env/jdbc/apache");
				if(ds!=null){
					con=ds.getConnection();
					local.set(con);
				}
			}
		} catch (NamingException e) {
			e.printStackTrace();
		} catch (SQLException e){
			e.printStackTrace();
		}
		return con;
	}
	
	public synchronized static void release(Object obj) {
		try {
			if (obj instanceof ResultSet) {
				((ResultSet) obj).close();
			} else if (obj instanceof Statement) {
				((Statement) obj).close();
			} else if (obj instanceof Connection) {
				((Connection) obj).close();
				local.set(null);
			}
		} catch (SQLException se) {
			se.printStackTrace();
		}
	}
	
	public static void release(ResultSet rs,Statement stmt,Connection con){
		if(rs!=null){
			try {
				rs.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		if(stmt!=null){
			try {
				stmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		if(con!=null){
			try {
				con.close();
				local.set(null);
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
}