c3p0参数的说明以及整合spring使用_迪迪调调的博客-程序员宅基地

技术标签: c3p0Spring  c3p0参数配置  工作  c3p0  

准备需要的jar包,如下:

这里写图片描述

这些jar包,我已经放到后面贴的源码里了,可自行下载。

列出常用的c3p0参数的配置的含义:

<!-- c3p0连接池配置 -->
     <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
          <!--数据库连接相关的配置 --> 
          <property name="driverClass" value="${jdbc.driverClassName}"></property>
          <property name="jdbcUrl" value="${jdbc.url}"></property>
          <property name="user" value="${jdbc.username}"></property>
          <property name="password" value="${jdbc.password}"></property>

          <!--连接池中保留的最大连接数。默认值: 15 --> 
          <property name="maxPoolSize" value="30"/>
          <!-- 连接池中保留的最小连接数,默认为:3-->
          <property name="minPoolSize" value="2"/>
          <!-- 初始化连接池中的连接数,取值应在minPoolSize与maxPoolSize之间,默认为3-->
          <property name="initialPoolSize" value="2"/>

          <!--最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。默认值: 0 --> 
          <property name="maxIdleTime">60</property>

          <!-- 当连接池连接耗尽时,客户端调用getConnection()后等待获取新连接的时间,超时后将抛出SQLException,如设为0则无限期等待。单位毫秒。默认: 0 --> 
          <property name="checkoutTimeout" value="3000"/>

          <!--当连接池中的连接耗尽的时候c3p0一次同时获取的连接数。默认值: 3 --> 
          <property name="acquireIncrement" value="2"/>

         <!--定义在从数据库获取新连接失败后重复尝试的次数。默认值: 30 ;小于等于0表示无限次--> 
          <property name="acquireRetryAttempts" value="0"/>

          <!--重新尝试的时间间隔,默认为:1000毫秒--> 
          <property name="acquireRetryDelay" value="1000" />

          <!--关闭连接时,是否提交未提交的事务,默认为false,即关闭连接,回滚未提交的事务 --> 
          <property name="autoCommitOnClose">false</property>

          <!--每60秒检查所有连接池中的空闲连接。默认值: 0,不检查 --> 
          <property name="idleConnectionTestPeriod">60</property>
          <!--c3p0全局的PreparedStatements缓存的大小。如果maxStatements与maxStatementsPerConnection均为0,则缓存不生效,只要有一个不为0,则语句的缓存就能生效。如果默认值: 0--> 
          <property name="maxStatements">100</property>
          <!--maxStatementsPerConnection定义了连接池内单个连接所拥有的最大缓存statements数。默认值: 0 --> 
          <property name="maxStatementsPerConnection"></property>
     </bean>

下面就简单使用一下:

新建一个student的model:

public class Student {
    

    private int id;
    private String username;
    private String age;
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }
    public void setUsername(String username) {
        this.username = username;
    }
    public String getAge() {
        return age;
    }
    public void setAge(String age) {
        this.age = age;
    }


}

并创建student表:

create table student (id int(10) not null auto_increment,username varchar(20),age varchar(3),primary key(id));

spring bean.xml配置文件:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://www.springframework.org/schema/context 
       http://www.springframework.org/schema/context/spring-context.xsd">       
  <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="locations">
            <value>classpath:jdbc.properties</value>
        </property>
   </bean>

    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="${jdbc.driverClassName}"></property>
        <property name="jdbcUrl" value="${jdbc.url}"></property>
        <property name="user" value="${jdbc.username}"></property>
        <property name="password" value="${jdbc.password}"></property>

        <property name="minPoolSize"><value>1</value></property>
        <property name="maxPoolSize"><value>3</value></property>
        <property name="maxIdleTime"><value>300</value></property>
        <property name="checkoutTimeout" value="3000"/>  

    </bean>
    <bean id="jdbctemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"></property>
    </bean>
</beans>

mysql数据库配置jdbc.properties:


jdbc.username=root
jdbc.password=root
jdbc.url=jdbc:mysql://localhost:3306/spring
jdbc.driverClassName=com.mysql.jdbc.Driver

测试代码:

import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;


public class Test {
     public static void main(String[] args) {
            ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext("beans.xml");
            JdbcTemplate jdbcTemplate = (JdbcTemplate) ctx.getBean("jdbctemplate");
            System.out.println(jdbcTemplate);
            jdbcTemplate.update("insert into student(id,username,age)values(null,?,?)", "xiaoming","20");
    }
}

可以在mysql客户端查看代码插入的一条记录。

我的主要目的是想测试一下参数maxPoolSize的具体含义,因为在工作中遇到了连接池的连接数满了导致的报错。,当使用的连接数已经达到最大的连接数时,再申请连接会发生什么情况?

import java.sql.Connection;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.mchange.v2.c3p0.ComboPooledDataSource;


public class TestPoolSize {
    
     public static void main(String[] args) throws Exception {

            ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext("beans.xml");

            ComboPooledDataSource cpds =(ComboPooledDataSource)ctx.getBean("dataSource");

            for (int i = 0; i <3; i++) {
                Connection con = cpds.getConnection();
                System.out.println("获取第" +i+ "个连接:" + con);

            }
            System.out.println("正在使用的连接数:" +cpds.getNumBusyConnections());
            Connection con = cpds.getConnection();
            System.out.println("再获取一个连接" + con);



    }

}

从配置文件中我们可以知道,配置的最大连接数是maxPoolSize=3,我们的测试代码的循环中取了三个连接,且没有释放,达到了我们设置的最大连接数3。此时再去连接池中拿连接,就会抛出异常。

这里写图片描述

注意,这是因为我们设置了参数checkoutTimeout,要是不设置这个参数,程序会一直等待连接,不会报错了。

如果我们将获取的连接用完就正确的释放,这个连接就会重新回到连接池中,就可以再次使用了。

import java.sql.Connection;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.mchange.v2.c3p0.ComboPooledDataSource;


public class TestPoolSize {
     public static void main(String[] args) throws Exception {

            ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext("beans.xml");

            ComboPooledDataSource cpds =(ComboPooledDataSource)ctx.getBean("dataSource");

            for (int i = 0; i <3; i++) {
                Connection con = cpds.getConnection();
                System.out.println("获取第" +(i+1)+ "个连接:" + con);
                System.out.println("使用完毕,释放连接....");
                con.close();//释放连接

            }
            System.out.println("正在使用的连接数:" +cpds.getNumBusyConnections());

            for (int i = 0; i <3; i++) {
                Connection con = cpds.getConnection();
                System.out.println("重新获取连接:" + con);

            }



    }

}

实验结果:

获取第1个连接:[email protected]
使用完毕,释放连接....
获取第2个连接:[email protected]
使用完毕,释放连接....
获取第3个连接:[email protected]
使用完毕,释放连接....
正在使用的连接数:1
重新获取连接:[email protected]
重新获取连接:[email protected]
重新获取连接:[email protected]

acquireRetryAttempts:连接池在获得新连接失败时重试的次数,如果小于等于0则无限重试直至连接获得成功

checkoutTimeout:配置当连接池所有连接用完时应用程序getConnection的等待时间。为0则无限等待直至有其他连接释放或者创建新的连接,不为0则当时间到的时候如果仍没有获得连接,则会抛出SQLException

所以当不设置checkoutTimeout,且设置acquireRetryAttempts时,当当前连接数达到最大的maxPoolSize时,再申请连接时,会一直等待有连接释放后拿到连接。

修改配置文件:

    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="${jdbc.driverClassName}"></property>
        <property name="jdbcUrl" value="${jdbc.url}"></property>
        <property name="user" value="${jdbc.username}"></property>
        <property name="password" value="${jdbc.password}"></property>

        <property name="minPoolSize"><value>1</value></property>
        <property name="maxPoolSize"><value>10</value></property>
        <property name="maxIdleTime"><value>300</value></property>
<!--        <property name="checkoutTimeout" value="3000"/>-->
        <property name="acquireRetryAttempts"><value>30</value></property>

    </bean>
import java.sql.Connection;
import java.sql.SQLException;
import java.util.*;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.mchange.v2.c3p0.ComboPooledDataSource;


public class TestPoolSize {
    
     public static void main(String[] args) throws Exception {

            ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext("beans.xml");

            final ComboPooledDataSource cpds =(ComboPooledDataSource)ctx.getBean("dataSource");
            final List<Connection>cons =new ArrayList<Connection>();
            for (int i = 0; i <10; i++) {
                Connection con = cpds.getConnection();
                cons.add(con);
                System.out.println("获取第" +(i+1)+ "个连接:" + con);
            }
            System.out.println("正在使用的连接数:" +cpds.getNumBusyConnections());


            new Thread(new Runnable() {

                @Override
                public void run() {
                     for (Connection connection : cons) {
                        try {
                                System.out.println("正在释放一个连接....");
                                Thread.sleep(2000);
                                connection.close();

                         } catch (Exception e) {
                            e.printStackTrace();
                        }
                    }
                }
            }).start();
            //主线程申请的连接已经达到maxPoolSize,运行到下面的线程获取连接时,如果不设置checkoutTimeout,会一直等待,
            //且如果设置了acquireRetryAttempt就会一直尝试获取连接,如果上面有连接释放,就获取连接。

            new Thread( new Runnable() {
                public void run() {
                    for (int i = 0; i <10; i++) {
                        Connection con=null;
                        try {
                            con = cpds.getConnection();
                        } catch (Exception e) {
                            e.printStackTrace();
                        }
                        System.out.println("新获取第" +(i+1)+ "个连接:" + con);
                    }
                }
            }).start();





    }

}

测试源码下载地址:

http://pan.baidu.com/s/1dF1mR7N

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/u010248330/article/details/73089642

智能推荐

openstack部署过程1_Weach的博客-程序员宅基地

openstack部署过程1名称IP地址主机名称控制节点192.168.56.10Controller计算节点1192.168.56.20Computer1计算节点2192.168.56.30Computer21.基础环境准备使用VMware初始化三台虚拟机controller节点配置这里安装了图像化界面GNOME Desktop( 方便偷懒 ????设置静态IP使用命令 vi /etc/sysconfig/network-scripts/i

西门子200实现远程监控和程序调试_weixin_33806300的博客-程序员宅基地

2019独角兽企业重金招聘Python工程师标准&gt;&gt;&gt; ...

输入两个整数序列,第一个序列表示栈的压入顺序,请判断第二个序列是否可能为该栈的弹出顺序。假设压入栈的所有数字均不相等。_Tom Hardy的博客-程序员宅基地

题目描述输入两个整数序列,第一个序列表示栈的压入顺序,请判断第二个序列是否可能为该栈的弹出顺序。假设压入栈的所有数字均不相等。例如序列1,2,3,4,5是某栈的压入顺序,序列4,5,3,2,1是该压栈序列对应的一个弹出序列,但4,3,5,1,2就不可能是该压栈序列的弹出序列。(注意:这两个序列的长度是相等的)题目分析这里有一个陷阱,栈的弹出序列不一定是栈的压入序列的倒序,因为有可能在压入的过...

0429建立Extended Statistics函数索引问题_weixin_33994444的博客-程序员宅基地

[20160429]建立Extended Statistics 和函数索引问题.txt --11G支持相关数据的统计分析,比如如果两个字段存在相关性通过分析,能够得到更加良好的统计信息,以及生成好的执行计划. --但是如果结合函数索引呢?通过一个简单的例子来说明: --前次做的测试: http://blog.it...

43个功能测试点总结_iteye_15968的博客-程序员宅基地

43个功能测试点总结 软件测试  功能测试就是对产品的各功能进行验证,根据功能测试用例,逐项测试,检查产品是否达到用户要求的功能。针对Web系统的常用测试方法如下:  1. 页面链接检查:每一个链接是否都有对应的页面,并且页面之间切换正确。可以使用一些工具,如LinkBotPro、File-AIDCS、HTML Link Validater、Xenu等工具。LinkBotPro不支持...

随便推点

UILabel设置富文本格式显示_weixin_30439067的博客-程序员宅基地

标签:实例化方法和使用方法实例化方法:使用字符串初始化- (id)initWithString:(NSString*)str;例:NSMutableAttributedString*AttributedStr = [[NSMutableAttributedStringalloc]initWithString:@"今天天气不错呀"];- (id)init...

开源ETL工具kettle系列之增量更新设计技巧_青龙白虎米老鼠的博客-程序员宅基地

ETL中增量更新是一个比较依赖与工具和设计方法的过程,Kettle中主要提供Insert / Update 步骤,Delete 步骤和Database  Lookup  步骤来支持增量更新,增量更新的设计方法也是根据应用场景来选取的,虽然本文讨论的是Kettle的实现方式,但也许对其他工具也有一些帮助。本文不可能涵盖所有的情况,欢迎大家讨论。应用场景增量更新按照数据种类的不同大概可以分成:

PTA基础编程题目集7-4~7-6(C++)_return-0的博客-程序员宅基地

7-4 BCD解密 (10 分)BCD数是用一个字节来表达两位十进制的数,每四个比特表示一位。所以如果一个BCD数的十六进制是0x12,它表达的就是十进制的12。但是小明没学过BCD,把所有的BCD数都当作二进制数转换成十进制输出了。于是BCD的0x12被输出成了十进制的18了!现在,你的程序要读入这个错误的十进制数,然后输出正确的十进制数。提示:你可以把18转换回0x12,然后再转换回12。输入格式:输入在一行中给出一个[0, 153]范围内的正整数,保证能转换回有效的BCD数,也就是说这

获取设备IMEI ,手机名称,系统SDK版本号,系统版本号_weixin_33735077的博客-程序员宅基地

1、获取设备IMEI TelephonyManager tm = (TelephonyManager) getSystemService(Context.TELEPHONY_SERVICE); String IMEIs = tm.getDeviceId() ;需要的权限 &lt;uses-permission androi...

Github配置_Andrew_Zhu的博客-程序员宅基地

-----如果你的代码不知道放哪里好,放到github是一个不错的选择。下面奉上一文入门级别的配置篇。(以下配置同时适用于window和linux) 在github注册完后,首先创建一个仓库(repositry),在你的个人页面右边"Your Repositories"模块,点击 New repository,这里我们把project name 填写

snmp_diexian5592的博客-程序员宅基地

snmpd作为一个服务,本身有系统的一些信息,外部可以通过snmp -get ,walk来获取,而snmptrap理解为一个陷阱,等着掉进来猎物,就是一个收数据的服务,但是收到的数据和snmpd中呈现的数据时互不相关的,两个是独立的,snmptrap收到的数据打到一个日志文件中,通过snmptt可以进行简单的过滤操作,使得拿到的数据更加的符合要求。snmptrap数据收集流程s...

推荐文章

热门文章

相关标签