java 数据库操作类详解编程语言

import java.sql.Connection; 
import java.sql.DriverManager; 
import java.sql.ResultSet; 
import java.sql.SQLException; 
import java.sql.Statement; 
import java.util.Properties; 
import javax.naming.Context; 
import javax.naming.InitialContext; 
import javax.naming.NamingException; 
import javax.sql.DataSource; 
import org.apache.log4j.Logger; 
public class DBConnection { 
    /** 
     * @param path 
     * @return Connection 
     * wgy 
     */ 
    public static Connection getConn(String classDriver, String url, 
            String user, String pwd) { 
        try { 
            Class.forName(classDriver); 
            return DriverManager.getConnection(url, user, pwd); 
        } catch (ClassNotFoundException ex) { 
            ex.printStackTrace(); 
        } catch (SQLException ex) { 
            ex.printStackTrace(); 
        } 
        return null; 
    } 
    public static Connection getConn(DataSource dataSource) { 
        try { 
            return dataSource.getConnection(); 
        } catch (SQLException ex) { 
            ex.printStackTrace(); 
        } 
        return null; 
    } 
    public static Connection getConn(String jndiName) { 
        try { 
            Context ctx; 
            ctx = new InitialContext(); 
            DataSource dataSource = (DataSource) ctx.lookup("java:comp/env/" 
                    + jndiName); 
            return dataSource.getConnection(); 
        } catch (NamingException ex) { 
            ex.printStackTrace(); 
        } catch (SQLException ex) { 
            ex.printStackTrace(); 
        } 
        return null; 
    } 
    public static Connection getConn(Properties properties) { 
        try { 
            String driver = properties.getProperty("jdbc.driverClassName"); 
            String url = properties.getProperty("jdbc.url"); 
            String user = properties.getProperty("jdbc.username"); 
            String password = properties.getProperty("jdbc.password"); 
            Class.forName(driver); 
            return DriverManager.getConnection(url, user, password); 
        } catch (ClassNotFoundException ex) { 
            ex.printStackTrace(); 
        } catch (SQLException ex) { 
            ex.printStackTrace(); 
        } 
        return null; 
    } 
    /** 
     * oracle 
     * 
     * @param path 
     * @return Connection 
     */ 
    public static Connection getOracleConn(String url, String user, String pwd) { 
        try { 
            Class.forName("oracle.jdbc.driver.OracleDriver"); 
            return DriverManager.getConnection(url, user, pwd); 
        } catch (ClassNotFoundException ex) { 
            ex.printStackTrace(); 
        } catch (SQLException ex) { 
            ex.printStackTrace(); 
        } 
        return null; 
    } 
    /** 
     * mysql 
     * 
     * @param path 
     * @return Connection 
     */ 
    public static Connection getMysqlConn(String url, String user, String pwd) { 
        try { 
            Class.forName("com.mysql.jdbc.Driver"); 
            return DriverManager.getConnection(url, user, pwd); 
        } catch (ClassNotFoundException ex) { 
            ex.printStackTrace(); 
        } catch (SQLException ex) { 
            ex.printStackTrace(); 
        } 
        return null; 
    } 
    /** 
     * Access���� 
     * 
     * @param path 
     * @return Connection 
     */ 
    public static Connection getAccessConn(String path) { 
        try { 
            Class.forName("sun.jdbc.odbc.JdbcOdbcDriver"); 
            String url = "jdbc:odbc:Driver={MicroSoft Access Driver (*.mdb)};DBQ=" 
                    + path; 
            return DriverManager.getConnection(url, "", ""); 
        } catch (ClassNotFoundException ex) { 
            ex.printStackTrace(); 
        } catch (SQLException ex) { 
            ex.printStackTrace(); 
        } 
        return null; 
    } 
    public static void close(Object... objects) { 
        try { 
            for (Object object : objects) { 
                if (object != null) { 
                        
                    if (object instanceof ResultSet) { 
                        ResultSet rs = (ResultSet) object; 
                        rs.close(); 
                        log.info("ResultSet close"); 
                    } else if (object instanceof Statement) { 
                        Statement stmt = (Statement) object; 
                        stmt.close(); 
                        log.info("Statement close"); 
                    } else if (object instanceof Connection) { 
                        Connection conn = (Connection) object; 
                        conn.close(); 
                        log.info("Connection close"); 
                    } 
                } 
            } 
        } catch (SQLException e) { 
            e.printStackTrace(); 
        } 
    } 
        
    private static Logger log = Logger.getRootLogger(); 
}