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;

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 = "csd0802";
		String pwd = "csd0802";
		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();
			}
		}
	}
}