Go语言视频零基础入门到精通

javalearner

dbcp使用
--------------------
dbcp提供了数据库连接池；
可以在spring，iBatis，hibernate中调用dbcp完成数据库连接，框架一般都提供了dbcp连接的方法；
tomcat中也提供了dbcp的jndi设置方法； 也可以不在框架中使用dbcp，单独使用dbcp需要3个包：common-dbcp.jar,common-pool.jar,common-collections.jar 下面是个dbcp的实用类，通过它可以完成DBCP的使用： package dbcp;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.HashMap;
import java.util.Map;
import javax.sql.DataSource;
import org.apache.commons.dbcp.BasicDataSource;
/**
* @author space
* @date Aug 12, 2008 3:25:49 PM
*
* dbcp 实用类，提供了dbcp连接，不允许继承；
*
* 该类需要有个地方来初始化 DS ，通过调用initDS 方法来完成，可以在通过调用带参数的构造函数完成调用，
* 可以在其它类中调用，也可以在本类中加一个static{}来完成；
*/
public final class DbcpBean {
        /** 数据源，static */
        private static DataSource DS;
        /** 从数据源获得一个连接 */
        public Connection getConn() {
                Connection con = null;
                if (Ds!= null) {
                        try {
                                con = Ds.getConnection();
                        } catch (Exception e) {
                                e.printStackTrace(System.err);
                        }
                       
                        try {
                                con.setAutoCommit(false);
                        } catch (SQLException e) {
                                e.printStackTrace();
                        }
                        return con;
                }
                return con;
        }
        /** 默认的构造函数 */
        public DbcpBean() {
        }
        /** 构造函数，初始化了 DS ，指定 数据库 */
        public DbcpBean(String connectURI) {
                initDS(connectURI);
        }
        /** 构造函数，初始化了 DS ，指定 所有参数 */
        public DbcpBean(String connectURI, String username, String pswd, String driverClass, int initialSize,
                        int maxActive, int maxIdle, int maxWait) {
                initDS(connectURI, username, pswd, driverClass, initialSize, maxActive, maxIdle, maxWait);
        }
        /**
         * 创建数据源，除了数据库外，都使用硬编码默认参数；
         *
         * @param connectURI 数据库
         * @return
         */
        public static void initDS(String connectURI) {
                initDS(connectURI, "root", "password", "com.mysql.jdbc.Driver", 5, 100, 30, 10000);
        }
        /**
         * 指定所有参数连接数据源
         *
         * @param connectURI 数据库
         * @param username 用户名
         * @param pswd 密码
         * @param driverClass 数据库连接驱动名
         * @param initialSize 初始连接池连接个数
         * @param maxActive 最大激活连接数
         * @param maxIdle 最大闲置连接数
         * @param maxWait 获得连接的最大等待毫秒数
         * @return
         */
        public static void initDS(String connectURI, String username, String pswd, String driverClass, int initialSize,
                        int maxActive, int maxIdle, int maxWait) {
                BasicDataSource ds = new BasicDataSource();
                ds.setDriverClassName(driverClass);
                ds.setUsername(username);
                ds.setPassword(pswd);
                ds.setUrl(connectURI);
                ds.setInitialSize(initialSize); // 初始的连接数；
                ds.setMaxActive(maxActive);
                ds.setMaxIdle(maxIdle);
                ds.setMaxWait(maxWait);
                DS = ds;
        }
        /** 获得数据源连接状态 */
        public static Map<String, Integer> getDataSourceStats() throws SQLException {
                BasicDataSource bds = (BasicDataSource) DS;
                Map<String, Integer> map = new HashMap<String, Integer>(2);
                map.put("active_number", bds.getNumActive());
                map.put("idle_number", bds.getNumIdle());
                return map;
        }
        /** 关闭数据源 */
        protected static void shutdownDataSource() throws SQLException {
                BasicDataSource bds = (BasicDataSource) DS;
                bds.close();
        }
        public static void main(String[] args) {
                DbcpBean db = new DbcpBean("jdbc:mysql://localhost:3306/testit");
                Connection conn = null;
                Statement stmt = null;
                ResultSet rs = null;
                try {
                        conn = db.getConn();
                        stmt = conn.createStatement();
                        rs = stmt.executeQuery("select * from test limit 1 ");
                        System.out.println("Results:");
                        int numcols = rs.getMetaData().getColumnCount();
                        while (rs.next()) {
                                for (int i = 1; i <= numcols; i++) {
                                        System.out.print("        " + rs.getString(i) + "        ");
                                }
                                System.out.println("");
                        }
                        System.out.println(getDataSourceStats());
                } catch (SQLException e) {
                        e.printStackTrace();
                } finally {
                        try {
                                if (rs != null)
                                        rs.close();
                                if (stmt != null)
                                        stmt.close();
                                if (conn != null)
                                        conn.close();
                                if (db != null)
                                        shutdownDataSource();
                        } catch (Exception e) {
                                e.printStackTrace();
                        }
                }
        }
}[/code]