数据库连接池之c3p0入门

来源:互联网
更新时间:2018/2/18 7:45:14
责任编辑:李佳
 DB2 
字体:

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

如果你不知道什么是连接池,可以先去百度一下。我理解的呢,就是一个大水池,里面有很多鱼,每条鱼对应一个数据库连接,你拿到一条鱼你就获得一个连接,当然,这鱼不能吃,你摸完了还要放回去的。这例子有点变态哈哈,能理解就行。

好!下面我们开始了。

一、首先我们从最最基本的开始,就是如何用java代码实现用c3p0连接数据库,并且执行查询操作。

首先我们新建一个项目:it_xiaorenwu

我们要做c3p0那就要先导入c3p0的包:

1.c3p0-0.9.2.1.jar

2.mchange-commons-java-0.2.3.4.jar

3.mysql-connector-java-5.1.7-bin.jar

4.commons-io-2.0.1.jar

5.junit-4.5.jar

二、我们先准备数据库和数据

  1. /* 
  2. SQLyog Ultimate v11.24 (32 bit) 
  3. MySQL - 5.5.24 : Database - test 
  4. ********************************************************************* 
  5. */ 
  6.   
  7.   
  8. /*!40101 SET NAMES utf8 */; 
  9.   
  10. /*!40101 SET SQL_MODE=''*/; 
  11.   
  12. /*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */; 
  13. /*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */; 
  14. /*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='NO_AUTO_VALUE_ON_ZERO' */; 
  15. /*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */; 
  16. CREATE DATABASE /*!32312 IF NOT EXISTS*/`test` /*!40100 DEFAULT CHARACTER SET latin1 */; 
  17.   
  18. USE `test`; 
  19.   
  20. /*Table structure for table `user` */ 
  21.   
  22. DROP TABLE IF EXISTS `user`; 
  23.   
  24. CREATE TABLE `user` ( 
  25.   `id` int(10) NOT NULL AUTO_INCREMENT, 
  26.   `user_name` varchar(20) CHARACTER SET latin1 DEFAULT NULL, 
  27.   `password` varchar(100) CHARACTER SET latin1 DEFAULT NULL, 
  28.   `address` varchar(100) CHARACTER SET latin1 DEFAULT NULL, 
  29.   `phone_number` varchar(20) CHARACTER SET latin1 DEFAULT NULL, 
  30.   `create_time` datetime DEFAULT NULL, 
  31.   `update_time` datetime DEFAULT NULL, 
  32.   PRIMARY KEY (`id`) 
  33. ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8; 
  34.   
  35. /*Data for the table `user` */ 
  36.   
  37. insert  into `user`(`id`,`user_name`,`password`,`address`,`phone_number`,`create_time`,`update_time`) values (1,'test','CY9rzUYh03PK3k6DJie09g==','test','test','2014-03-29 00:48:14','2014-03-29 00:48:17'),(2,'te2','CY9rzUYh03PK3k6DJie09g==','asdfk','4156434885','2015-08-05 11:09:29','2015-08-20 11:09:33'); 
  38.   
  39. /*!40101 SET SQL_MODE=@OLD_SQL_MODE */; 
  40. /*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */; 
  41. /*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */; 
  42. /*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */; 
<$xue63fenye$>

我们开始第一个简单的java例子:通过读取properties配置文件。然后获取c3p0的连接。

首先我们准备一个db.properties ,根据自己所需要,修改用户名和密码。

  1. jdbcdriver=com.mysql.jdbc.Driver 
  2. url=jdbc:mysql://localhost:3306/test 
  3. username=root 
  4. password=root 

新建一个类:C3p0Demo1

  1. package day12; 
  2.   
  3. import java.beans.PropertyVetoException; 
  4. import java.io.IOException; 
  5. import java.io.InputStream; 
  6. import java.sql.Connection; 
  7. import java.sql.PreparedStatement; 
  8. import java.sql.ResultSet; 
  9. import java.sql.SQLException; 
  10. import java.util.Properties; 
  11.   
  12. import javax.sql.DataSource; 
  13.   
  14. import org.junit.Test; 
  15.   
  16. import com.mchange.v2.c3p0.ComboPooledDataSource; 
  17.   
  18. public class C3p0Demo1 { 
  19.     @Test 
  20.     public void getConnection() throws IOException, PropertyVetoException, SQLException 
  21.     { 

  1. <span style="white-space:pre">  </span>//首先读取配置文件信息,以供配置c3p0所用 
  2.         Properties prop = new Properties(); 
  3.         InputStream in = C3p0Demo1.class.getClassLoader().getResourceAsStream("db.properties"); 
  4.         prop.load(in);//加载信息 
  5.           
  6.         ComboPooledDataSource comb = new ComboPooledDataSource();//下面就是开始配置 
  7.         comb.setDriverClass(prop.getProperty("jdbcdriver")); 
  8.         comb.setJdbcUrl(prop.getProperty("url")); 
  9.         comb.setUser(prop.getProperty("jdbc:mysql://localhost:3306/test")); 
  10.         comb.setPassword(prop.getProperty("root")); 
  11.           
  12.         Connection con = comb.getConnection();//从c3p0拿一条鱼,啊呸!什么鱼啊,拿一条数据库连接 
  13.         //执行查询语句 
  14.         String sql = "select * from user"; 
  15.         PreparedStatement ps = con.prepareStatement(sql); 
  16.         ResultSet rs = ps.executeQuery(); 
  17.         //打印数据库信息 
  18.         while(rs.next()) 
  19.         { 
  20.             System.out.println(rs.getString(1)); 
  21.             System.out.println(rs.getString(2)); 
  22.             System.out.println(rs.getString(3)); 
  23.             System.out.println(rs.getString(5)); 
  24.             System.out.println(rs.getString(6)); 
  25.             System.out.println(rs.getString(7));  
  26.         } 
  27.           
  28.         //关闭连接 
<$xue63fenye$>

con.close();//这是啥,这是把连接还给连接池,而不是关闭连接in.close();comb.close();rs.close();ps.close();} }

第二种方法:(类似于,但更简洁)

我们需要新建一个配置文件:c3p0.properties (注意:名字是固定的。c3p0默认只认识这个名字)

  1. c3p0.driverClass=com.mysql.jdbc.Driver 
  2. c3p0.jdbcUrl=jdbc:mysql://localhost:3306/test 
  3. c3p0.user=root 
  4. c3p0.password=root 

OK!我们新建一个类:C3p0Demo2

  1. package day12; 
  2.   
  3. import java.beans.PropertyVetoException; 
  4. import java.io.IOException; 
  5. import java.io.InputStream; 
  6. import java.sql.Connection; 
  7. import java.sql.PreparedStatement; 
  8. import java.sql.ResultSet; 
  9. import java.sql.SQLException; 
  10. import java.util.Properties; 
  11.   
  12. import javax.sql.DataSource; 
  13.   
  14. import org.junit.Test; 
  15.   
  16. import com.mchange.v2.c3p0.ComboPooledDataSource; 
  17.   
  18. public class C3p0Demo2 { 
  19.       
  20.     @Test 
  21.     public void getConByC3P0() throws SQLException 
  22.     { 
  23.         DataSource ds = new ComboPooledDataSource();//c3p0自己去读配置文件了,我们啥也不干 
  24.           
  25.         Connection con = ds.getConnection();//我们直接拿一条鱼 
  26.         System.out.println("con:"+con); 
  27.           
  28.         String sql = "select * from user"; 
  29.         PreparedStatement ps = con.prepareStatement(sql); 
  30.         ResultSet rs = ps.executeQuery(); 
  31.           
  32.         while(rs.next()) 
  33.         { 
  34.             System.out.println(rs.getString(1)); 
  35.             System.out.println(rs.getString(2)); 
  36.             System.out.println(rs.getString(3)); 
  37.             System.out.println(rs.getString(5)); 
  38.             System.out.println(rs.getString(6)); 
  39.             System.out.println(rs.getString(7));  
  40.         } 
  41.           
  42.         //关闭连接 
  43.            
  44.         con.close();//这是啥,这是把连接还给连接池,而不是关闭连接 
  45.         rs.close(); 
  46.         ps.close(); 
  47.     } 
<$xue63fenye$>

根据您访问的内容,您可能还对以下内容感兴趣,希望对您有帮助:

C++哪里有真正可用的数据库连接池

答:数据库连接池存于客户端内部客户端连接数据库提高效率种式 基本原理客户端初始化性建立N数据库链接需要访问数据库通getConnection获取现连接重新建链releaseConnection 实际没断跟数据库链接放链接池内!

用C3P0做数据库连接池,在Tomcat运行项目中运行项...

答:我觉得是jdbc无法关闭,所以tomcat强制关闭导致的,据说这是basicdatasource的bug可以重写一下close方法 public class XBasicDataSource extends BasicDataSource { @Override public synchronized void close() throws SQLException { DriverMa...

C++ socket连接池 TCP

答:可以参看如下代码,不过多线程函数要自己写了,程序的核心功能是线程池 DWORD WINAPI start2connect(LPVOID); int main(int argc,char * argv[]) { //初始化Winsock WSADATA wsaDATA; WORD version = MAKEWORD(2, 0); int ret = WSAStartup(vers...

5.下面关于数据库连接池说法有错的是()。

答:5b6b7c8c

[高分求助!!]关于mysql C API连接池的问题

答:没人回答...算了,自己收分!

用pro*c/c++ 和qt creator工具让C++连接Oracle数据...

答:数据库连接作为一种资源,我们的应用必须对之进行行之有效的管理。我们在访问数据库的时候,一般传统上采用先建立连接,然后使用该连接访问数据库,在使用完毕后,关闭该连接。这是我们经常采用的方法。该方法的好处是使用简单,不用对连接进行...

用tomcat连接oracle的连接池需要的jar包要几个?

答:就需要一个"ojdbc.jar"。ojdbc的不同版本主要是为了匹配不同的jdk版本环境,和tomcat没关系。 “ojdbc5.jar”,适用于jdk5.0。 “ojdbc6.jar”, 适用于jdk6.0。 “ojdbc14.jar”,适用于 JDK 1.4 and 5.0。 备注:jdk高版本的话,可以用”ojdbc6.jar“...

tomcat 7,mysql,intelliJ IDEA,jsp ....实现数据...

答:把换成下面的试试:

tomcat连接池中连接的重用是什么意思,能否举个例...

答:tomcat中的几种连接池配置代码 对于大型网站来说,信息查询的次数会非常多,每次查询都需要这样的过程:加载驱动程序、创建连接、创建语句对象、执行SQL语句、关闭这些对象。建立与数据库之间的连接和释放连接会占用很多系统的时间。如果能够让...

mongodb c driver的怎么实现断线重新连接

答:MongoDB2.6的CXX驱动(mongo-cxx-driver-26compat),内置包含了数据库连接池,方便管理数据库连接,但是官方文档说的比较晦涩,新手入门往往不知道怎样使用连接池获取数据库连接。本文简单介绍如何使用基本的连接池。 首先要明确的一点是,虽然...


www.xue163.net true http://www.xue163.net/exploit/184/1843324.html report 33606 数据库连接池之c3p0入门,C3P0是一个开源的JDBC连接池,它实现了数据源和JNDI绑定,支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有Hibernate,Spring等。如果你不知道什么是连接池,可以先去百度一下。我理解的呢,就是一个大水池,里面有很多鱼...
网友评论
最新添加资讯
24小时热门资讯
娱乐时尚
科技资讯
历史文化
真视界
旅游美食
精彩图文
我爱我车
母婴健康
关于本站 | 广告服务 | 手机版 | 商务合作 | 免责申明 | 招聘信息 | 联系我们
Copyright © 2004-2018 xue163.net All Rights Reserved. 学网 版权所有
京ICP备10044368号-1 京公网安备11010802011102号
教育考试: 学历财经建筑 医药公考资格外语电脑作文招聘中小学留学 文档 移民 文库专栏23问答中心问答图书馆知识IT编程数码信息解决方案信息中心IT科技topzttophottopsctopnew问答新闻中心软件教室设计大全网络相关英语学习开发编程考试中心参考范文管理文库营销中心站长之家IT信息中心商学院数码大全硬件DIY企业服务网吧在线百科硬件知识手机平板汽车游戏家电精彩摄影现代家居IT女人经验健康养生猎奇创业攻略教育学习历史时尚潮流最近更新涨知识