java JDBC資料庫連接池技術 為什麼使用資料庫連接池? 這個原因與為什麼使用線程池有點相似,都是為了提高資源的利用率,減少申請時間的浪費,提高程式的運行效率。 資料庫連接池的基本思想就是為資料庫連接建立一個“緩衝池”。預先在緩衝池中放入一定數量的連接,當需要建立數 據庫連接時,只需從“緩衝池” ...
java JDBC資料庫連接池技術
為什麼使用資料庫連接池?
這個原因與為什麼使用線程池有點相似,都是為了提高資源的利用率,減少申請時間的浪費,提高程式的運行效率。
資料庫連接池的基本思想就是為資料庫連接建立一個“緩衝池”。預先在緩衝池中放入一定數量的連接,當需要建立數
據庫連接時,只需從“緩衝池”中取出一個,使用完畢之後再放回去。我們可以通過設定連接池最大連接數來防止系統
無盡的與資料庫連接。
資料庫連接池的優點:
1.1 資源的重用
資料庫連接池中的連接可以重覆使用,避免頻繁的創建,大大減少了性能的開銷,即減少了系統的消耗,也增加了系統環境運行的平穩性
1.2提高系統的反應速度
s資料庫連接池在初始化的過程中,往往已經創建了若幹資料庫連接置於連接池中備用,在由業務要使用的時候可以直接拿來使用,避免了初始化和釋放過程的時間開銷,從而減少了系統的響應時間
1.3新的資源分配手段
當多個應用共用一個資料庫的時候,可以在應用層通過資料庫連接池的配置,實現某一應用最大資料庫連接數的限制,避免某一應用占用過多的資源
1.4統一連接管理,避免資料庫的連接泄露
資料庫連接池中可設置超時占用設定,強制收回被占用的連接,避免常規資料庫連接操作中可能出現的資源泄露
兩種資料庫連接池技術 C3P0 Druid
C3P0 是一個開源組織提供的一個資料庫連接池,速度相對較慢,穩定性還可以。hibernate官方推薦使用
Druid 是阿裡提供的資料庫連接池,據說是集DBCP 、C3P0 、Proxool 優點於一身的資料庫連接池,但是速度不確定是否有BoneCP快,據說是目前最弔的資料庫連接池之一
c3p0的使用
*** 步驟:**
1. 導入jar包 (兩個) c3p0-0.9.5.2.jar mchange-commons-java-0.2.12.jar ,
* 不要忘記導入資料庫驅動jar包
2. 定義配置文件:
* 名稱: c3p0.properties 或者 c3p0-config.xml
* 路徑:直接將文件放在src目錄下即可。
3. 創建核心對象 資料庫連接池對象 ComboPooledDataSource
4. 獲取連接: getConnection
配置文件:
<c3p0-config>
<!-- 使用預設的配置讀取連接池對象 -->
<default-config>
<!-- 連接參數 -->
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://localhost:3309/db2</property>
//資料庫用戶名
<property name="user">root</property>
//密碼
<property name="password">1234</property>
<!-- 連接池參數 -->
//初始化連接數
<property name="initialPoolSize">5</property>
//最大連接數
<property name="maxPoolSize">10</property>
//最長的超時連接時間
<property name="checkoutTimeout">3000</property>
</default-config>
//自己定義的配置
<named-config name="otherc3p0">
<!-- 連接參數 -->
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">jdbc:mysql://localhost:3306/day25</property>
<property name="user">root</property>
<property name="password">root</property>
<!-- 連接池參數 -->
<property name="initialPoolSize">5</property>
<property name="maxPoolSize">8</property>
<property name="checkoutTimeout">1000</property>
</named-config>
</c3p0-config>
java代碼
package JDBC;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class C3P0 {
public static void main(String[] args) throws SQLException {
//創建資料庫連接池
DataSource ds = new ComboPooledDataSource();
//獲取連接對象
Connection connection = ds.getConnection();
//定義sql語句
String sql="update count set money=0";
//獲取statement對象
PreparedStatement preparedStatement = connection.prepareStatement(sql);
//執行
int i = preparedStatement.executeUpdate();
System.out.println(i);
//關閉statement,歸還connection
preparedStatement.close();
connection.close();
}
}
Druid的使用
1.導入jar包
導入jar包 druid-1.0.9.jar
2.定義配置文件
是properties形式的
可以叫任意名稱,可以放在任意目錄下
3.載入配置文件
4.獲取資料庫連接池對象
通過工廠來來獲取 DruidDataSourceFactory
5.獲取連接
getConnection
配置文件
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3309/db2
username=root
password=1234
//初始化連接數
initialSize=5
//最大連接數
maxActive=10
//最長等待時間
maxWait=3000
工具類
package JDBC;
import com.alibaba.druid.pool.DruidDataSourceFactory;
import javax.sql.DataSource;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
public class DruidUtils {
private static DataSource dataSource=null;
//獲取資料庫連接池
public static DataSource getDataSource() {
return dataSource;
}
//關閉statement,歸還connection
public static void close(Statement statement, Connection connection){
if (statement!=null){
try {
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (connection!=null){
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
public static void setDataSource(DataSource dataSource) {
DruidUtils.dataSource = dataSource;
}
static {
try {
//載入配置文件經記憶體
Properties properties = new Properties();
InputStream resourceAsStream = DruidUtils.class.getClassLoader().getResourceAsStream("druid.properties");
properties.load(resourceAsStream);
dataSource = DruidDataSourceFactory.createDataSource(properties);
} catch (IOException e) {
System.out.println(e);
} catch (Exception e) {
e.printStackTrace();
}
}
public static Connection getConnection() throws SQLException {
return dataSource.getConnection();
}
}
主函數
package JDBC;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class Druid {
public static void main(String[] args) throws SQLException {
//獲取連接對象
Connection connection = DruidUtils.getConnection();
//定義sql執行語句
String sql="update count set money=10";
//獲取statement對象
PreparedStatement preparedStatement = connection.prepareStatement(sql);
//執行語句
preparedStatement.executeUpdate();
//關閉
DruidUtils.close(preparedStatement,connection);
}
}