資料庫連接池兩種配置方式詳解

来源:http://www.cnblogs.com/julinhuitianxia/archive/2017/05/09/6832593.html
-Advertisement-
Play Games

資料庫連接池: 負責分配、管理和釋放資料庫連接，它允許應用程式重覆使用一個現有的資料庫連接，而再不是重新建立一個；釋放空閑時間超過最大空閑時間的資料庫連接來避免因為沒有釋放資料庫連接而引起的資料庫連接遺漏；資料庫連接池原理: 連接池基本的思想是在系統初始化的時候，將資料庫連接作為對象存儲在記憶體中，當 ...


資料庫連接池:
   負責分配、管理和釋放資料庫連接，它允許應用程式重覆使用一個現有的資料庫連接，而再不是重新建立一個；釋放空閑時間超過最大空閑時間的資料庫連接來避免因為沒有釋放資料庫連接而引起的資料庫連接遺漏；
資料庫連接池原理:
   連接池基本的思想是在系統初始化的時候，將資料庫連接作為對象存儲在記憶體中，當用戶需要訪問資料庫時，並非建立一個新的連接，而是從連接池中取出一個已建立的空閑連接對象。使用完畢後，用戶也並非將連接關閉，而是將連接放回連接池中，以供下一個請求訪問使用。而連接的建立、斷開都由連接池自身來管理。同時，還可以通過設置連接池的參數來控制連接池中的初始連接數、連接的上下限數以及每個連接的最大使用次數、最大空閑時間等等；
分類：
1.Tomcat數據源連接池，依賴於web容器tomcat伺服器，採用java的JNDI獲取DataSource對象；
2.C3P0是一個開放源代碼的JDBC連接池，它在lib目錄中與Hibernate一起發佈,包括了實現jdbc3和jdbc2擴展規範說明的Connection 和Statement 池的DataSources 對象；
3.DBCP DBCP是一個依賴commons-pool對象池機制的資料庫連接池，DBCP可以直接的在應用程式用使用；
方式：

一傳統方式：
tomcat資料庫連接池配置：
1）首先將連接資料庫jar包拷貝到tomcat下的lib文件夾下；
2）更改tomcat/conf/context.xml文件，加入數據源配置；

<Resource name="myshop" auth="Container" type="javax.sql.DataSource" maxActive="25" maxIdle="3" maxWait="10000"
    username="sa" password="sa" driverClassName="com.microsoft.sqlserver.jdbc.SQLServerDriver"
    url="jdbc:sqlserver://localhost:1433;databaseName=yun4jbook"    />

首先利用tomcat的web管理配置數據源，resource配置項中屬性說明：  

 name：數據源連接池命名   

url：連接資料庫的URL

driverClassName： 資料庫驅動類
username：資料庫的用戶名 
password：是資料庫的密碼  

maxActive : 最大的活動連接數  

maxIdle：最大的空閑連接數

maxWait： 最大的等待時間，毫秒為單位
type：resource所屬的java類名
auth:指定由誰管理數據源

Container表示由容器管理
3）打開項目的web.xml加入數據源的配置；

<resource-ref>
        <!-- name屬性必須放在第一位 -->
        <res-ref-name>myshop</res-ref-name>
        <res-type>javax.sql.DataSource</res-type>
        <res-auth>Container</res-auth>
    </resource-ref>

4）編寫dao代碼，使用JNDI（java naming and Directory Interface）技術取得數據源以數據源的形式操作資料庫；

package com.jinzhi.db;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;

/**
 * 2017-5-9
 * @author lin
 *
 */
public class DBManager {
	//上下文關係對象
	private static Context context;
	//數據源
	private static DataSource ds;
	//資料庫連接對象
	private Connection conn;
	//資料庫sql語句預編譯對象
	private PreparedStatement ps; 
	//查詢結果集
	protected ResultSet rs;
	/**
	 * 連接池負責連接資料庫
	 */
	static{
		try {
			context = new InitialContext();
			ds = (DataSource) context.lookup("java:comp/env/myshop");
		} catch (NamingException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	{
		System.out.println("aa");
	}
	
	/**
	 * 獲得connection對象
	 * @return
	 */
	public Connection getConn(){
//		try {
//			Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
//			conn = DriverManager.getConnection("jdbc:sqlserver://localhost:1433;dataBaseName=yun4jbook", "sa", "sa");
//		} catch (ClassNotFoundException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		} catch (SQLException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
		try {
			conn = ds.getConnection();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return conn;
	}
	/**
	 * 關閉資料庫方法
	 */
	public void closeAll(){
		
		try {
			if(null!=rs){
				rs.close();
			}
			if(null!=ps){
				ps.close();
			}
			if(null!=conn){
				conn.close();
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	/**
	 * 查詢結果集
	 * 註意：查詢結果集時不能關閉資料庫連接，否則拿不到連接
	 * @param sql
	 * @param obj
	 * @return
	 */
	public ResultSet query(String sql,Object [] obj){
		conn = getConn();
		try {
			ps = conn.prepareStatement(sql);
			if(obj!=null&&obj.length>0){
				for (int i = 0; i < obj.length; i++) {
					ps.setObject(i+1, obj[i]);
				}
				
			}
			rs = ps.executeQuery();
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return rs;
	}
	
	/**
	 * 更新數據的方法
	 * 註意：更新數據後應該關閉資料庫連接
	 * @param sql
	 * @param obj
	 * @return
	 */
	public int update(String sql,Object [] obj){
		conn = getConn();
		int count = 0;
		try {
			ps = conn.prepareStatement(sql);
			if(obj!=null&&obj.length>0){
				for (int i = 0; i < obj.length; i++) {
					ps.setObject(i+1, obj[i]);
				}
			}
			count = ps.executeUpdate();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			closeAll();
		}
		return count;
	}
	
	/**
	 * 重寫了connection方法
	 * @param conn
	 * @param sql
	 * @param obj
	 * @return
	 * @throws SQLException
	 */
	public ResultSet queryNotClose(Connection conn,String sql,Object [] obj) throws SQLException{
		
		ps = conn.prepareStatement(sql);
		if(obj!=null&&obj.length>0){
			for (int i = 0; i < obj.length; i++) {
				ps.setObject(i+1, obj[i]);
			}
			
		}
		rs = ps.executeQuery();
		return rs;
	}
	
	/**
	 * 為後期保證操作在一個事務中，重寫了update方法，添加了connection
	 * @param conn
	 * @param sql
	 * @param obj
	 * @return
	 * @throws SQLException
	 */
	public int updateNotClose(Connection conn,String sql,Object [] obj) throws SQLException{
		int count = 0;
		ps = conn.prepareStatement(sql);
		if(obj!=null&&obj.length>0){
			for (int i = 0; i < obj.length; i++) {
				ps.setObject(i+1, obj[i]);
			}
		}
		count = ps.executeUpdate();
		return count;
	}
	
	/**
	 * 測試方法
	 * @param args
	 */
	public static void main(String[] args) {
		DBManager db = new DBManager();
		System.out.println(db.getConn());
	}
}

 二.Druid方式：
1.druid-0.2.15.jar包
2.編寫一個xx.properties文件

下麵是一個oracle的配置文件

url = jdbc:oracle:thin:@127.0.0.1:1521/orcl
username = detection1
password = detection1
initialSize = 5
maxActive = 10
minIdle = 3
maxWait = 60000
removeAbandoned = true
removeAbandonedTimeout = 180
timeBetweenEvictionRunsMillis = 60000
minEvictableIdleTimeMillis = 300000
testWhileIdle = true 
testOnBorrow = false
testOnReturn = false
poolPreparedStatements = true
maxPoolPreparedStatementPerConnectionSize = 50
filters = stat

3.連接資料庫

package testDruid;

import java.io.InputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Properties;

import javax.sql.DataSource;

import com.alibaba.druid.pool.DruidDataSourceFactory;

public class OracleDB {

	private static DataSource ds = null;	
	
	private PreparedStatement ps;
	
	private ResultSet rs;
	
	private Connection conn;
	
	
	static {
		try{
				//讀取配置文件oracle.properties
			InputStream in = OracleDB.class.getClassLoader()
					               .getResourceAsStream("oracle.properties");
            Properties props = new Properties();
       //載入配置文件
			props.load(in);
			//創建數據源
			ds = DruidDataSourceFactory.createDataSource(props);
		}catch(Exception ex){
			ex.printStackTrace();
		}
	}
	//得到資料庫連接對象
	public Connection openConnection() throws SQLException{
		return ds.getConnection();
	}	

	//得到查詢結果集
	public ResultSet find(String sql,Object...objects){
		try {
			conn = ds.getConnection();
			ps = conn.prepareStatement(sql);
			if(objects!=null&&objects.length>0){
				for (int i = 0; i < objects.length; i++) {
					ps.setObject(i+1, objects[i]);
				}
			}
			rs = ps.executeQuery();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return rs;
	}
	//進行數據更新
	public int update(String sql,Object...objects){
		int count = 0;
		try {
			conn = ds.getConnection();
			ps = conn.prepareStatement(sql);
			if(objects!=null&&objects.length>0){
				for (int i = 0; i < objects.length; i++) {
					ps.setObject(i+1, objects[i]);
				}
			}
			count = ps.executeUpdate();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return count;
	}
	//關閉資料庫連接
	public void close(){
		try {
			if(rs!=null){
				rs.close();
			}
			if(ps!=null){
				ps.close();
			}
			if(conn!=null){
				conn.close();
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
}

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Spring Session實現分散式session的簡單示例
    前面有用 tomcat-redis-session-manager來實現分散式session管理，但是它有一定的局限性，主要是跟tomcat綁定太緊了，這裡改成用Spring Session來管理分散式session，Spring Session就完全實現了與具體的容器無關，如果需要瞭解如何用tom ...
  • linux環境下編譯php擴展
    1、使用ext_skel工具生成擴展框架 ./ext_skel --extname=myext 2、編輯config.m4文件 cd myext/vim config.m4 3、php化並配置phpize5 ./configure --with-php-config=/usr/bin/php-con ...
  • Java—IO流 位元組流
    IO流（輸入流、輸出流），又分為位元組流、字元流。 流是磁碟或其它外圍設備中存儲的數據的源點或終點。 輸入流：程式從輸入流讀取數據源。數據源包括外界(鍵盤、文件、網路…)，即是將數據源讀入到程式的通信通道。 輸出流：程式向輸出流寫入數據。將程式中的數據輸出到外界（顯示器、印表機、文件、網路…）的通信通 ...
  • volatile關鍵字
    一、基本概念 volatile作為Java虛擬機提供的最輕量級同步機制，用於保證共用變數在多線程的情況下各線程獲取相同，不出現對該變數的操作和其他記憶體操作一樣重排序。 重排序 在虛擬機上，由於記憶體操作速度遠小於CPU的操作速度，為了減少CPU在等待記憶體操作過程的時間，虛擬機會按照一定規則打亂指令的執 ...
  • python第七天-作業[購物車]
    作業要示: 購物車程式：啟動程式後，輸入用戶名密碼後，如果是第一次登錄，讓用戶輸入工資，然後列印商品列表允許用戶根據商品編號購買商品用戶選擇商品後，檢測餘額是否夠，夠就直接扣款，不夠就提醒 可隨時退出，退出時，列印已購買商品和餘額在用戶使用過程中， 關鍵輸出，如餘額，商品已加入購物車等消息，需高亮顯 ...
  • 鏈表
    與順序表相同，鏈表也是一種線性表，它的數據邏輯組織形式是一維的。而與順序表不同的是，鏈表的物理存儲結構是用一組地址任意的存儲單元存儲數據的。也就是說，它不像鏈表一樣占據一段連續的記憶體空間，而是將存儲單元分散在記憶體的任意地址上。在鏈表結構中，每一個數據元素記錄都存放在鏈表的一個結點中（node）,而每 ...
  • java泛型探索——小特性
    泛型特性（小篇幅） 1. 補充介紹一些常見的泛型特性： 類型參數T可以是recursive（類似遞歸性），它的邊界可以是類型參數是自身的介面或類。 如我實現尋找最大值的方法，可以這麼寫: 泛型多邊界（Multiple Bounds） 2. Bridges特性 對於泛型介面而言，如Comparable ...
  • Leetcode: 30. Substring with Concatenation of All Words
    You are given a string, s, and a list of words, words, that are all of the same length. Find all starting indices of substring(s) in s that is a conca... ...
一周排行
    -Advertisement-
    Play Games
  • C# + WPF 音頻播放器 界面優雅，體驗良好
    前言 本文介紹一款使用 C# 與 WPF 開發的音頻播放器，其界面簡潔大方，操作體驗流暢。該播放器支持多種音頻格式（如 MP4、WMA、OGG、FLAC 等），並具備標記、實時歌詞顯示等功能。 另外，還支持換膚及多語言（中英文）切換。核心音頻處理採用 FFmpeg 組件，獲得了廣泛認可，目前 Git ...
  • OAuth2.0授權-gitee授權碼模式
    OAuth2.0授權驗證-gitee授權碼模式 本文主要介紹如何筆者自己是如何使用gitee提供的OAuth2.0協議完成授權驗證並登錄到自己的系統，完整模式如圖 1、創建應用 打開gitee個人中心->第三方應用->創建應用 創建應用後在我的應用界面，查看已創建應用的Client ID和Clien ...
  • FastReport.OpenSource .Net下開源免費報表列印組件
    解決了這個問題：《winForm下，fastReport.net 從.net framework 升級到.net5遇到的錯誤“Operation is not supported on this platform.”》 本文內容轉載自：https://www.fcnsoft.com/Home/Sho ...
  • 如何在 ASP.NET Core Web API 方法執行前後 “偷偷“ 作一些 “壞“ 事？初識 ActionFilterAttribute
    國內文章 WPF 從裸 Win 32 的 WM_Pointer 消息獲取觸摸點繪製筆跡 https://www.cnblogs.com/lindexi/p/18390983 本文將告訴大家如何在 WPF 裡面，接收裸 Win 32 的 WM_Pointer 消息，從消息裡面獲取觸摸點信息，使用觸摸點 ...
  • 在 ASP.NET Core Web API 中使用異常篩選器捕獲和統一處理異常
    前言 給大家推薦一個專為新零售快消行業打造了一套高效的進銷存管理系統。 系統不僅具備強大的庫存管理功能，還集成了高性能的輕量級 POS 解決方案，確保頁面載入速度極快，提供良好的用戶體驗。 項目介紹 Dorisoy.POS 是一款基於 .NET 7 和 Angular 4 開發的新零售快消進銷存管理 ...
  • AbpHelper CLI積累與實戰分享
    ABP CLI常用的代碼分享 一、確保環境配置正確 安裝.NET CLI： ABP CLI是基於.NET Core或.NET 5/6/7等更高版本構建的，因此首先需要在你的開發環境中安裝.NET CLI。這可以通過訪問Microsoft官網下載並安裝相應版本的.NET SDK來實現。 安裝ABP ...
  • 記一次HttpClient使用問題分析
    問題 問題是這樣的：第三方的webapi，需要先調用登陸介面獲取Cookie，訪問其它介面時攜帶Cookie信息。 但使用HttpClient類調用登陸介面，返回的Headers中沒有找到Cookie信息。 分析 首先，使用Postman測試該登陸介面，正常返回Cookie信息，說明是HttpCli ...
  • .NET周刊【9月第3期 2024-09-15】
    國內文章 關於.NET在中國為什麼工資低的分析 https://www.cnblogs.com/thinkingmore/p/18406244 .NET在中國開發者的薪資偏低，主要因市場需求、技術棧選擇和企業文化等因素所致。歷史上，.NET曾因微軟的閉源策略發展受限，儘管後來推出了跨平臺的.NET ...
  • 我的網站集成ElasticSearch初體驗
    在WPF開發應用中，動畫不僅可以引起用戶的註意與興趣，而且還使軟體更加便於使用。前面幾篇文章講解了畫筆（Brush），形狀（Shape），幾何圖形（Geometry），變換（Transform）等相關內容，今天繼續講解動畫相關內容和知識點，僅供學習分享使用，如有不足之處，還請指正。 ...
  • 第23篇 委托的概述
    什麼是委托？ 委托可以說是把一個方法代入另一個方法執行，相當於指向函數的指針；事件就相當於保存委托的數組； 1.實例化委托的方式： 方式1：通過new創建實例： public delegate void ShowDelegate(); 或者 public delegate string ShowDe ...
所有分類