mysql学习17（ 数据库连接池：DBCP，C3P0 ）

本文主要是介绍mysql学习17（ 数据库连接池：DBCP，C3P0 ），对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

mysql学习17

• 数据库连接池：

  • DBCP连接池；

  • C3P0连接池；

  • Druid连接池；

• 池化技术：

  • 数据库连接--执行完毕 --释放；（从连接---释放：十分浪费资源）

  • 池化技术：准备一些预先的资源，过来就连接预先准备好的；

    • 最小链接数：

    • 最大链接数：100 （业务最高承载上限）

    • 等待超时：100ms

  • 编写连接池，实现一个接口：DataSource

  • 开源数据源实现：

    • DBCP：

    • C3P0：

    • Druid：阿里巴巴

  • 使用了这些数据库连接池之后，我们在项目开发中就不需要编写链接数据库的代码了；

• DBCP：

  • 需要用到2个jar包：

    commons-dbcp2-2.9.0.jar
    commons-pool2-2.11.1.jar
    commons-logging-1.1.jar //需要这个jar包依赖

  • 代码案例：测试类

    ​
    /**
     * 测试DBCP
     */
    public class TestDBCP01 {
        public static void main(String[] args) {
    ​
            Connection conn =null;
            PreparedStatement st=null;
    ​
    ​
            try {
                conn= JdbcUtils_DBCP.getConnection();//获取连接
    ​
                /**
                 * 区别:
                 * 1，使用? 占位符代替参数
                 */
                //"INSERT INTO `users`(`id`,`NAME`,`PASSWORD`,`email`,`birthday`)VALUES('4','demo','123456','demo@sina.com','1980-12-04')";
                String sql="INSERT INTO `users`(`id`,`NAME`,`PASSWORD`,`email`,`birthday`)VALUES(?,?,?,?,?)";
                st=conn.prepareStatement(sql);//预编译SQL，先写SQL，然后不执行
    ​
                //手动给参数赋值
                st.setInt(1,1);
                st.setString(2,"demo");
                st.setString(3,"111111");
                st.setString(4,"demo@sina.com");
                //注意点： sql.Date()：数据库用的
                //        util.Date()：Java用的  new Date().getTime()获得时间戳
                st.setDate(5,new java.sql.Date(new Date().getTime()));
    ​
    ​
                //执行
                int i=st.executeUpdate();
                if(i>0){
                    System.out.println("插入成功");
                }
    ​
            } catch (SQLException e) {
                e.printStackTrace();
            }finally {
                JdbcUtils_DBCP.release(conn,st,null);
            }
    ​
        }
    }
    ​

  • 代码案例：JdbcUtils_DBCP工具类

    ​
    /**
     * JdbcUtils_DBCP工具类
     */
    public class JdbcUtils_DBCP {
    ​
        private static BasicDataSource dataSource =null;
    ​
        static {
            try {
                InputStream in = JdbcUtils_DBCP.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");
                Properties properties = new Properties();
                properties.load(in);
    ​
                //创建数据源 工厂模式：创建对象
                dataSource = BasicDataSourceFactory.createDataSource(properties);
    ​
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    ​
        //获取连接
        public static Connection getConnection() throws SQLException{
            return dataSource.getConnection();//从数据源中获取链接
        }
    ​
    ​
        //释放连接
        public static void release(Connection conn, PreparedStatement state, ResultSet res) {
    ​
           if(res !=null){
               try {
                   res.close();
               } catch (SQLException e) {
                   e.printStackTrace();
               }
           }
    ​
            if(state !=null){
                try {
                    state.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
    ​
            if(conn !=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
    ​
        }
    ​
    ​
    }
    ​

  • 代码案例：

    #连接设置
    driverClassName=com.mysql.jdbc.Driver
    url=jdbc:mysql://localhost:3306/demo?useUnicode=true&characterEncoding=utf8&useSSL=true
    username=demo
    password=demo
    ​
    #<!-- 初始化连接 -->
    initialSize=10
    ​
    #最大连接数量
    maxActive=50
    ​
    #<!-- 最大空闲连接 -->
    maxIdle=20
    ​
    #<!-- 最小空闲连接 -->
    minIdle=5
    ​
    #<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
    maxWait=60000
    #JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：【属性名=property;】
    #注意："user" 与 "password" 两个属性会被明确地传递，因此这里不需要包含他们。
    connectionProperties=useUnicode=true;characterEncoding=UTF8
    ​
    #指定由连接池所创建的连接的自动提交（auto-commit）状态。
    defaultAutoCommit=true
    ​
    #driver default 指定由连接池所创建的连接的只读（read-only）状态。
    #如果没有设置该值，则“setReadOnly”方法将不被调用。（某些驱动并不支持只读模式，如：Informix）
    defaultReadOnly=
    ​
    #driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。
    #可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
    defaultTransactionIsolation=READ_UNCOMMITTED

     

     

• C3P0：

  • 需要jar包

    c3p0-0.9.2.1.jar
    mchange-commons-java-0.2.20.jar

     

  • 代码案例：测试类

    ​
    /**
     * 测试类
     */
    public class C3P0Demo01 {
        public static void main(String[] args) {
    ​
            Connection conn =null;
            PreparedStatement st=null;
    ​
    ​
            try {
                conn= JdbcUtils_C3P0.getConnection();//获取连接
    ​
                /**
                 * 区别:
                 * 1，使用? 占位符代替参数
                 * 2，
                 *
                 *
                 *
                 *
                 */
                //"INSERT INTO `users`(`id`,`NAME`,`PASSWORD`,`email`,`birthday`)VALUES('4','demo','123456','demo@sina.com','1980-12-04')";
                String sql="INSERT INTO `users`(`id`,`NAME`,`PASSWORD`,`email`,`birthday`)VALUES(?,?,?,?,?)";
                st=conn.prepareStatement(sql);//预编译SQL，先写SQL，然后不执行
    ​
                //手动给参数赋值
                st.setInt(1,5);
                st.setString(2,"dd");
                st.setString(3,"111111");
                st.setString(4,"demo@sina.com");
                //注意点： sql.Date()：数据库用的
                //        util.Date()：Java用的  new Date().getTime()获得时间戳
                st.setDate(5,new java.sql.Date(new Date().getTime()));
    ​
    ​
                //执行
                int i=st.executeUpdate();
                if(i>0){
                    System.out.println("插入成功");
                }
    ​
            } catch (SQLException e) {
                e.printStackTrace();
            }finally {
                JdbcUtils_C3P0.release(conn,st,null);
            }
        }
    }
    ​

  • 代码案例：JdbcUtils_C3P0工具类

    ​
    /**
     * JdbcUtils_C3P0工具类
     */
    public class JdbcUtils_C3P0 {
    ​
        private static DataSource dataSource =null;
    ​
        static {
            try {
                //方式1：配置文件写法
                //private static DataSource dataSource =null;
                dataSource= new ComboPooledDataSource();
    ​
                //方式2：代码版配置；不建议使用
                //private static ComboPooledDataSource dataSource =null;
                //dataSource= new ComboPooledDataSource();
    ​
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    ​
        //获取连接
        public static Connection getConnection() throws SQLException{
            return dataSource.getConnection();//从数据源中获取链接
        }
    ​
    ​
        //释放连接
        public static void release(Connection conn, PreparedStatement state, ResultSet res) {
    ​
           if(res !=null){
               try {
                   res.close();
               } catch (SQLException e) {
                   e.printStackTrace();
               }
           }
    ​
            if(state !=null){
                try {
                    state.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
    ​
            if(conn !=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
    ​
        }
    ​
    ​
    }
    ​

  • 代码案例：c3p0配置文件

    <?xml version="1.0" encoding="UTF-8"?>
    <c3p0-config>
        <!--c3p0的缺省（默认）配置如果在代码中"ComboPooledDataSource ds=new ComboPooledDataSource();"这样写就表示使用的是c3p0的缺省（默认）-->
        <default-config>
            <property name="driverClass">com.mysql.cj.jdbc.Driver</property>
            <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&amp;characterEncoding=utf8&amp;useSSL=true&amp;serverTimezone=UTC</property>
            <property name="user">root</property>
            <property name="password">root</property>
    ​
            <property name="acquiredIncrement">5</property>
            <property name="initialPoolSize">10</property>
            <property name="minPoolSize">5</property>
            <property name="maxPoolSize">20</property>
        </default-config>
        </c3p0-config>

     

• Druid：

  • 百度学习；

     

• 笔记：

  • 无论使用什么数据源，本质还是一样的；（DataSource接口不会变，方法就不会变）

这篇关于mysql学习17（ 数据库连接池：DBCP，C3P0 ）的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！