【知了堂学习笔记】数据库连接池简介,以及Eclipse中C3p0连接池的简单运用

1.普通的JDBC连接数据库的弊端

  普通的JDBC数据库连接使用 DriverManager 来获取,每次向数据库建立连接的时候都要将 Connection 加载到内存中,再验证用户名和密码(得花费0.05s~1s的时间)。需要数据库连接的时候,就向数据库要求一个,执行完成后再断开连接。

  这样的方式将会消耗大量的资源和时间。数据库的连接资源并没有得到很好的重复利用.若同时有几百人甚至几千人在线,频繁的进行数据库连接操作将占用很多的系统资源,严重的甚至会造成服务器的崩溃。

  对于每一次数据库连接,使用完后都得断开。否则,如果程序出现异常而未能关闭,将会导致数据库系统中的内存泄漏,最终将导致重启数据库。这种开发不能控制被创建的连接对象数,系统资源会被毫无顾及的分配出去,如连接过多,也可能导致内存泄漏,服务器崩溃.

2.使用连接池的优势 

  数据库连接池的基本思想就是为数据库连接建立一个“缓冲池”。预先在缓冲池中放入一定数量的连接,当需要建立数据库连接时,只需从“缓冲池”中取出一个,使用完毕之后再放回去。数据库连接池负责分配、管理和释放数据库连接,它允许应用程序重复使用一个现有的数据库连接,而不是重新建立一个。它的优势有: 

  (1)资源重用:由于数据库连接得以重用,避免了频繁创建,释放连接引起的大量性能开销。在减少系统消耗的基础上,另一方面也增加了系统运行环境的平稳性。

  (2)更快的系统反应速度:数据库连接池在初始化过程中,往往已经创建了若干数据库连接置于连接池中备用。此时连接的初始化工作均已完成。对于业务请求处理而言,直接利用现有可用连接避免了数据库连接初始化和释放过程的时间开销,从而减少了系统的响应时间

  (3)新的资源分配手段对于多应用共享同一数据库的系统而言,可在应用层通过数据库连接池的配置实现某一应用最大可用数据库连接数的限制避免某一应用独占所有的数据库资源.
  (4)统一的连接管理,避免数据库连接泄露在较为完善的数据库连接池实现中,可根据预先的占用超时设定,强制回收被占用连接,从而避免了常规数据库连接操作中可能出现的资源泄露。

3.C3p0连接池的运用

  (1)下载C3p0 jar包   下载地址:https://sourceforge.net/projects/c3p0/files/latest/download?source=files 下载完后,将src文件夹内的2个jar文件拷贝到项目中,然后导入

  (2)设置C3p0配置文件,在项目的src目录下创建一个 c3p0-config.xml(必须这个文件名) 的文件,具体配置如下:

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
   <!--默认配置-->
    <default-config>  
        <property name="initialPoolSize">10</property> <!--设置初始连接池的大小 -->  
        <property name="maxIdleTime">30</property>     <!--设置连接池的最大空闲时间,如果超过这个时间,某个数据库连接还没有被使用,则会断开掉这个连接,如果为0,则永远不会断开连接 -->
        <property name="maxPoolSize">100</property>    <!--设置连接池的最大值,如果获得新连接时会使连接总数超过这个值则不会再获取新连接,而是等待其他连接释放 -->
        <property name="minPoolSize">10</property>     <!--设置连接池的最小值 -->
        <property name="maxStatements">100</property>  <!--设置连接池中的最大Statements数量 -->
    </default-config>  
  
   <!--配置连接池oracle-->
    <named-config name="oracle">  <!--数据库类型 --> 
        <property name="driverClass">oracle.jdbc.driver.OracleDriver</property>  <!--数据库驱动包 --> 
        <property name="jdbcUrl">jdbc:oracle:thin:@localhost:1521:orcl</property>  <!--数据库地址 --> 
        <property name="user">用户名</property>              <!--oracle用户 --> 
        <property name="password">用户密码</property>      <!--用户密码 -->    
        <property name="initialPoolSize">10</property>  
        <property name="maxIdleTime">30</property>      <!--和默认设置一样,也可以自定义设置 -->
        <property name="maxPoolSize">100</property>  
        <property name="minPoolSize">10</property>  
        <property name="maxStatements">100</property>  
    </named-config>  
    
    <!--配置连接池mysql-->
     <named-config name="mysql">  <!--mysql数据库 -->
        <property name="driverClass">com.mysql.jdbc.Driver</property>              <!--mysql驱动包 -->
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/数据库名</property>      <!--数据库地址 -->
        <property name="user">root</property>              <!--用户名 -->
        <property name="password">123456</property>      <!--用户密码 -->
        <property name="initialPoolSize">10</property>  
        <property name="maxIdleTime">30</property>      <!--和默认设置一样,也可以自定义设置 -->
        <property name="maxPoolSize">100</property>  
        <property name="minPoolSize">10</property>  
        <property name="maxStatements">100</property>  
     </named-config>
  
</c3p0-config>

(3)配置好 c3p0-config.xml 后,我们就编写C3p0Utils工具类,用于获取数据库连接,具体代码:

public class C3p0Utils {  
    static ComboPooledDataSource cpds=null;  
    static{   
        cpds = new ComboPooledDataSource("oracle"); //选择连接池的配置,这里是oracle
    }  
    /** 
     * 获得数据库连接  
     */  
    public static Connection getConnection(){  
        try {  
            return cpds.getConnection();  
        } catch (SQLException e) {  
            e.printStackTrace();  
            return null;  
        }  
    }  
      
    /** 
     * 数据库关闭操作 
     * 这里重写close方法,调用close方法并不是真正的关闭连接,只是将连接放回连接池
     */  
    public static void close(Connection conn,PreparedStatement pst,ResultSet rs){  
        if(rs!=null){  
            try {  
                rs.close();  
            } catch (SQLException e) {  
                e.printStackTrace();  
            }  
        }  
        if(pst!=null){  
            try {  
                pst.close();  
            } catch (SQLException e) {  
                e.printStackTrace();  
            }  
        }  
  
        if(conn!=null){  
            try {  
                conn.close();  
            } catch (SQLException e) {  
                e.printStackTrace();  
            }  
        }  
    }  
}

(4)接下来我们去测试一下,工具类是否能使用,测试类代码:

public class oracleTest {

    public static void main(String[] args) {
                Connection conn = null;
                PreparedStatement ps = null;
        ResultSet rs = null;
                conn = C3p0Utils.getConnection();//调用工具类的getConnection()方法
        String sql = "select * from emp";//SQL语句
        User user = new User();
        try {
            ps = conn.prepareStatement(sql);
            rs = ps.executeQuery();
            while (rs.next()) {
                System.out.print(rs.getInt(1) + " ");
                System.out.print(rs.getInt(2) + " ");
                System.out.print(rs.getString(3) + " ");
                System.out.print(rs.getString(4) + " ");
                System.out.println();
            }
            conn.close();//并不是真的关闭,只是将连接放回连接池
        } catch (SQLException e) {
            e.printStackTrace();
        } 
    }
}        

  运行的结果这里就不展示了,程序顺利的查出了员工表(emp)的信息。简单几步就实现了的C3p0连接池的运用。其实实现C3p0的方式大致有三种,这种方式算是最好的了,其他两种就不先不提了。当然,C3p0并不是那么的简单,要想深入的了解C3p0连接池的原理,那可要花不少的时间哦。

  欢迎大家来到知了堂社区学习——传送门:http://www.zhiliaotang.com

  最后填加一些 C3p0-config.xml 比较实用的配置及解释:

<!--acquireIncrement:链接用完了自动增量3个。 -->
    <property name="acquireIncrement">3</property>

    <!--acquireRetryAttempts:链接失败后重新试30次。-->
    <property name="acquireRetryAttempts">30</property>
 
    <!--acquireRetryDelay;两次连接中间隔1000毫秒。 -->
    <property name="acquireRetryDelay">1000</property>
 
    <!--autoCommitOnClose:连接关闭时默认将所有未提交的操作回滚。 -->
    <property name="autoCommitOnClose">false</property>
 
    <!--breakAfterAcquireFailure:出错时不把正在提交的数据抛弃。-->
    <property name="breakAfterAcquireFailure">false</property>
 
    <!--checkoutTimeout:100毫秒后如果sql数据没有执行完将会报错,如果设置成0,那么将会无限的等待。 --> 
    <property name="checkoutTimeout">100</property>
 
    <!--connectionTesterClassName:通过实现ConnectionTester或QueryConnectionTester的类来测试连接。类名需制定全路径。Default: com.mchange.v2.c3p0.impl.DefaultConnectionTester-->
    <property name="connectionTesterClassName"></property>
 
    <!--factoryClassLocation:指定c3p0 libraries的路径,如果(通常都是这样)在本地即可获得那么无需设置,默认null即可。-->
    <property name="factoryClassLocation">null</property>
 
    <!--idleConnectionTestPeriod:每60秒检查所有连接池中的空闲连接。--> 
    <property name="idleConnectionTestPeriod">60</property>
 
    <!--initialPoolSize:初始化时获取三个连接,取值应在minPoolSize与maxPoolSize之间。 --> 
    <property name="initialPoolSize">3</property>
 
    <!--maxIdleTime:最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。-->
    <property name="maxIdleTime">60</property>
 
    <!--maxPoolSize:连接池中保留的最大连接数。 -->
    <property name="maxPoolSize">15</property>
 
    <!--maxStatements:最大链接数。-->
    <property name="maxStatements">100</property>
 
    <!--maxStatementsPerConnection:定义了连接池内单个连接所拥有的最大缓存statements数。Default: 0  -->
    <property name="maxStatementsPerConnection"></property>
 
    <!--numHelperThreads:异步操作,提升性能通过多线程实现多个操作同时被执行。Default: 3--> 
    <property name="numHelperThreads">3</property>
 
    <!--overrideDefaultUser:当用户调用getConnection()时使root用户成为去获取连接的用户。主要用于连接池连接非c3p0的数据源时。Default: null--> 
    <property name="overrideDefaultUser">root</property>
 
    <!--overrideDefaultPassword:与overrideDefaultUser参数对应使用的一个参数。Default: null-->
    <property name="overrideDefaultPassword">password</property>
 
    <!--password:密码。Default: null--> 
    <property name="password"></property>
 
    <!--preferredTestQuery:定义所有连接测试都执行的测试语句。在使用连接测试的情况下这个一显著提高测试速度。注意: 测试的表必须在初始数据源的时候就存在。Default: null-->
    <property name="preferredTestQuery">select id from test where id=1</property>
 
    <!--propertyCycle:用户修改系统配置参数执行前最多等待300秒。Default: 300 --> 
    <property name="propertyCycle">300</property>
 
    <!--testConnectionOnCheckout:因性能消耗大请只在需要的时候使用它。Default: false -->
    <property name="testConnectionOnCheckout">false</property>
 
    <!--testConnectionOnCheckin:如果设为true那么在取得连接的同时将校验连接的有效性。Default: false -->
    <property name="testConnectionOnCheckin">true</property>
 
    <!--user:用户名。Default: null-->
    <property name="user">root</property>
 
    <!--usesTraditionalReflectiveProxies:动态反射代理。Default: false-->
    <property name="usesTraditionalReflectiveProxies">false</property>
原文地址:https://www.cnblogs.com/paopaolong/p/7446384.html