MySql教程

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 )的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!