日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 运维知识 > 数据库 >内容正文

数据库

数据库连接池的使用

發布時間:2023/12/2 数据库 25 豆豆
生活随笔 收集整理的這篇文章主要介紹了 数据库连接池的使用 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

關于數據庫連接池的使用,首先我們要明白我們為什么要用它,對應普通的數據庫連接操作,通常會涉及到以下一些操作是比較耗時的:

網絡通訊,涉及到網絡延時及協議通訊
身份驗證,涉及安全性檢查
連接合法性檢查,主要是檢查所連接的數據庫是否存在
并發控制機制
構造并初始化輸出緩沖區
連接成功后的信息保存,日志存儲
服務器性能
數據庫配置優化
系統分配內存資源
等等~~~狀況,導致數據庫連接操作比較耗時,~~~而且每次都得花費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項目還是可以的,畢竟并發量不會太大。但是對于大型網站,訪問量很大,切換連接的開銷就會非常的大,對系統而言是一個很大的瓶頸;而使用連接池比較只是在線程基本把連接給屏蔽掉(納秒級),所以使用連接池對整個網站而言是有很大的好處的;

總結

以上是生活随笔為你收集整理的数据库连接池的使用的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。