MySQL连接池 Java使用MySQL实现连接池代码实例

软件发布|下载排行|最新软件

当前位置:首页IT学院IT技术

MySQL连接池 Java使用MySQL实现连接池代码实例

shouyaya   2021-04-21 我要评论

官方:数据库连接池(Connection pooling)是程序启动时建立足够的数据库连接,并将这些连接组成一个连接池,由程序动态地对连接池中的连接进行申请,使用,释放。

理解:创建数据库连接池是一个很耗时的操作,也容易对数据库造成安全隐患。所以,在程序初始化的时候,集中创建多个数据库连接池,并把他们集中管理,供程序使用,可以保证较快的数据库读写速度,还更加的安全可靠。

手动配置连接池:

/**
   * 手动设置连接池
   */
  public void demo1(){

    // 获得连接:
    Connection conn = null;
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    try{
      // 创建连接池:
      ComboPooledDataSource dataSource = new ComboPooledDataSource();
      // 设置连接池的参数:
      dataSource.setDriverClass("com.mysql.jdbc.Driver");
      dataSource.setJdbcUrl("jdbc:mysql:///jdbctest");
      dataSource.setUser("root");
      dataSource.setPassword("abc");
      dataSource.setMaxPoolSize(20);
      dataSource.setInitialPoolSize(3);
      
      // 获得连接:
      conn = dataSource.getConnection();
      // 编写Sql:
      String sql = "select * from user";
      // 预编译SQL:
      pstmt = conn.prepareStatement(sql);
      // 设置参数
      // 执行SQL:
      rs = pstmt.executeQuery();
      while(rs.next()){
        System.out.println(rs.getInt("uid")+"  "+rs.getString("username")+"  "+rs.getString("password")+"  "+rs.getString("name"));
      }
    }catch(Exception e){
      e.printStackTrace();
    }finally{
      JDBCUtils.release(rs, pstmt, conn);
    }
  }

使用配置文件配置连接池:

配置文件xml如下:

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>

 <default-config>
  <property name="driverClass">com.mysql.jdbc.Driver</property>
  <property name="jdbcUrl">jdbc:mysql:///jdbctest</property>
  <property name="user">root</property>
  <property name="password">abc</property>
  <property name="initialPoolSize">5</property>
  <property name="maxPoolSize">20</property>
 </default-config>
 
</c3p0-config>

代码如下:

/**
   * 使用配置文件的方式
   */
  public void demo2(){
    Connection conn = null;
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    try{
      /*// 获得连接:
      ComboPooledDataSource dataSource = new ComboPooledDataSource();*/
      // 获得连接:
      // conn = dataSource.getConnection();
      conn = JDBCUtils2.getConnection();
      // 编写Sql:
      String sql = "select * from user";
      // 预编译SQL:
      pstmt = conn.prepareStatement(sql);
      // 设置参数
      // 执行SQL:
      rs = pstmt.executeQuery();
      while(rs.next()){
        System.out.println(rs.getInt("uid")+"  "+rs.getString("username")+"  "+rs.getString("password")+"  "+rs.getString("name"));
      }
    }catch(Exception e){
      e.printStackTrace();
    }finally{
      JDBCUtils2.release(rs, pstmt, conn);
    }
  }

Copyright 2022 版权所有 软件发布 访问手机版

声明:所有软件和文章来自软件开发商或者作者 如有异议 请与本站联系 联系我们