本篇內(nèi)容介紹了“JDBC數(shù)據(jù)庫連接池 怎么實現(xiàn)”的有關(guān)知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細閱讀，能夠?qū)W有所成！
創(chuàng)新互聯(lián)建站成立于2013年，是專業(yè)互聯(lián)網(wǎng)技術(shù)服務(wù)公司，擁有項目成都網(wǎng)站建設(shè)、做網(wǎng)站網(wǎng)站策劃，項目實施與項目整合能力。我們以讓每一個夢想脫穎而出為使命，1280元修水做網(wǎng)站,已為上家服務(wù),為修水各地企業(yè)和個人服務(wù),聯(lián)系電話:13518219792
對于一個簡單的數(shù)據(jù)庫應(yīng)用，由于對于數(shù)據(jù)庫的訪問不是很頻繁。這時可以簡單地在需要訪問數(shù)據(jù)庫時，就新創(chuàng)建一個連接，用完后就關(guān)閉它，這樣做也不會帶來什么明顯的性能上的開銷。但是對于一個復(fù)雜的數(shù)據(jù)庫應(yīng)用，情況就完全不同了。頻繁的建立、關(guān)閉連接，會極大的減低系統(tǒng)的性能，因為對于連接的使用成了系統(tǒng)性能的瓶頸。
連接復(fù)用。通過建立一個數(shù)據(jù)庫連接池以及一套連接使用管理策略，使得一個數(shù)據(jù)庫連接可以得到高效、安全的復(fù)用，避免了數(shù)據(jù)庫連接頻繁建立、關(guān)閉的開銷。
對于共享資源，有一個很著名的設(shè)計模式：資源池。該模式正是為了解決資源頻繁分配、釋放所造成的問題的。把該模式應(yīng)用到數(shù)據(jù)庫連接管理領(lǐng)域，就是建立一個數(shù)據(jù)庫連接池，提供一套高效的連接分配、使用策略，最終目標是實現(xiàn)連接的高效、安全的復(fù)用。
數(shù)據(jù)庫連接池的基本原理是在內(nèi)部對象池中維護一定數(shù)量的數(shù)據(jù)庫連接，并對外暴露數(shù)據(jù)庫連接獲取和返回方法。
外部使用者可通過 getConnection 方法獲取連接，使用完畢后再通過 close 方法將連接返回，注意此時連接并沒有關(guān)閉，而是由連接池管理器回收，并為下一次使用做好準備。
Java 中有一個 DataSource 接口, 數(shù)據(jù)庫連接池就是 DataSource 的一個實現(xiàn)
下面我們自己實現(xiàn)一個數(shù)據(jù)庫連接池:
首先實現(xiàn) DataSource, 這里使用 BlockingQueue 作為池 (只保留了關(guān)鍵代碼)
重慶分公司
重慶分公司
import javax.sql.DataSource;import java.io.PrintWriter;import java.sql.Connection;import java.sql.DriverManager;import java.sql.SQLException;import java.sql.SQLFeatureNotSupportedException;import java.util.concurrent.ArrayBlockingQueue;import java.util.concurrent.BlockingQueue;import java.util.logging.Logger;public class MyDataSource implements DataSource {
static {
try {
Class.forName("com.MySQL.jdbc.Driver");
} catch (Exception e) {
e.printStackTrace();
}
}
//這里有個坑
//MySQL用的是5.5的
//驅(qū)動用的是最新的
//連接的時候會報The server time zone value '?й???????'
// is unrecognized or represents more than one time zone
//解決方法:
//1.在連接串中加入?serverTimezone=UTC
//2.在mysql中設(shè)置時區(qū)，默認為SYSTEM
//set global time_zone='+8:00'
private String url = "jdbc:mysql://localhost:3306/test?serverTimezone=UTC";
private String user = "root";
private String password = "123456";
private BlockingQueue pool = new ArrayBlockingQueue<>(3);
public MyDataSource() {
initPool();
}
private void initPool() {
try {
for (int i = 0; i < 3; i++) {
pool.add(new MyConnection(
DriverManager.getConnection(url, user, password), this));
}
} catch (SQLException e) {
e.printStackTrace();
}
}
/*
從池中獲取連接
*/
@Override
public synchronized Connection getConnection() throws SQLException {
try {
return pool.take();
} catch (InterruptedException e) {
e.printStackTrace();
}
throw new RuntimeException("get connection failed!");
}
public BlockingQueue getPool() {
return pool;
}
public void setPool(BlockingQueue pool) {
this.pool = pool;
}} 實現(xiàn)自己的連接, 對原生連接進行封裝, 調(diào)用 close 方法的時候?qū)⑦B接放回到池中
import java.sql.*; import java.util.Map; import java.util.Properties; importjava.util.concurrent.Executor; public class MyConnection implements Connection { //包裝的連接private Connection conn; private MyDataSource dataSource; public MyConnection(Connection conn, MyDataSource dataSource) { this.conn = conn; this.dataSource = dataSource; } @Overridepublic Statement createStatement() throws SQLException { return conn.createStatement(); }@Override public PreparedStatement prepareStatement(String sql) throws SQLException { returnconn.prepareStatement(sql); } @Override public boolean getAutoCommit() throws SQLException {return conn.getAutoCommit(); } @Override public void setAutoCommit(boolean autoCommit) throwsSQLException { conn.setAutoCommit(autoCommit); } @Override public void commit() throwsSQLException { conn.commit(); } @Override public void rollback() throws SQLException { conn.rollback(); } @Override public void close() throws SQLException { //解決重復(fù)關(guān)閉問題 if(!isClosed()) { dataSource.getPool().add(this); } } @Override public boolean isClosed()throws SQLException { return dataSource.getPool().contains(this); } }main 方法
import javax.sql.DataSource; import java.sql.Connection; import java.sql.SQLException;import java.sql.Statement; public class Main { public static void main(String[] args) { DataSource source = new MyDataSource(); try { Connection conn = source.getConnection(); Statement st = conn.createStatement(); st.execute("INSERT INTO USER (name,age) values('bob',12)"); conn.close(); } catch (SQLException e) { e.printStackTrace(); } } }在Java Web開發(fā)過程中，會廣泛使用到數(shù)據(jù)源。
我們基本的使用方式，是通過Spring使用類似如下的配置，來聲明一個數(shù)據(jù)源：
