成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

數據庫連接池之c3p0入門

數據庫
  C3P0是一個開源的JDBC連接池,它實現了數據源和JNDI綁定,支持JDBC3規范和JDBC2的標準擴展。目前使用它的開源項目有Hibernate,Spring等。

  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.   `passwordvarchar(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 */; 

 

  我們開始***個簡單的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.         //關閉連接 

 

  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.     } 

 

責任編輯:honglu 來源: 紅黑聯盟/c3p0
相關推薦

2018-07-20 14:50:43

Java數據庫連接池

2009-09-22 17:53:09

Hibernate C

2020-03-04 13:55:28

c3p0數據庫連接池

2009-07-15 11:14:30

c3p0連接池

2021-05-12 07:32:58

數據庫C3P0項目

2009-09-22 14:44:18

Hibernate.c

2013-06-17 10:25:16

連接池Java

2009-06-24 07:53:47

Hibernate數據

2022-07-19 13:51:47

數據庫Hikari連接池

2015-04-27 09:50:45

Java Hibern連接池詳解

2010-03-18 15:09:15

python數據庫連接

2009-08-10 17:34:42

C#數據庫連接池

2017-06-22 14:13:07

PythonMySQLpymysqlpool

2019-11-27 10:31:51

數據庫連接池內存

2009-06-17 09:34:31

Hibernate3Hibernate2連接池

2009-06-16 09:25:31

JBoss配置

2009-09-22 14:52:55

Hibernate p

2021-08-12 06:52:01

.NET數據庫連接池

2020-04-30 14:38:51

數據庫連接池線程

2018-10-10 14:27:34

數據庫連接池MySQL
點贊
收藏

51CTO技術棧公眾號

主站蜘蛛池模板: 91精品国产777在线观看 | 91精品国产91久久综合桃花 | 嫩草一区二区三区 | 精品免费国产一区二区三区四区 | 国产免费观看一级国产 | 欧美久久久久久久久中文字幕 | 亚洲国产精品久久久久秋霞不卡 | 免费观看黄色一级片 | 91视频久久| 成人精品在线视频 | 久久精品 | 国产成人免费视频网站高清观看视频 | 中文字幕免费在线观看 | 欧美bondage紧缚视频 | 三级高清| 国产一区二区电影 | 一区二区日韩 | www.久久精品 | www.亚洲精品 | 91国内外精品自在线播放 | 久久久av一区 | 久久综合一区二区 | 欧美激情一区二区 | 免费观看一级视频 | 成人免费一区二区三区视频网站 | 精品一二三区视频 | 国产精品一区二区欧美黑人喷潮水 | 一区二区三区四区国产 | 一级a性色生活片久久毛片 一级特黄a大片 | 久久久久久免费观看 | 黄色免费在线观看网站 | 五月激情综合 | 免费欧美| 91精品一区| 一区二区成人 | 精品国产不卡一区二区三区 | 亚洲精品黑人 | 亚洲人成人一区二区在线观看 | 亚洲毛片在线观看 | 成人区精品一区二区婷婷 | 日本大香伊一区二区三区 |