import java.sql.Connection
import java.sql.SQLException
import java.util.Vector
/**数据库连接池的公共类 **/
public class ConnectionPool {
private Vector<Connection>pool//声明集合,里面只能是放Connection
/**
* 声明要的东西
*/
private String url = "jdbc:sqlserver://localhost:1433database=ajax"
private String username = "sa"
private String password = "sa123"
private String driverClassName = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
/**
* 连接池的大小,也就是连接池中有多少个数据库连接
*/
private int poolSize = 5
private static ConnectionPool instance = null
/**
* 私有的构造方法,禁止外部创建本类的对象,要想获得本类的对象,通过<code>getIstance</code>方法
* 使用了设计模式中的单子模式
*/
private ConnectionPool() {
init()
}
/**
* 连接池初始化方法,读取属性文件的内容 建立连接池中的初始连
*/
private void init() {
pool = new Vector<Connection>(poolSize)
//readConfig()
addConnection()
}
/**
* 返回连接到连接池
*/
public synchronized void release(Connection conn) {
pool.add(conn)
}
/**
* 关闭连接池中的所有数据库连接
*/
public synchronized void closePool() {
for (int i = 0i <pool.size()i++) {
try {
((Connection) pool.get(i)).close()
} catch (SQLException e) {
e.printStackTrace()
}
pool.remove(i)
}
}
/**
* 返回当前连接池的对象
*/
public static ConnectionPool getInstance() {
if (instance == null) {
instance = new ConnectionPool()
}
return instance
}
/**
* 返回连接池中的一个数据库连接
*/
public synchronized Connection getConnection() {
if (pool.size() >0) {
Connection conn = pool.get(0)
pool.remove(conn)
return conn
} else {
return null
}
}
/**
* 在连接池中创建初始设置的的数据库连接
*/
private void addConnection() {
Connection conn = null
for (int i = 0i <poolSizei++) {
try {
Class.forName(driverClassName)
conn = java.sql.DriverManager.getConnection(url, username,
password)
pool.add(conn)
} catch (ClassNotFoundException e) {
e.printStackTrace()
} catch (SQLException e) {
e.printStackTrace()
}
}
}
}
可以在 服务器里配置tomcat 啥的
或者 自己写
一个连接池的类, 一个监听, 一个连接类
连接池最大连接20个
初始化时,连接5个
每新建一个 连接对象 时,都是在连接池里取的
如果没有空闲连接,就建立一个连接.如果超过最大连接,就等待
监听 查看当前连接池里的连接, 把被调用过的连接再设置为空闲连接
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)