加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 编程开发 > Java > 正文

java 数据库操作类

发布时间:2020-12-14 23:38:23 所属栏目:Java 来源:网络整理
导读:今天PHP站长网 52php.cn把收集自互联网的代码分享给大家,仅供参考。 import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;im

以下代码由PHP站长网 52php.cn收集自互联网

现在PHP站长网小编把它分享给大家,仅供参考

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,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 pwd) {
        try {
            Class.forName("oracle.jdbc.driver.OracleDriver");
            return DriverManager.getConnection(url,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 pwd) {
        try {
            Class.forName("com.mysql.jdbc.Driver");
            return DriverManager.getConnection(url,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();
}

以上内容由PHP站长网【52php.cn】收集整理供大家参考研究

如果以上内容对您有帮助,欢迎收藏、点赞、推荐、分享。

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读