数据库连接池C3P0,DBCP教程详解示例

@Test
public void demo01() throws Exception{
    //1 获得连接池(数据源)
    ComboPooledDataSource dataSource = new ComboPooledDataSource();
    //1.1 设置基本项
    dataSource.setDriverClass("com.mysql.jdbc.Driver");
 dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/webdb_4");
    dataSource.setUser("root");
    dataSource.setPassword("root");
    //1.2其他项
    // * 初始化连接池中连接的个数
    dataSource.setInitialPoolSize(5);
    // * 最小|最大连接池中连接的个数
    dataSource.setMinPoolSize(2);
    dataSource.setMaxPoolSize(10);
    // * 最大空闲数
    dataSource.setMaxIdleTime(60);
    // * 每次增长个数
    dataSource.setAcquireIncrement(2);
    //2获得连接
    Connectionconn = dataSource.getConnection();
    System.out.println(conn);
}

<c3p0-config>
    <!-- 命名的配置 -->
    <named-configname="itheima">
        <!--连接数据库的4项基本参数 -->
 <propertyname="driverClass">com.mysql.jdbc.Driver</property>
   <propertyname="jdbcUrl">jdbc:mysql://127.0.0.1:3306/webdb</property>
        <propertyname="user">root</property>
        <propertyname="password">root</property>
        <!--如果池中数据连接不够时一次增长多少个-->
        <propertyname="acquireIncrement">5</property>
        <!--初始化连接数 -->
        <propertyname="initialPoolSize">20</property>
        <!--最小连接受 -->
        <propertyname="minPoolSize">10</property>
        <!--最大连接数 -->
        <propertyname="maxPoolSize">40</property>
        <!---JDBC的标准参数，用以控制数据源内加载的PreparedStatements数量 -->
        <propertyname="maxStatements">0</property>
        <!--连接池内单个连接所拥有的最大缓存statements数 -->
<propertyname="maxStatementsPerConnection">5</property>
    </named-config>
</c3p0-config>

<c3p0-config>
    <!-- 默认配置，如果没有指定则使用这个配置 -->
    <default-config>
      <propertyname="driverClass">com.mysql.jdbc.Driver</property>
      <propertyname="jdbcUrl">jdbc:mysql://127.0.0.1:3306/webdb</property>
        <propertyname="user">root</property>
        <propertyname="password">root</property>
        <propertyname="checkoutTimeout">30000</property>
       <propertyname="idleConnectionTestPeriod">30</property>
        <propertyname="initialPoolSize">10</property>
        <propertyname="maxIdleTime">30</property>
        <propertyname="maxPoolSize">100</property>
        <propertyname="minPoolSize">10</property>
        <propertyname="maxStatements">200</property>
        <user-overridesuser="test-user">
            <propertyname="maxPoolSize">10</property>
            <propertyname="minPoolSize">1</property>
            <propertyname="maxStatements">0</property>
        </user-overrides>
</default-config>

public class C3P0Utils{
    //使用默认配置
//  privatestatic ComboPooledDataSource dataSource = new ComboPooledDataSource();
    //使用命名配置
    private static ComboPooledDataSource dataSource = new ComboPooledDataSource("itheima");
    /**
     * 获得数据源（连接池）
     * @return
     */
    public static DataSource getDataSource(){
        returndataSource;
    }
    /**
     * 获得连接
     * @return
     * @throws SQLException
     */
    public static Connection getConnection(){
        try {
            returndataSource.getConnection();
        }catch (Exception e) {
            thrownew RuntimeException(e);
        }
    }
} 

@Test
public void demo01() throws Exception{
    //1 获得连接池
    BasicDataSource dataSource = new BasicDataSource();
    //1.1 基本项
    dataSource.setDriverClassName("com.mysql.jdbc.Driver");
   dataSource.setUrl("jdbc:mysql://localhost:3306/webdb_4");
    dataSource.setUsername("root");
    dataSource.setPassword("root");
    //1.2 其他项
    // * 初始化连接池中连个的个数
    dataSource.setInitialSize(5);
    // * 最大活动数
    dataSource.setMaxActive(10);
    //2获得连接
    Connectionconn = dataSource.getConnection();
    System.out.println(conn);
 }

public class DBCPUtils{
    private static DataSource dataSource;
    static{
        try {
            //1加载配置文件，获得文件流
            InputStreamis =DBCPUtils.class.getClassLoader().getResourceAsStream("dbcp.properties");
            //2使用Properties处理配置文件
            Propertiesprops = new Properties();
            props.load(is);
            //3使用工具类创建连接池（数据源）
            dataSource= BasicDataSourceFactory.createDataSource(props);
        }catch (Exception e) {
            thrownew RuntimeException(e);
        }
    }
    public static DataSource getDataSource(){
        returndataSource;
    }
    public static Connection getConnection(){
        try {
            return  dataSource.getConnection();
        }catch (Exception e) {
            thrownew RuntimeException(e);

        }

    }

}

//#1 创建容器，用于存放连接Connection
private static LinkedList<Connection> pool =new LinkedList<Connection>();
//#1.1初始化连接池中的连接
static{
    try {
        //1 注册驱动
        Class.forName("com.mysql.jdbc.Driver");
        for(int i = 0; i < 3; i++) {
            //2获得连接
            Connectionconn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day10_db","root", "1234");
            //3将连接添加到连接池中
            pool.add(conn);
        }
    } catch(Exception e) {
        thrownew RuntimeException(e);
    }
}

/**
 * #2 获得连接，从连接池中获得连接
 * @return
 */
public static Connection getConnection(){
   returnpool.removeFirst();
}
1.4.2.3   归还连接
/**
 * #3 释放资源，当链接connection close时，归还给连接池
 * @paramconn
 * @param st
 * @param rs
 */
public static void release(Connection conn){
    try {
        if(conn != null) {
//          conn.close();   //不是真的关闭
            pool.add(conn); //将从连接池获得连接，归还给连接池
        }
    } catch(Exception e) {
    }
}

public class TestCustomPool {
    public static void main(String[] args) {
        //1 获得连接
            Connectionconn = JdbcUtils.getConnection();
            System.out.println("使用：" + conn + " , " +Thread.currentThread()); 
            //2释放资源
            JdbcUtils.release(conn);
    }
}

A a = …C;
B b = new B(a);
class B implements A{
  private Aa;
  public B(Aa){
     this.a =a;
}
//增强的方法
public void close(){
}
  //不需要增强的方法
  public voidcommit(){
   this.a.commit();
}
}

public class MyConnection implements Connection {
    private Connection conn;
    private List<Connection> pool;
    public MyConnection(Connection conn){
        this.conn= conn;
    }

    /* 因为与自定义连接池有关系，所以需要另外添加一个构造方法 */

    public MyConnection(Connection conn,List<Connection> pool){
        this.conn= conn;
        this.pool= pool;
    }
    /* 以下是增强的方法 */
    @Override
    public void close() throws SQLException {
        //将调用当前close的链接Connection对象添加到链接池中
//      System.out.println("连接归还：" + this);
        this.pool.add(this);
    }
    /* 以下是不需要增强的方法  */

    @Override
    public void commit() throws SQLException {
        this.conn.commit();
    }
    ....
}