package connectionpool;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Stack;
import test.TestInterface;
public class ConnectionPool {
Stack<Connection> st = new Stack<Connection>(); //创建一个堆栈,作为池子
private static ConnectionPool instance = new ConnectionPool(); //单例模式
public static int initialPoolSize = 5;
public static String dbName = "test";
public static String userName = "root";
public static String userPasswd = "";
private ConnectionPool() {
for(int i = 0; i < initialPoolSize; i++) //初始化缓冲池
try {
createConnection().close();
} catch (Exception e) {
e.printStackTrace();
}
}
public synchronized static Connection getConnection() throws Exception {
if (instance.st.size() > 0) return instance.st.pop();
else return createConnection();
}
synchronized static void returnConnection(Connection conn) {
instance.st.push(conn);
}
private static Connection createConnection() throws Exception { //以mysql为例 创建数据库连接
String url="jdbc:mysql://localhost/"+dbName+"?user="+userName+"&password="+userPasswd;
Class.forName("com.mysql.jdbc.Driver").newInstance();
Connection connection=DriverManager.getConnection(url);
ConnectionProxy handler = new ConnectionProxy(connection);
Connection proxy = (Connection ) Proxy.newProxyInstance( //创建代理
connection.getClass().getClassLoader(),
connection.getClass().getInterfaces(),handler);
return proxy;
}
}
接着实现代理类
package connectionpool;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.sql.Connection;
public class ConnectionProxy implements InvocationHandler{
Connection delegate;
ConnectionProxy(Connection delegate) {
this.delegate = delegate;
}
public Object invoke(Object proxy, Method method, Object[] args)
throws Throwable {
try {
if ("close".equals(method.getName())) { //在close函数处设置钩子
ConnectionPool.returnConnection((Connection) proxy);
//将数据库连接归还缓冲池,跳过了原来的close()函数
// 这里的proxy实际上就是Connection的一个代理实例
}
else return method.invoke(delegate, args);
} catch (Exception e){
}
return null;
}
}
使用缓冲池很简单 ConnectionPool.getConnection();
使用完connection后,直接执行close()函数就行了,connection将返回缓冲池中而不是真正的关闭
当然这只是实现了很简单的一个缓冲池,实用化还需要加上其他一些功能
比如关闭idle连接等等
接下来介绍一个实用的java数据库缓冲池 c3p0。
分享到:
相关推荐
数据库连接池的基本思想就是为数据库连接建立一个“缓冲池”。预先在缓冲池中放入一定数量的连接, 当需要建立数据库连接时,只需从“缓冲池”中取出一个,使用完毕之后再放回去。 我们可以通过设定连接池最大连接数...
EAServer6.x数据库缓冲池配置
连接池类是对某一数据库所有连接的“缓冲池”,主要实现以下功能:从连接池获取或创建可用连接;使用完毕之后,把连接返还给连接池;在系统关闭前,断开所有连接并释放连接占用的系统资源;还能够处理无效连接(原来...
c3p0数据库缓冲池配置 a----最大JDBC连接数量,超出这个数量就会抛异常. b----最少JDBC连接数量. c----以秒为单位。如果空闲连接的空闲超过了timeout,就会删除 d----最大的PreparedStatement的数量 e----每隔...
数据库连接池的基本思想就是为数据库连接建立一个“缓冲池”。预先在缓冲池中放入一定数量的连接,当需要建立数据库连接时,只需从“缓冲池”中取出一个,使用完毕之后再放回去。我们可以通过设定连接池最大连接数来...
Tomcat 4.0如何配置数据库连结缓冲池
数据库连接池的基本原理就是为数据库建立一个缓冲池。在缓冲池中先创建指定数量的数据库连接,当有连接请求时就从缓冲池中取出处于“空闲”状态的连接,并将此连接标记为“忙碌”,直到该请求进程结束后,它所使用的...
操作系统缓冲池模拟和实现(C++版) 用来实现和模拟操作系统中缓冲池的操作 很有用操作系统缓冲池模拟和实现(C++版) 用来实现和模拟操作系统中缓冲池的操作 很有用
java访问数据库集合、多种访问数据库方式、包含缓冲池等内容、jdbc、spring、hibernate、mybatis
java双缓冲原理简单易懂,适合初学者,原理讲解,过程讲解,不懂欢迎给差评
建立“缓冲存储池”,是数据库连接池的基本设计思想。这种技术类似于CPU 中的Cache 技术,将预先设定好的数据库连接放入该缓冲池中,当要建立数据库连接操作时,便从池中取出一个连接,使用完毕后再将其放回。这样就...
数据库缓冲区溢出漏洞原理解析.pdf
一个数据库缓冲区实现文档,实现一个简单的缓冲区。
Java双缓冲技术原理详细讲解例子Java实用源码整理learns
NULL 博文链接:https://patterncat.iteye.com/blog/387077
数据库实验资料,实现缓冲区数据交换,使用了LRU算法。
非常实用的缓冲池类非常实用的缓冲池类非常实用的缓冲池类非常实用的缓冲池类非常实用的缓冲池类非常实用的缓冲池类
中科大研究生计算机专业基础课《高级数据库系统》(教师:金培权)2020年大作业,设计一个数据库的缓冲管理系统,C++实现,包含源码及实验报告。
用java编程实现的缓冲池,用于模拟操作系统相关内容。