java數據庫連接池技術簡單使用

阿新 • • 發佈：2017-05-07

util mysql 一個 dsta getc lean 創建 gin eat

JDBCDemo.java：
package com.itheima.jdbc;

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

import com.itheima.pool.MyPool;

public class JDBCDemo {

	public static void main(String[] args) {
		
		Connection conn = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		MyPool pool = new MyPool();
		try {
			conn = pool.getConnection();
			ps = conn.prepareStatement("select * from account");
			rs = ps.executeQuery();
			while(rs.next()) {
				String name = rs.getString(2);
				String salary = rs.getString(3);
				System.out.println(name + " : " + salary);
			}
		} catch (Exception e) {
			e.printStackTrace();
			throw new RuntimeException(e);
		} finally {
			//關閉數據庫連接
			if(rs != null) {
				try {
					rs.close();
				} catch (SQLException e) {
					rs = null;
				}
			}
			if(ps != null) {
				try {
					ps.close();
				} catch (SQLException e) {
					ps = null;
				}
			}
			/*
			if(rs != null) {
				try {
					rs.close();
				} catch (SQLException e) {
					rs = null;
				}
			}
			*/
			//這裏不能關閉數據庫連接對象connection，應該將其返還給數據庫連接池
			pool.returnConn(conn);
		}
	}
}

MyPool.java：

package com.itheima.pool;

import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.SQLFeatureNotSupportedException;
import java.util.LinkedList;
import java.util.List;
import java.util.logging.Logger;

import javax.sql.DataSource;

public class MyPool implements DataSource{

	//list集合保存數據庫連接池中的connection對象
	private static List<Connection> pool = new LinkedList<Connection>();
	//靜態代碼塊。用於初始化list集合。即初始化數據庫連接池，創建5個connection對象保存當中以備使用
	static {
		try {
			Class.forName("com.mysql.jdbc.Driver");
			for(int i = 0; i < 5; i++) {
				Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day11", "root", "root");
				pool.add(conn);
			}
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
			throw new RuntimeException(e);
		} catch (SQLException e) {
			e.printStackTrace();
			throw new RuntimeException(e);
		}
	}
	@Override
	public PrintWriter getLogWriter() throws SQLException {
		return null;
	}
	@Override
	public void setLogWriter(PrintWriter out) throws SQLException {
	}
	@Override
	public void setLoginTimeout(int seconds) throws SQLException {
	}
	@Override
	public int getLoginTimeout() throws SQLException {
		return 0;
	}
	@Override
	public Logger getParentLogger() throws SQLFeatureNotSupportedException {
		return null;
	}
	@Override
	public <T> T unwrap(Class<T> iface) throws SQLException {
		// TODO Auto-generated method stub
		return null;
	}

	@Override
	public boolean isWrapperFor(Class<?> iface) throws SQLException {
		// TODO Auto-generated method stub
		return false;
	}

	//重寫父類的getConnection()方法，返回數據庫連接池中的一個connection對象。
	//假設數據庫連接池中connection對象都已被使用。即都被取走未返還,則創建3個connection對象保存當中供以後使用
	@Override
	public Connection getConnection() throws SQLException {
		if(pool == null) {
			for(int i = 0; i < 3; i++) {
				Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day11", "root", "root");
				pool.add(conn);
			}
		}
		return pool.remove(0);
	}
	//創建新方法。用於返回數據庫連接對象connection。由於dao層用完數據庫的連接後，不應該將其銷毀，而是應該將其返還給數據庫連接池
	public void returnConn(Connection conn) {
		pool.add(conn);
	}
	@Override
	public Connection getConnection(String username, String password)
			throws SQLException {
		// TODO Auto-generated method stub
		return null;
	}

	
}

以上代碼是數據庫連接池的簡單使用，可是有一個問題就是當你使用數據庫連接池技術時，你須要改動JDBCDemo.java文件裏finally代碼塊中的代碼，即conn對象在finally代碼塊裏不應該通過conn.close();方法關閉，而是應該返還給數據庫連接池。

這裏我們採用“動態代理”的方式，解決該問題，即finally代碼塊裏依舊調用conn.close();方法。

此時以上兩個java文件的代碼更改例如以下：

package com.itheima.jdbc;

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

import com.itheima.pool.MyPool;

public class JDBCDemo {

	public static void main(String[] args) {
		
		Connection conn = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		MyPool pool = new MyPool();
		try {
			conn = pool.getConnection();
			ps = conn.prepareStatement("select * from account");
			rs = ps.executeQuery();
			while(rs.next()) {
				String name = rs.getString(2);
				String salary = rs.getString(3);
				System.out.println(name + " : " + salary);
			}
		} catch (Exception e) {
			e.printStackTrace();
			throw new RuntimeException(e);
		} finally {
			//關閉數據庫連接
			if(rs != null) {
				try {
					rs.close();
				} catch (SQLException e) {
					rs = null;
				}
			}
			if(ps != null) {
				try {
					ps.close();
				} catch (SQLException e) {
					ps = null;
				}
			}
			if(conn != null) {
				try {
					conn.close();
				} catch (SQLException e) {
					conn = null;
				}
			}
		}
	}
}

package com.itheima.pool;

import java.io.PrintWriter;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.SQLFeatureNotSupportedException;
import java.util.LinkedList;
import java.util.List;
import java.util.logging.Logger;

import javax.sql.DataSource;

public class MyPool implements DataSource{

	//list集合保存數據庫連接池中的connection對象
	private static List<Connection> pool = new LinkedList<Connection>();
	//靜態代碼塊，用於初始化list集合，即初始化數據庫連接池，創建5個connection對象保存當中以備使用
	static {
		try {
			Class.forName("com.mysql.jdbc.Driver");
			for(int i = 0; i < 5; i++) {
				Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day11", "root", "root");
				pool.add(conn);
			}
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
			throw new RuntimeException(e);
		} catch (SQLException e) {
			e.printStackTrace();
			throw new RuntimeException(e);
		}
	}
	@Override
	public PrintWriter getLogWriter() throws SQLException {
		return null;
	}
	@Override
	public void setLogWriter(PrintWriter out) throws SQLException {
	}
	@Override
	public void setLoginTimeout(int seconds) throws SQLException {
	}
	@Override
	public int getLoginTimeout() throws SQLException {
		return 0;
	}
	@Override
	public Logger getParentLogger() throws SQLFeatureNotSupportedException {
		return null;
	}
	@Override
	public <T> T unwrap(Class<T> iface) throws SQLException {
		// TODO Auto-generated method stub
		return null;
	}

	@Override
	public boolean isWrapperFor(Class<?> iface) throws SQLException {
		// TODO Auto-generated method stub
		return false;
	}

	//重寫父類的getConnection()方法。返回數據庫連接池中的一個connection對象，
	//假設數據庫連接池中connection對象都已被使用。即都被取走未返還,則創建3個connection對象保存當中供以後使用
	@Override
	public Connection getConnection() throws SQLException {
		if(pool == null) {
			for(int i = 0; i < 3; i++) {
				Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day11", "root", "root");
				pool.add(conn);
			}
		}
		final Connection conn = pool.remove(0);
		
		//使用動態代理改造close方法
		//newProxyInstance(類載入器, 要改造的conn對象所實現的全部接口,  匿名內部類)
		Connection proxy = (Connection) Proxy.newProxyInstance(conn.getClass().getClassLoader(), conn.getClass().getInterfaces(), new InvocationHandler() {
			
			@Override
			public Object invoke(Object proxy, Method method, Object[] args)
					throws Throwable {
				if("close".equals(method.getName())) {
					//假設是close方法。我們進行重寫
					returnConn(conn);
					return null;
				} else {
					//假設是其它方法，直接調用
					return method.invoke(conn, args);
				}
			}
		});
		System.out.println("獲取一個連接對象,剩余連接對象：" + pool.size());
		return proxy;
	}
	//創建新方法，用於返回數據庫連接對象connection，由於dao層用完數據庫的連接後，不應該將其銷毀，而是應該將其返還給數據庫連接池
	public void returnConn(Connection conn) {
		pool.add(conn);
		System.out.println("返還一個連接對象,剩余連接對象：" + pool.size());
	}
	@Override
	public Connection getConnection(String username, String password)
			throws SQLException {
		// TODO Auto-generated method stub
		return null;
	}

	
}

執行結果：

獲取一個連接對象,剩余連接對象：4
a : 1000.0
b : 1000.0
c : 1000.0
返還一個連接對象,剩余連接對象：5

java數據庫連接池技術簡單使用

util mysql 一個 dsta getc lean 創建 gin eat JDBCDemo.java： package com.itheima.jdbc; import java.sql.Connection; import java.sql.PreparedS

Java數據庫連接池實現原理

fix 獲取時有 .get soft div port 構造定義一般來說，Java應用程序訪問數據庫的過程是：　　①裝載數據庫驅動程序；　　②通過jdbc建立數據庫連接；　　③訪問數據庫，執行sql語句；　　④斷開數據庫連接。 [java] v

[數據庫連接池] Java數據庫連接池--DBCP淺析.

resource contex destroy 代碼 its cat data active 驗證前言對於數據庫連接池, 想必大家都已經不再陌生, 這裏僅僅設計Java中的兩個常用數據庫連接池: DBCP和C3P0(後續會更新). 一. 為何要使用數據庫連接池假設網站一

數據庫連接池技術

管理機超過等待隊列優勢初始化連接數量占用斷開 http 一、基本原理連接池基本的思想是在系統初始化的時候，將數據庫連接作為對象存儲在內存中，當用戶需要訪問數據庫時，並非建立一個新的連接，而是從連接池中取出一個已經建立的空閑連接對象。使用完畢後，用戶也並非將連

DBCP數據庫連接池的簡單使用

load === get spa lips trac 獲取 return 復用 0、DBCP簡介 DBCP(DataBase connection pool)數據庫連接池是 apache 上的一個Java連接池項目。DBCP通過連接池預先同數據庫建立一些連接放在內

簡單的數據庫連接池實例(java語言)

proxy read public ++ load empty 返回 not 超時 1.概述頻繁的創建和銷毀數據庫連接消耗非常多的系統資源，創建一個池子，管理一定數量的連接，用的時候去池中取，用完了放回池中，這時比較通用的做法。 2.關鍵字 LinkedList

Java中Semaphore(信號量) 數據庫連接池

each jdb 同步方法 [] pop 線程 emp use builder 計數信號量用來控制同時訪問某個特定資源的操作數或同時執行某個指定操作的數量 A counting semaphore.Conceptually, a semaphore maintains a

java常用數據庫連接池 (DBCP、c3p0、Druid) 配置說明

clu special access etime have started 組件 flags 最小 1. 引言 1.1 定義數據庫連接是一種關鍵的有限的昂貴的資源，這一點在多用戶的網頁應用程序中體現得尤為突出。對數據庫連接的管理能顯著影響到整個應用程序的伸縮性和健壯性，影

Java Web（五） -- 事務 & 數據庫連接池 & DBUtiles

ML run count() lis into 銀行定義數據 dao util #事務&數據庫連接池&DBUtils ##事務 > Transaction 其實指的一組操作，裏面包含許多個單一的邏輯。只要有一個邏輯沒有執行成功，那麽都算失敗。

Java 中數據庫連接池的比較

alt -c com ace inf image 圖片 wid aso 見原文 Java 中數據庫連接池的比較

2018-07-24期 Java動態代理實現數據庫連接池

iter 異常 ... lse system com link 是我 driver package cn.sjq.proxy.ds.pool;import java.io.PrintWriter;import java.lang.reflect.InvocationHand

【java】簡單實現數據庫連接池

zed cal lean jdbc stat eof LEDE import thread 一直在想java事務是怎麽實現的，在原聲jdbc的時候級別下，我們可以通過關掉autocommit 然後再手動commit。但是項目開發中基本上是看不見conection的。所以自己

初識數據庫連接池開源框架Druid

數據庫連接Druid是阿裏巴巴的一個數據庫連接池開源框架，準確來說它不僅僅包括數據庫連接池這麽簡單，它還提供強大的監控和擴展功能。本文僅僅是在不采用Spring框架對Druid的窺探，采用目前最新版本druid1.0.26 github地址：https://github.com/alibaba/druid。在

實現數據庫連接池

tinc port 一次通過所有 name 不能註冊失敗　　文件ConnectionParam.java package exam.Util.DButil; public class ConnectionParam { private String d

如何查看IIS與MSSQL數據庫連接池

nor 進程 for 打開數據庫實例 window border ima mas 1、打開IIS服務器windows任務管理器，進程，找到對應進程的PID，如下圖； 2、打開dos命令提示符窗口，輸入netstat –ano |findstr “6408” >

Spring Boot入門第三天：配置日誌系統和Druid數據庫連接池。

禁用 css ret 輸入 ogg servlet log http gif 一、日誌管理 1.在application.properties文件中加入如下內容： logging.level.root=WARN logging.level.org.springfram

c3p0 數據庫連接池

mat cti bsp edm debug nsa prepare abs ins 一直用c3p0很久了，但也沒時間或沒主動去研究過，直到最近頻頻在出現一些莫名其妙的問題，覺得還是有必要了解和研究一下。 c3p0是什麽　　c3p0的出現，是為了大大提高

Java數據庫連接——jdbc-odbc橋連接方式

exe bsp cdr oid if語句 tac 管理工具 for prepare jdbc-odbc橋連接方式操作數據庫SU（Course）步驟： 1、配置數據源控制面板下搜索管理工具->ODBC數據源(32位)->添加->選擇sql server(

13.數據庫連接池

默認 quick 選擇變量修改 bcp inf 包裝一次 /*使用數據庫連接池優化程序性能*/ 一次性從數據庫中拿出一定數量的連接，放到一個池子中，每次程序要拿連接的時候，從這個池子裏面去拿，用完了，也是放到這個池子裏，避免頻繁的從數據庫中去存取連接編寫自己

Python數據庫連接池實例——PooledDB

fetch 單位 har 連接池 too lba locking als com 不用連接池的MySQL連接方法 import MySQLdbconn= MySQLdb.connect(host=‘localhost‘,user=‘root‘,passwd=‘pwd‘,

java數據庫連接池技術簡單使用

相關推薦