欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Java个人总结——JDBC数据库连接池(二)

程序员文章站 2022-05-24 12:27:49
...

三种常见的数据库连接池


一、DBCP连接池

DBCP(DataBase connection pool),[数据库连接池]。是 apache 上的一个 java 连接池项目,也是 tomcat 使用的连接池组件。单独使用dbcp需要2个包:commons-dbcp.jar 和 commons-pool.jar由于建立数据库连接是一个非常耗时的行为,所以通过连接池预先同数据库建立一些连接,放在内存中,应用程序需要建立数据库连接时直接到连接池中申请一个就行,用完后再放回去。

1 、DBCP连接池的使用

  • 1.1 创建项目
    创建JavaWeb项目

  • 1.2 导入相应jar包

    mysql驱动包
    commons-dbcp.jar
    commons-pool.jar
    commons-logging.jar 日志支持

  • 1.3 硬编码使用DBCP

所谓的硬编码方式就是在代码中添加配置

public class DbcpTest2 {

    @Test
    public void test() {
        //创建DBCP对象
        BasicDataSource bds = new BasicDataSource() ;
        //1.四个基本参数
        bds.setDriverClassName("com.mysql.jdbc.Driver");
        bds.setUrl("jdbc:mysql://localhost:3306/emp");
        bds.setUsername("root");
        bds.setPassword("root");
        //2.其他参数
        //初始大小
        bds.setInitialSize(10);
        //最大空间
        bds.setMaxTotal(50);
        //最大空闲
        bds.setMaxIdle(15);
        //最小空闲
        bds.setMinIdle(5);
        //最大等待时间
        bds.setMaxWaitMillis(5000);

        try {
            for (int i = 0; i < 100; i++) {
                Connection conn = bds.getConnection();
                System.out.println(conn + ".........." + i);
                conn.close();//没有真的关闭,只是归还给连接池
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

}
  • 1.4 软编码使用DBCP

所谓的软编码,就是在项目中添加配置文件,这样就不需要每次代码中添加配合!

  1. 项目中添加配置

    文件名称: dbcp.properties

    文件位置: src下

#连接设置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/school
username=root
password=root
#<!-- 初始化连接 -->
initialSize=10
#最大连接数量
maxTotal=50
#<!-- 最大空闲连接 -->
maxIdle=20
#<!-- 最小空闲连接 -->
minIdle=5
#<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
maxWaitMillis=5000

代码实现

public class DbcpTest {

    @Test
    public void test() {
        //加载属性文件
        InputStream is = DbcpTest.class.getClassLoader().getResourceAsStream("dbcp.properties");
        Properties pro = new Properties();
        BasicDataSource bds = null ;
        try {
            pro.load(is);
            //使用工厂获取数据库连接池对象
            bds = BasicDataSourceFactory.createDataSource(pro) ;
            for (int i = 0; i < 100; i++) {
                Connection conn = bds.getConnection();
                System.out.println(conn + ".........." + i);
                conn.close();
            }

        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

二、 C3P0连接池

C3P0是一个开源的JDBC连接池,它实现了数据源和JNDI绑定,支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有Hibernate,Spring等。

c3p0与dbcp区别
 1.
    dbcp没有自动回收空闲连接的功能
    c3p0有自动回收空闲连接功能
 2. 
    dbcp需要手动加载配置文件
    c3p0自动加载

1、 使用步骤

  • 1.1 创建项目

  • 1.2 导入jar包

    c3p0-0.9.1.2.jar
    mchange-commons-java-0.2.11.jar
    mysql驱动包

  • 1.3.添加配置文件

    c3p0是在外部添加配置文件,工具直接进行应用,因为直接引用,所以要求固定的命名和文件位置

    文件位置: src

    文件命名:c3p0-config.xml 和 c3p0.properties

使用配置文件:c3p0-config.xml

<!-- 该配置文件为固定格式,需要时直接复制使用即可,无需记忆 -->
<c3p0-config>
    <!-- 默认配置,如果没有指定则使用这个配置 -->
    <default-config>
        <!-- 基本配置 -->
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/school</property>
        <property name="user">root</property>
        <property name="password">root</property>
        <!--扩展配置-->
        <!-- 连接超过10秒报错-->
        <property name="checkoutTimeout">10000</property>
        <!--30秒检查空闲连接 -->
        <property name="idleConnectionTestPeriod">30</property>
        <!-- 初始大小 -->
        <property name="initialPoolSize">10</property>
        <!-- 每次增长的个数 -->
        <property name="acquireIncrement">5</property>
         <!-- 30秒不适用丢弃-->
        <property name="maxIdleTime">20</property>
        <property name="maxPoolSize">50</property>
        <property name="minPoolSize">5</property>
    </default-config> 
    <!-- 自己的配置,named-config name="自定义名称" -->
    <!-- 程序调用时可以指定该自定义名称,若不指定,系统自动调用上面的默认配置 -->
    <named-config name="my">
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/day2</property>
        <property name="user">root</property>
        <property name="password">111</property>
        <!-- 如果池中数据连接不够时一次增长多少个 -->
        <property name="acquireIncrement">5</property>
        <property name="initialPoolSize">20</property>
        <property name="minPoolSize">10</property>
        <property name="maxPoolSize">40</property>
    </named-config>
</c3p0-config> 

使用属性文件:c3p0.properties

c3p0.driverClass=com.mysql.jdbc.Driver
c3p0.jdbcUrl=jdbc:mysql://localhost:3306/school
c3p0.user=root
c3p0.password=root
c3p0.acquireIncrement=5
c3p0.initialPoolSize=20
c3p0.minPoolSize=10
c3p0.maxPoolSize=40

注意:

  • c3p0的配置文件内部可以包含命名配置文件和默认配置文件!默认是选择默认配置!如果需要切换命名配置可以在创建c3p0连接池的时候填入命名即可!

  • 如果xml配置文件和属性文件都存在时,xml优先级高于属性文件

代码实现:

使用配置文件配置数据库连接池

public class C3p0Test2 {
    @Test
    public void test() {
        //使用配置文件中的自定义配置,不写参数自动调用默认配置
        ComboPooledDataSource cpds = new ComboPooledDataSource("my");
        try {
            //循环验证是否成功
            for(int i=0; i<100; i++) {
                //从连接池中获取连接
                Connection conn = cpds.getConnection() ;
                System.out.println(conn + "......" + i);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

同样,我们还可以使用硬编码的形式来配置C3P0

public class C3p0Test {
    @Test
    public void test() {
        ComboPooledDataSource cpds = new ComboPooledDataSource() ;
        try {
            //1.四个基本参数
            cpds.setDriverClass("com.mysql.jdbc.Driver");
            cpds.setJdbcUrl("jdbc:mysql://localhost:3306/emp");
            cpds.setUser("root");
            cpds.setPassword("lvyifan");
            //2.其他参数
            //2.1设置初始池大小
            cpds.setInitialPoolSize(10);
            //2.2设置最大池大小
            cpds.setMaxPoolSize(50);
            //2.3设置最小池大小
            cpds.setMinPoolSize(5);
            //2.4设置等待时间
            cpds.setCheckoutTimeout(5000);
            //2.5连接池一次扩展的大小
            cpds.setAcquireIncrement(5);
            for(int i=0; i<100; i++) {
                Connection conn = cpds.getConnection() ;
                System.out.println(conn + "....." + i);
                conn.close();
            }

        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

由于此方法是代码显得臃肿,且不易维护,所以我们一般使用配置文件或属性文件的方式进行配置。


三、Druid连接池

Druid 是目前比较流行的高性能的,分布式列存储的OLAP框架(具体来说是MOLAP)。它有如下几个特点:
一、亚秒级查询
druid提供了快速的聚合能力以及亚秒级的OLAP查询能力,多租户的设计,是面向用户分析应用的理想方式。
二、实时数据注入
druid支持流数据的注入,并提供了数据的事件驱动,保证在实时和离线环境下事件的实效性和统一性
三、可扩展的PB级存储
druid集群可以很方便的扩容到PB的数据量,每秒百万级别的数据注入。即便在加大数据规模的情况下,也能保证时其效性
四、多环境部署
druid既可以运行在商业的硬件上,也可以运行在云上。它可以从多种数据系统中注入数据,包括hadoop,spark,kafka,storm和samza等
五、丰富的社区
druid拥有丰富的社区,供大家学习

使用步骤:

  • 1、导入jar包
    druid-1.1.5.jar

  • 2、配置文件 database.properties:

//连接设置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/school
username=root
password=root
<!-- 初始化连接 -->
initialSize=10
//最大连接数量
maxActive=50
<!-- 最小空闲连接 -->
minIdle=5
<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
maxWait=5000

实现代码:

public class DruitTest2 {
    @Test
    public void test() {
        // 使用类加载器加载属性文件
        InputStream is = DruitTest2.class.getClassLoader().getResourceAsStream("druid.properties") ;
        Properties pro = new Properties() ;
        try {
            pro.load(is);
            // 使用Druid连接池工厂实例化DruidDataSource接口
            DruidDataSource dds = (DruidDataSource) DruidDataSourceFactory.createDataSource(pro) ;
            for (int i = 0; i < 100; i++) {
                Connection conn = dds.getConnection() ;
                System.out.println(conn.getClass().getName() + "..." + i);
                conn.close() ;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}