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

来源: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
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類