C3p0数据库连接池的使用-阿里云开发者社区

开发者社区> biehl> 正文

C3p0数据库连接池的使用

简介: 1:首先介绍c3p0的一般使用用法,这种用法练习使用,当然工作的时候使用第二种xml配置完成c3p0的使用。 c3p0的网址:http://www.mchange.com/projects/c3p0/   1.1:第一种方式使用c3p0:     使用编码方式实现c3p0数据库连接池,练习学习使用的方式     1.1.1:创建数据库和数据表,省略。
+关注继续查看

1:首先介绍c3p0的一般使用用法,这种用法练习使用,当然工作的时候使用第二种xml配置完成c3p0的使用。

c3p0的网址:http://www.mchange.com/projects/c3p0/

  1.1:第一种方式使用c3p0:

    使用编码方式实现c3p0数据库连接池,练习学习使用的方式

    1.1.1:创建数据库和数据表,省略。

    1.1.2:引包,如下所示,因为需要连接数据库,所以必须加上mysql的驱动包
       c3p0-0.9.1.2.jar
       mysql-connector-java-5.1.12-bin.jar

    1.1.3:创建实体类,例如User.java,源码如下所示:

 1 package com.bie.po;
 2 /** 
 3 * @author BieHongLi 
 4 * @version 创建时间:2017年3月11日 下午12:55:21 
 5 * 
 6 */
 7 public class User {
 8 
 9     private int id;
10     private String name;
11     private String password;
12     private String email;
13     private String phone;
14     public int getId() {
15         return id;
16     }
17     public void setId(int id) {
18         this.id = id;
19     }
20     public String getName() {
21         return name;
22     }
23     public void setName(String name) {
24         this.name = name;
25     }
26     public String getPassword() {
27         return password;
28     }
29     public void setPassword(String password) {
30         this.password = password;
31     }
32     public String getEmail() {
33         return email;
34     }
35     public void setEmail(String email) {
36         this.email = email;
37     }
38     public String getPhone() {
39         return phone;
40     }
41     public void setPhone(String phone) {
42         this.phone = phone;
43     }
44     @Override
45     public String toString() {
46         return "User [id=" + id + ", name=" + name + ", password=" + password + ", email=" + email + ", phone=" + phone
47                 + "]";
48     }
49     
50     
51 }

    1.1.4:创建好实体类之后就可以进行测试c3p0了,这里使用junit进行测试;源码如下所示:

 1 package com.bie.test;
 2 
 3 import java.beans.PropertyVetoException;
 4 import java.sql.Connection;
 5 import java.sql.PreparedStatement;
 6 import java.sql.ResultSet;
 7 import java.sql.SQLException;
 8 import java.util.ArrayList;
 9 import java.util.List;
10 
11 import org.junit.Test;
12 
13 import com.bie.po.User;
14 import com.mchange.v2.c3p0.ComboPooledDataSource;
15 
16 /** 
17 * @author BieHongLi 
18 * @version 创建时间:2017年3月11日 下午12:40:11 
19 * 
20 */
21 public class C3p0Test {
22 
23     //使用编码方式实现c3p0数据库连接池
24     @Test
25     public void TestC3p0() throws PropertyVetoException, SQLException{
26         //第一步:创建连接池核心工具类
27         ComboPooledDataSource dataSource=new ComboPooledDataSource();
28         //第二步:连接池,url,驱动,账号,密码,初始连接数,最大连接数
29         dataSource.setJdbcUrl("jdbc:mysql:///test");//设置url
30         dataSource.setDriverClass("com.mysql.jdbc.Driver");//设置驱动
31         dataSource.setUser("root");//mysql的账号
32         dataSource.setPassword("123456");//mysql的密码
33         dataSource.setInitialPoolSize(6);//初始连接数,即初始化6个连接
34         dataSource.setMaxPoolSize(50);//最大连接数,即最大的连接数是50
35         dataSource.setMaxIdleTime(60);//最大空闲时间
36         
37         //第三步:从连接池对象中获取数据库连接
38         Connection con=dataSource.getConnection();
39         String sql="select * from user ";
40         PreparedStatement ps=con.prepareStatement(sql);
41         ResultSet rs=ps.executeQuery();
42         
43         List<User> list=new ArrayList<User>();
44         while(rs.next()){
45             User user=new User();
46             user.setId(rs.getInt("id"));
47             user.setName(rs.getString("name"));
48             user.setPassword(rs.getString("password"));
49             user.setEmail(rs.getString("email"));
50             user.setPhone(rs.getString("phone"));
51             list.add(user);
52         }
53         
54         System.out.println(list);
55     }
56 
57 }

  1.2:第二种方式:

    使用配置文件xml方式完成c3p0数据库连接池的应用,是工作之后经常使用的方式:

    1.2.1:在src目录下面创建c3p0-config.xml这个文件名,文件名必须是这个。代码如下所示:

 1 <c3p0-config>
 2     
 3     <!-- c3p0默认配置,下面还可以配置多个数据库 -->
 4     <default-config>
 5         <property name="jdbcUrl">jdbc:mysql://localhost:3306/test
 6         </property>
 7         <property name="driverClass">com.mysql.jdbc.Driver</property>
 8         <property name="user">root</property>
 9         <property name="password">123456</property>
10         <property name="initialPoolSize">6</property>
11         <property name="maxPoolSize">50</property>
12         <property name="maxIdleTime">1000</property>
13     </default-config>
14 
15 </c3p0-config>

    1.2.2:开始使用junit测试,源码如下,自动读取上面的配置文件c3p0-config.xml;所以切记这个配置文件c3p0-config.xml这个名称必须写成这个哦~~~

 1 package com.bie.test;
 2 
 3 import java.beans.PropertyVetoException;
 4 import java.sql.Connection;
 5 import java.sql.PreparedStatement;
 6 import java.sql.ResultSet;
 7 import java.sql.SQLException;
 8 import java.util.ArrayList;
 9 import java.util.List;
10 
11 import org.junit.Test;
12 
13 import com.bie.po.User;
14 import com.mchange.v2.c3p0.ComboPooledDataSource;
15 
16 /** 
17 * @author BieHongLi 
18 * @version 创建时间:2017年3月11日 下午12:40:11 
19 * 
20 */
21 public class C3p0Test2 {
22 
23     //使用编码方式实现c3p0数据库连接池
24     @Test
25     public void TestXml() throws PropertyVetoException, SQLException{
26         //第一步:创建连接池核心工具类
27         ComboPooledDataSource dataSource=new ComboPooledDataSource();
28         
29         //第三步:从连接池对象中获取数据库连接
30         Connection con=dataSource.getConnection();
31         String sql="select * from user ";
32         PreparedStatement ps=con.prepareStatement(sql);
33         ResultSet rs=ps.executeQuery();
34         
35         List<User> list=new ArrayList<User>();
36         while(rs.next()){
37             User user=new User();
38             user.setId(rs.getInt("id"));
39             user.setName(rs.getString("name"));
40             user.setPassword(rs.getString("password"));
41             user.setEmail(rs.getString("email"));
42             user.setPhone(rs.getString("phone"));
43             list.add(user);
44         }
45         
46         System.out.println("~~~"+list);
47     }
48 
49 }

方式一和方式二都是使用一个数据库和数据表,演示效果如下所示:


努力ing,校招开始咯,加油!!!~~~

下一篇,c3p0和QueryRunner的结合让开发更加简便~~~

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Spring Boot 2.x基础教程:使用国产数据库连接池Druid
Spring Boot 2.x基础教程:使用国产数据库连接池Druid
24 0
阿里云服务器怎么设置密码?怎么停机?怎么重启服务器?
如果在创建实例时没有设置密码,或者密码丢失,您可以在控制台上重新设置实例的登录密码。本文仅描述如何在 ECS 管理控制台上修改实例登录密码。
8493 0
在ArcGIS中如何使用直连方式连接Oracle数据库
1.      背景 直连方式比使用SDE方式更加稳定,特别是在大数据量处理的应用中,不易出场由SDE连接进程造成的gsvr错误。
1048 0
c3p0数据库连接池
C3P0: 一个开源的JDBC连接池,它实现了数据源和JNDI绑定,支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有Hibernate,Spring等。   默认情况下(即没有配置连接池的情况下),Hibernate会采用内建的连接池。
1122 0
阿里云服务器端口号设置
阿里云服务器初级使用者可能面临的问题之一. 使用tomcat或者其他服务器软件设置端口号后,比如 一些不是默认的, mysql的 3306, mssql的1433,有时候打不开网页, 原因是没有在ecs安全组去设置这个端口号. 解决: 点击ecs下网络和安全下的安全组 在弹出的安全组中,如果没有就新建安全组,然后点击配置规则 最后如上图点击添加...或快速创建.   have fun!  将编程看作是一门艺术,而不单单是个技术。
10310 0
Spring Boot中使用MongoDB的连接池配置
Spring Boot中使用MongoDB的连接池配置
16 0
阿里云服务器如何登录?阿里云服务器的三种登录方法
购买阿里云ECS云服务器后如何登录?场景不同,阿里云优惠总结大概有三种登录方式: 登录到ECS云服务器控制台 在ECS云服务器控制台用户可以更改密码、更换系.
12167 0
排查数据库连接池错误
最近在使用druid数据源时,碰到一个问题closed connection。在本地及测试环境都运行正常,但是在正式环境,过一段时间就出现closed conneciton问题,关闭的连接。
10 0
牛逼哄哄的数据库连接池,底层原理是个啥?
这次我们采取技术演进的方式来谈谈数据库连接池的技术出现过程及其原理,以及当下最流行的开源数据库连接池jar包。
13 0
+关注
biehl
爱生活,爱工作。
202
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载