工作生活

Java 数据库连接池使用

2019-06-29  本文已影响0人  第八共同体

1.c3p0简介

c3p0被设计成易于使用。只需要在项目中导入相关jar包即可,导入相关包时，需要注意，包的版本的及依赖包的版本

<dependencies>
  <!-- https://mvnrepository.com/artifact/com.mchange/c3p0 -->
    <dependency>
        <groupId>com.mchange</groupId>
        <artifactId>c3p0</artifactId>
        <version>0.9.5.4</version>
    </dependency>
    <!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>5.1.6</version>
    </dependency>
  </dependencies>

即可进行简单的数据库操作

ComboPooledDataSource cpds = new ComboPooledDataSource();
cpds.setDriverClass( "org.postgresql.Driver" ); //loads the jdbc driver            
cpds.setJdbcUrl( "jdbc:postgresql://localhost/testdb" );
cpds.setUser("dbuser");                                  
cpds.setPassword("dbpassword");

如果需要打开PreparedStatement池，需要设置maxStatements、 maxStatementsPerConnection ，它们的默认值都是0.
cpds.setMaxStatements( 180 );
使用完成后，清理
cpds.close();就是这样，剩下的就是细节了。

2.c3p0使用

获取c3p0池支持的DataSource有三种方法：

大多数用户可能会发现实例化ComboPooledDataSource是最方便的方法。 实例化后，c3p0 DataSources几乎可以绑定到任何符合JNDI的名称服务。

实例化和配置一个ComboPooledDataSource

ds = new ComboPooledDataSource();
//          ds.setDriverClass(env.getProperty("jdbc.driver"));
//          ds.setJdbcUrl(url);
//          ds.setUser(username);
//          ds.setPassword(password);
//          ds.setMaxPoolSize(200);
//          ds.setMinPoolSize(10);
//          ds.setInitialPoolSize(50);
//          ds.setMaxStatements(180);

3. c3p0 PooledDataSources的清理工作

 DataSources.destroy( ds_pooled );

或者，c3p0的PooledDataSource接口包含一个close（）方法，当您知道已完成DataSource时可以调用该方法

4.c3p0配置

虽然c3p0不需要很多配置，但它是非常可调整的。有几种方法可以修改c3p0属性：您可以直接更改代码中与特定DataSource关联的属性值，也可以从外部配置c3p0

5.基本的池配置

6.管理池大小和连接时间

不同的应用程序在性能，占用空间和可靠性之间的权衡方面有不同的需求。C3P0提供了多种选项，用于控制在负载下变大的池恢复到minPoolSize的速度，以及是否应主动替换池中的“旧”连接以保持其可靠性。

7.hibernate c3p0

导入相关包，注意包的版本问题，否则无法支持相关功能：

<!-- https://mvnrepository.com/artifact/org.hibernate/hibernate-c3p0 -->
<dependency>
    <groupId>org.hibernate</groupId>
    <artifactId>hibernate-c3p0</artifactId>
    <version>5.3.3.Final</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.mchange/c3p0 -->
<dependency>
    <groupId>com.mchange</groupId>
    <artifactId>c3p0</artifactId>
    <version>0.9.5.2</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.hibernate/hibernate-core -->
<dependency>
    <groupId>org.hibernate</groupId>
    <artifactId>hibernate-core</artifactId>
    <version>5.3.3.Final</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.jboss.logging/jboss-logging -->
<dependency>
    <groupId>org.jboss.logging</groupId>
    <artifactId>jboss-logging</artifactId>
    <version>3.3.2.Final</version>
</dependency>

其相关依赖包都要相应导入，导入时需注意包的版本依赖


image.png

相关包导入后，即可在项目中，进行相关配置，来使用数据库连接池的功能了

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE hibernate-configuration PUBLIC
   "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
   "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
    <session-factory>
        <property name="dialect">org.hibernate.dialect.Oracle9iDialect</property>
        <property name="connection.driver_class">oracle.jdbc.driver.OracleDriver</property>
        <property name="connection.url">jdbc:oracle:thin:@127.0.0.1:1521:orcl</property>
        <property name="connection.username">username</property>
        <property name="connection.password">password</property>
        <property name="format_sql">false</property>
        <property name="show_sql">false</property>
        <property name="hbm2ddl.auto">update</property>
        <property name="c3p0.min_size">5</property>
        <property name="c3p0.max_size">30</property>
        <property name="c3p0.timeout">120</property>
        <property name="c3p0.idle_test_period">3000</property>
    </session-factory>
</hibernate-configuration>

mysql数据库

hibernate.cfg.xml配置

        <property name="dialect">org.hibernate.dialect.MySQL5InnoDBDialect</property>
        <property name="connection.driver_class">com.mysql.jdbc.Driver</property>
        <property name="connection.url">jdbc:mysql://localhost:3306/dbname?useSSL=false</property>
        <property name="connection.characterEncoding">utf-8 </property>
        <property name="connection.username">username</property>
        <property name="connection.password">password</property>

在dao层进行查询操作时，使用
Object result = query.uniqueResult();要注意，因为该方法在查询为空时，返回的是null,不能进行诸如
(Long)null此类的强制类型转换，所以需要另外处理

oracle数据库

hibernate.cfg.xml配置

        <property name="dialect">org.hibernate.dialect.Oracle9iDialect</property>
        <property name="connection.driver_class">oracle.jdbc.driver.OracleDriver</property>
        <property name="connection.url">jdbc:oracle:thin:@127.0.0.1:1521:sid</property>
        <property name="connection.username">username</property>
        <property name="connection.password">password</property>

c3p0配置

使用c3p0数据库连接池配置

        <!--连接池中保留的最小连接数。-->
        <property name="c3p0.min_size">5</property>
        <!--连接池中保留的最大连接数。Default: 15 -->
        <property name="c3p0.max_size">30</property>
        <!-- 获得连接的超时时间,如果超过这个时间,会抛出异常，单位毫秒 -->
        <property name="c3p0.timeout">120</property>
        <!-- 每隔3000秒检查连接池里的空闲连接 ，单位是秒-->
        <property name="c3p0.idle_test_period">3000</property>
        <!-- 当连接池里面的连接用完的时候，C3P0一下获取的新的连接数 -->
        <property name="c3p0.acquire_increment">2</property>
        <!-- 每次都验证连接是否可用 -->
        <property name="c3p0.validate">true</property>

c3p0验证是否配置生效的方法：

+-----+------+-----------------+----------------+---------+------+----------+------------------+
| 413 | root | localhost:60627 | localhost_mayi | Sleep   |   49 |          | NULL             |
| 414 | root | localhost:60628 | NULL           | Sleep   |   56 |          | NULL             |
| 457 | root | localhost       | NULL           | Query   |    0 | starting | show processlist |
| 463 | root | localhost:62823 | localhost_mayi | Sleep   |   12 |          | NULL             |
| 464 | root | localhost:62822 | localhost_mayi | Sleep   |   12 |          | NULL             |
| 465 | root | localhost:62824 | localhost_mayi | Sleep   |    1 |          | NULL             |
| 466 | root | localhost:62825 | localhost_mayi | Sleep   |    0 |          | NULL             |
| 467 | root | localhost:62826 | localhost_mayi | Sleep   |   12 |          | NULL             |
+-----+------+-----------------+----------------+---------+------+----------+------------------+
8 rows in set (0.00 sec)

注 ：无论使用何种数据库存储，都把相关驱动提前加入到pom文件中，后续仅仅调整配置文件即可，无需重新编译

上一篇 下一篇

猜你喜欢

热点阅读