数据库连接池---DBCP

    xiaoxiao2025-06-25  4

    数据库连接池---DBCP

    最开始,当然是要将三个支持包导进来才能使用该连接池的,三个包分别为:

    apache.commons.pool-1.5.3.jar、commons-dbcp-1.4.jar、mysql-connector-java-5.1.5-bin.jar

    我在后面会使用到一个配置文件,我在这里先把它贴上来了:dbcp.properties

    #mysql driver=com.mysql.jdbc.Driver url=jdbc:mysql:///mydata?useUnicode=true&characterEncoding=utf-8 username=root password=因为我没有设置密码,因此密码这里空。

    然后就开始讲了

    DbcpPoolDemo.java

    package cn.hncu.dbcp; import java.sql.Connection; import java.util.Properties; import javax.sql.DataSource; import org.apache.commons.dbcp.BasicDataSource; import org.apache.commons.dbcp.BasicDataSourceFactory; import org.junit.Test; public class DbcpPoolDemo { //纯Java方式设置参数,使用dbcp池 @Test public void testDbcp() throws Exception{ BasicDataSource pool=new BasicDataSource(); pool.setUsername("root"); pool.setPassword(""); pool.setDriverClassName("com.mysql.jdbc.Driver"); pool.setUrl("jdbc:mysql://127.0.0.1:3306/mydata?useUnicode=true&characterEncoding=utf-8"); System.out.println(pool.getMaxActive());//最多能有多少个Connection System.out.println(pool.getInitialSize());//初始化时有几个Connection System.out.println( pool.getMaxIdle() ); //最大空闲时间。如果一个用户获取一个连接,不用,多长时间会被强行收回 System.out.println( pool.getMaxWait() ); //等待多长时间,超过该时间就算超时,抛出异常 System.out.println("-----------------"); pool.setMaxActive(10);//可以我们自己设置池的相关参数,如最大连接数 //从池中获取连接 for (int i=0;i<20;i++){ Connection con=pool.getConnection(); System.out.println(con.hashCode()); if (i%2==0){ con.close(); } } } //通过配置文件方式设置参数,使用dbcp池 @Test public void testPropertyFile() throws Exception{ Properties p=new Properties(); //p.load(DbcpPoolDemo.class.getClassLoader().getResourceAsStream("dbcp.properties"));//配置文件要放在src(bin)的根目录---classpath的根 p.load(DbcpPoolDemo.class.getResourceAsStream("dbcp.properties"));//配置文件和当前类的class放在一起 DataSource pool=BasicDataSourceFactory.createDataSource(p); //从它的池中获取连接 for (int i=0;i<20;i++){ Connection con=pool.getConnection(); System.out.println(con.hashCode()); if (i%2==0){ con.close(); } } } }

    上面的代码中已经提到了如何使用,在这里我就进行补充说明:

    关于dbcp的close方法调用后,该Connection就会真的关了,变为null不能使用了;池中只能放设置好的数量Connection,若一直不close或还回来将一直占用,谁要拿都拿不到。

    在上面代码中可以证实上面补充的内容:

    我都以上面代码的testDbcp()方法为例

    1、关于调用close就真的关了:

    按照上面的代码,输出会是这样的

    一看到下面这样的hash值很多人会很疑惑,为什么关了之后还是原来的hash值,再下一个就不是了。

    那么我们把代码位置换一下,换成这样的,结果就很明显了:

    for (int i=0;i<20;i++){ Connection con=pool.getConnection(); if (i%2==0){ con.close(); } <span style="white-space:pre"> </span>System.out.println(con.hashCode()); }结果就是如下了:

    我们在这里输的是hash值,因此空的就是输出0,若直接输出con,就会输出null

    2、占用不还

    这个很好证明,我们只要不调用close就好,因为我们这里也没有写还回去的方法

    我们只需要将代码改成如下即可:

    for (int i=0;i<20;i++){ Connection con=pool.getConnection(); <span> </span>System.out.println(con.hashCode()); }结果如下:

    当然了,这个可以做成一个工具类供数据库连接时使用的,如下我做了一个:

    package cn.hncu.dbcp; import java.io.IOException; import java.sql.Connection; import java.sql.SQLException; import java.util.Properties; import javax.sql.DataSource; import org.apache.commons.dbcp.BasicDataSourceFactory; public class DbcpUtil { private static DataSource pool; private static ThreadLocal<Connection> t=new ThreadLocal<Connection>(); static { try { Properties p=new Properties(); p.load(DbcpUtil.class.getResourceAsStream("dbcp.properties"));// 配置文件和当前类的class放在一起<pre name="code" class="java"><span style="white-space:pre"> </span>//p.load(DbcpPoolDemo.class.getClassLoader().getResourceAsStream("dbcp.properties"));//配置文件要放在src(bin)的根目录---classpath的根 pool=BasicDataSourceFactory.createDataSource(p);} catch (IOException e) {e.printStackTrace();} catch (Exception e) {e.printStackTrace();}}public static DataSource getDataSource(){return pool;}public static Connection getConnection() throws SQLException{Connection con=t.get();if (con==null){con=pool.getConnection();t.set(con);}return con;}}

    转载请注明原文地址: https://ju.6miu.com/read-1300324.html
    最新回复(0)