连接池快速入门

• 目录

  数据库连接的背景

  数据库连接池

  DataSource

  自定义数据库连接池

  演示

  测试

  ---

• 数据库连接的背景

• 数据库连接是一种关键的、有限的、昂贵的资源
• 这一点在多用户的网页应用程序中体现得尤为突出
• 对数据库连接的管理能显著影响到整个应用程序的性能指标，数据库连接池正是针对这个问题提出来的
• 如：在用户访问网站时不断创建连接不断销毁连接，那么这个效率就不是很高

• 数据库连接池

• 数据库连接池负责分配，管理和释放数据库连接
• 它允许应用程序重复使用一个现有的数据库连接，而不是再重新建立一个
• 这项技术能明显提高对数据库操作的性能
• 简要过程：
• 就是提前准备一个容器，这个容器就是数据库的连接池，在容器中，提前准备好了一些数据库连接
• 这时来了请求后，就从连接池中拿一个连接对象进行使用
• 使用完成以后不关掉，而是归还到连接池当中，达到重复使用的效果
• 所谓的池，就是搞一个容器，这个容器里边保存的就是很多个数据库连接对象

• DataSource

• DataSource接口概述
• javax.sql.DataSourse接口:数据源(数据库连接池)
• Java官方提供的数据库连接池规范(接口)
• 如果想完成数据库连接池技术，就必须实现DataSource接口
• 核心功能：
• 获取数据库连接对象：
• Connection getConnection();

• 自定义数据库连接池

• 1.定义一个类，实现DataSource接口
• 2.定义一个容器，用于保存多个Connection连接对象
• 3.定义静态代码块，通过JDBC工具类获取10个连接保存到容器中
• 4.重写getConnection方法，从容器中获取一个连接并返回
• 5.定义getSize方法，用于获取容器的大小并返回

• 演示

• 

• package demo02.myDataSourse;
  import demo02.utils.JDBCUtils;
  
  import javax.sql.DataSource;
  import java.io.PrintWriter;
  import java.sql.Connection;
  import java.sql.SQLException;
  import java.sql.SQLFeatureNotSupportedException;
  import java.util.ArrayList;
  import java.util.Collections;
  import java.util.List;
  import java.util.logging.Logger;
  
  //自定义数据库连接池
  public class demoDataSourse implements DataSource{
      //1.准备容器，用于保存多个连接对象
      private static List<Connection> pool = Collections.synchronizedList(new ArrayList<>());
      //2.定义静态代码块，通过工具类获取10个连接对象
      static{
          for(int i=1;i<=10;i++){
              Connection con = JDBCUtils.getConnection();
              pool.add(con);
          }
      }
      //3.重写getConnection(),用于获取一个连接对象
      @Override
      public Connection getConnection() throws SQLException {
          if(pool.size()>0){
              Connection con = pool.remove(0);
              return con;
          }else{
              throw new RuntimeException("连接数量已用尽");
          }
      }
      //4.定义getSize方法，获取连接池容器的大小
      public int getSize(){
          return pool.size();
      }
      @Override
      public Connection getConnection(String username, String password) throws SQLException {
          return null;
      }
  
      @Override
      public <T> T unwrap(Class<T> iface) throws SQLException {
          return null;
      }
  
      @Override
      public boolean isWrapperFor(Class<?> iface) throws SQLException {
          return false;
      }
  
      @Override
      public PrintWriter getLogWriter() throws SQLException {
          return null;
      }
  
      @Override
      public void setLogWriter(PrintWriter out) throws SQLException {
  
      }
  
      @Override
      public void setLoginTimeout(int seconds) throws SQLException {
  
      }
  
      @Override
      public int getLoginTimeout() throws SQLException {
          return 0;
      }
  
      @Override
      public Logger getParentLogger() throws SQLFeatureNotSupportedException {
          return null;
      }
  }

• 测试

• 此处测试未对连接对象进行归还，而是直接关闭
• 演示中有影响结果，后面再介绍如何归还
• 
• 

• package demo02.myDataSourse;
  
  import java.sql.Connection;
  import java.sql.PreparedStatement;
  import java.sql.ResultSet;
  
  public class demoDataSourseTest {
      public static void main(String[] args) throws Exception {
          //1.创建连接池对象
          demoDataSourse dataSourse = new demoDataSourse();
  
          System.out.println("使用之前的数量" + dataSourse.getSize());
  
          //2.通过连接池对象获取连接对象
          Connection con = dataSourse.getConnection();
          //3.查询学生表的全部信息
          String sql = "SELECT * FROM student";
          PreparedStatement pst = con.prepareStatement(sql);
          //4.执行sql语句,接收结果集
          ResultSet rs = pst.executeQuery();
          //5.处理结果集
          while(rs.next()){
              System.out.println(rs.getInt("sid")+"\t"+rs.getString("name")+"\t"+rs.getInt("age")+"\t"+rs.getDate("birthday"));
          }
          //6.释放资源
          rs.close();
          pst.close();
          con.close();//用完以后，未归还进行关闭连接；归还后面再讲
  
          System.out.println("使用之后的数量" + dataSourse.getSize());
      }
  }