数据库连接池的使用
關于數據庫連接池的使用,首先我們要明白我們為什么要用它,對應普通的數據庫連接操作,通常會涉及到以下一些操作是比較耗時的:
網絡通訊,涉及到網絡延時及協議通訊身份驗證,涉及安全性檢查
連接合法性檢查,主要是檢查所連接的數據庫是否存在
并發控制機制
構造并初始化輸出緩沖區
連接成功后的信息保存,日志存儲
服務器性能
數據庫配置優化
系統分配內存資源
等等~~~狀況,導致數據庫連接操作比較耗時,~~~而且每次都得花費0.05s~1s的時間
但是使用連接池技術,本質上就是在一個請求對應的連接,都由一個線程池來維護著,也就是說“上下文切換”的代價是線程級別(所謂的納秒級),對于大規模的并發訪問,就算以每秒幾億級別的訪問量都是不成問題的。
一、在Java平臺
之前一段時間曾經弄過數據庫連接池,使用的是c3p0這個工具包,
簡單記錄下c3p0的使用,當作學習的一個鞏固;
第一步導入jar包;
第二步:
把jar包導入進來:
import com.mchange.v2.c3p0.ComboPooledDataSource;
import com.mchange.v2.c3p0.DataSources;
第三步:定義變量
private ComboPooledDataSource cpds;?
然后在DbUtil里面使用:
private DbUtil() {?
cpds = new ComboPooledDataSource();
try {
cpds.setDriverClass( driver);
cpds.setJdbcUrl( url );
cpds.setUser(user);?
cpds.setPassword(passwd);?
cpds.setMinPoolSize(5);?
cpds.setAcquireIncrement(5);
cpds.setMaxPoolSize(30);
cpds.setMaxIdleTime(60);
} catch (PropertyVetoException e) {
e.printStackTrace();
}?
}
最后每個連接里面都可以用上了:
public Connection getConn() {?
try {
return cpds.getConnection();
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
完整的使用類:
package util;import java.beans.PropertyVetoException; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement;import com.mchange.v2.c3p0.ComboPooledDataSource; import com.mchange.v2.c3p0.DataSources;public class DbUtil {private static String url = "jdbc:mysql://localhost:3306/zdbang_net";private static String user = "root";private static String passwd = "admin";private static String driver = "com.mysql.jdbc.Driver";private ComboPooledDataSource cpds; private static DbUtil db = new DbUtil();public static DbUtil getInstance() {return db;}private DbUtil() { cpds = new ComboPooledDataSource();try {cpds.setDriverClass( driver);cpds.setJdbcUrl( url );cpds.setUser(user); cpds.setPassword(passwd); cpds.setMinPoolSize(5); cpds.setAcquireIncrement(5);cpds.setMaxPoolSize(30);cpds.setMaxIdleTime(60);} catch (PropertyVetoException e) {e.printStackTrace();} }public Connection getConn() { try {return cpds.getConnection();} catch (SQLException e) {e.printStackTrace();}return null;}protected void finalize() throws Throwable {DataSources.destroy(cpds);super.finalize();}public static void closeConn(Connection conn) {try {if (conn != null)conn.close();} catch (SQLException e) {e.printStackTrace();}}public static Statement getStmt(Connection conn) {Statement stmt = null;try {stmt = conn.createStatement();return stmt;} catch (SQLException e) {e.printStackTrace();}return null;}public static void closeStmt(Statement stmt) {try {if (stmt != null)stmt.close();} catch (SQLException e) {e.printStackTrace();}}public static PreparedStatement getPs(Connection conn, String sql) {PreparedStatement ps = null;try {ps = conn.prepareStatement(sql);return ps;} catch (SQLException e) {e.printStackTrace();}return null;}public static void closePs(PreparedStatement ps) {try {if (ps != null)ps.close();} catch (SQLException e) {e.printStackTrace();}}public static ResultSet doQuery(Statement stmt, String sql) {try {ResultSet rs = stmt.executeQuery(sql);return rs;} catch (SQLException e) {e.printStackTrace();}return null;}public static void closeRs(ResultSet rs) {try {if (rs != null)rs.close();} catch (SQLException e) {e.printStackTrace();}} }具體的源碼還沒具體看,不過估計實現上也不會太難,爭取這段時間看一下源代碼。~~~~~
?二、在.Net
沒有使用數據庫連接池的情況是這樣的:每當一個請求過來根據連接字符串新建一個連接,請求結束,數據庫連接關閉。
例如:
public static int ExecuteSql(string SQLString){using (SqlConnection connection = new SqlConnection(connectionString)){using (SqlCommand cmd = new SqlCommand(SQLString, connection)){try{connection.Open();cmd.CommandTimeout = 600;int rows = cmd.ExecuteNonQuery();return rows;}catch (System.Data.SqlClient.SqlException e){LogHelper.Log("sqlexception;sql:" + SQLString, e);log.Error("\r\n客戶機IP:" + HttpContext.Current.Request.UserHostAddress+ "\r\n錯誤地址:" + HttpContext.Current.Request.Url + "\r\n", e);connection.Close();throw e;}}}}請求的字符串就是:connectionString
然后每一個連接字符串都會當作是一個新的連接請求。
這樣子對于一些小型的web項目還是可以的,畢竟并發量不會太大。但是對于大型網站,訪問量很大,切換連接的開銷就會非常的大,對系統而言是一個很大的瓶頸;而使用連接池比較只是在線程基本把連接給屏蔽掉(納秒級),所以使用連接池對整個網站而言是有很大的好處的;
總結
- 上一篇: javaweb之Filter详解
- 下一篇: ubuntu中启动oracle数据库