jdbc数据库连接管理封装工具类，不同使用属性文件配置数据库连接信息

 

package com.yanek.base.database;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import org.apache.log4j.Logger;

 

 

public class ConnectionManager {

 static Logger logger = Logger.getLogger(ConnectionManager.class.getName());

 public static void main(String[] args) {
  
  try {
   System.out.println("conn=" + ConnectionManager.getConnection());
  } catch (Exception e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
  

 }

 private static String poolName = null;

 private static boolean thirdConnectionPoolEnabled = false;

 private static Object providerLock = new Object();

 public ConnectionManager() {
 }

 /**
  * 从指定连接池获取数据库连接
  *
  * @param poolName
  *            连接池名称
  * @return
  * @throws SQLException
  */
 public static Connection getConnection(final String poolName)
   throws SQLException {
  try {
   return DriverManager.getConnection(poolName);
  } catch (Exception e) {
   logger.error(e);
   return null;
  }
 }

 public static Connection getConnection() throws SQLException {
  
  
  Connection conn = null;
  try {
   /*
    * //start 连接池 context = new InitialContext(); InitialContext
    * context = new InitialContext(); ds =
    * (DataSource)context.lookup("jdbc/OracleDS"); conn =
    * ds.getConnection(); //end 连接池
    */

   /*
    * //这是odbc方式连接方式 String driver="sun.jdbc.odbc.JdbcOdbcDriver";
    * String url="jdbc:odbc:newjchtdb"; String username="sa"; String
    * password="";
    *
    */

   // 这里通过配置文件实现数据库连接参数的设置
   String url = (String) ConfigUtil.getConfigInfo().get("url");
   // System.out.println("url100="+url);
   String driver = (String) ConfigUtil.getConfigInfo().get("driver");
   // System.out.println("driver="+driver);
   String username = (String) ConfigUtil.getConfigInfo().get("user");
   // System.out.println("user="+username);
   String password = (String) ConfigUtil.getConfigInfo().get(
     "password");
   // System.out.println("password="+password);

   Class.forName(driver);
   conn = DriverManager.getConnection(url, username, password);
   
   //conn = getConnectionFromPool();

  } catch (SQLException se) {
   // throw new ServletException(se);
  }

  catch (Exception e) {
   e.printStackTrace();
   conn = null;

  }
  return conn;  
  

 }

 public static void closeConnection(Statement stmt, Connection con) {
  try {
   if (stmt != null)
    stmt.close();
  } catch (Exception e) {
   logger.error(e);
  }
  closeConnection(con);
 }

 public static void closeConnection(PreparedStatement pstmt, Connection con) {
  try {
   if (pstmt != null)
    pstmt.close();
  } catch (Exception e) {
   logger.error(e);
  }
  closeConnection(con);
 }

 public static void closeConnection(CallableStatement cstmt, Connection con) {
  try {
   if (cstmt != null)
    cstmt.close();
  } catch (Exception e) {
   logger.error(e);
  }
  closeConnection(con);
 }

 public static void close(CallableStatement cstmt, Connection con) {
  try {
   if (cstmt != null)
    cstmt.close();
  } catch (Exception e) {
   logger.error(e);
  }
  closeConnection(con);
 }

 public static void closeConnection(ResultSet rs, PreparedStatement pstmt,
   Connection con) {
  closeResultSet(rs);
  closePreparedStatement(pstmt);
  closeConnection(con);
 }

 public static void closeConnection(ResultSet rs, PreparedStatement pstmt) {
  closeResultSet(rs);
  closePreparedStatement(pstmt);
 }

 public static void close(ResultSet rs, PreparedStatement pstmt) {
  closeResultSet(rs);
  closePreparedStatement(pstmt);
 }

 public static void close(ResultSet rs, PreparedStatement pstmt,
   Connection con) {
  closeResultSet(rs);
  closePreparedStatement(pstmt);
  closeConnection(con);
 }

 public static void closeConnection(Connection con) {
  try {
   if (con != null)
    con.close();
  } catch (Exception e) {
   logger.error(e);
  }
 }

 public static void close(Connection con) {
  try {
   if (con != null)
    con.close();
  } catch (Exception e) {
   logger.error(e);
  }
 }

 public static void closePreparedStatement(PreparedStatement pstmt) {
  try {
   if (pstmt != null)
    pstmt.close();
  } catch (Exception e) {
   logger.error(e);
  }
 }

 public static void close(PreparedStatement pstmt) {
  try {
   if (pstmt != null)
    pstmt.close();
  } catch (Exception e) {
   logger.error(e);
  }
 }

 public static void closeResultSet(ResultSet rs) {
  try {
   if (rs != null)
    rs.close();
  } catch (SQLException e) {
   logger.error(e);
  }
  rs = null;
 }

 public static void close(ResultSet rs) {
  try {
   if (rs != null)
    rs.close();
  } catch (SQLException e) {
   logger.error(e);
  }
  rs = null;
 }

 public static Connection getTransactionConnection() throws SQLException {
  Connection con = getConnection();
  con.setAutoCommit(false);
  return con;
 }
 
    /**
     * 通过连接池获取事务连接
     * @param poolName String
     * @return Connection
     * @throws SQLException
     */
    public static Connection getTransactionConnection(final String poolName)
    throws SQLException
    {
        Connection con = getConnection(poolName);
        con.setAutoCommit(false);
        return con;
    } 

    public static void closeTransactionConnection(PreparedStatement pstmt, Connection con, boolean abortTransaction)
    {
        try
        {
            if(pstmt != null)
                pstmt.close();
        }
        catch(Exception e)
        {
            logger.error(e);
        }
        closeTransactionConnection(con, abortTransaction);
    }
   
    public static void closeTransactionConnection(ResultSet rs,PreparedStatement pstmt, Connection con, boolean abortTransaction)
    {
     closeResultSet(rs);
     closePreparedStatement(pstmt);
        closeTransactionConnection(con, abortTransaction);
    }

    public static void closeTransactionConnection(Connection con, boolean abortTransaction)
    {
        if(con == null)
            return;

            try
            {
                if(abortTransaction)
                    con.rollback();
                else
                    con.commit();
            }
            catch(Exception e)
            {
                logger.error(e);
            }
        try
        {
            con.setAutoCommit(true);
        }
        catch(Exception e)
        {
            logger.error(e);
        }
        try
        {
            con.close();
        }
        catch(Exception e)
        {
            logger.error(e);
        }
    }
   
   
   
}