以下是一个简单的MySQL连接池示例,使用Java语言:
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
public class MySQLConnectionPool {
private static final String DB_URL = "jdbc:mysql://localhost:3306/mydatabase";
private static final String DB_USER = "username";
private static final String DB_PASSWORD = "password";
private List<Connection> connectionPool;
private int maxPoolSize;
public MySQLConnectionPool(int maxPoolSize) {
this.maxPoolSize = maxPoolSize;
connectionPool = new ArrayList<>();
// 初始化连接池
initializeConnectionPool();
}
private void initializeConnectionPool() {
try {
for (int i = 0; i < maxPoolSize; i++) {
Connection conn = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD);
connectionPool.add(conn);
}
} catch (SQLException e) {
e.printStackTrace();
}
}
public synchronized Connection getConnection() throws InterruptedException {
while (connectionPool.isEmpty()) {
wait(); // 当连接池为空时,等待新的连接可用
}
Connection conn = connectionPool.remove(connectionPool.size() - 1);
return conn;
}
public synchronized void releaseConnection(Connection conn) {
if (conn != null) {
connectionPool.add(conn);
notifyAll(); // 释放连接后通知等待的线程可以获取到连接
}
}
}
这个示例实现了一个简单的MySQL连接池,其中maxPoolSize
表示最大连接数。在初始化时会创建指定数量的数据库连接,并存储在一个列表中。当需要获取连接时,可以从连接池中获取一个可用的连接;当释放连接时,将连接放回到连接池中。这样可以避免频繁地创建和关闭数据库连接,提高了性能。
需要注意的是,在使用完连接后要及时释放,以免资源泄漏。同时在多线程环境下,需要进行同步处理来保证线程安全性。此外,还应该添加一些异常处理和其他的功能(例如超时机制)来增强连接池的稳定性和可靠性。
请注意根据实际情况调整代码并进行适当的测试和优化。
内容由零声教学AI助手提供,问题来源于学员提问