转自 http://soft-development.iteye.com/blog/1401770
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;
import java.util.Vector;
public class PersonDefine_ConnectionPool implements Runnable {
public String ProductionDB = "axdb_tmp";//給的默認值
private String database_driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";//給的默認值
// private String
// dakabase_url="jdbc:sybase:Tds:IP:port/dakabase_test?useUnicode=true&characterEncoding=UTF-8";
private String database_url = "jdbc:sqlserver://localhost:1433;DatabaseName=mgr_live"; //給的默認值
private String username = "sa";
private String password = "12345678";
private int maxConnections = 50;
private boolean waitIfBusy = true;
private Vector availableConnections, busyConnections;
private boolean connectionPending = false;
public PersonDefine_ConnectionPool(Properties props) throws SQLException {
System.out.println("jdbc:PersonDefine_ConnectionPool...");
int initialConnections = 0;
this.ProductionDB = props.getProperty("ELITEDATA.ProductionDB");
this.database_driver = props.getProperty("ELITEDATA.database_driver").trim();
this.database_url = props.getProperty("ELITEDATA.database_url");
this.username=props.getProperty("ELITEDATA.database_username");
this.password=props.getProperty("ELITEDATA.database_password");
this.maxConnections = maxConnections;
this.waitIfBusy = waitIfBusy;
if (initialConnections > maxConnections) {
initialConnections = maxConnections;
}
availableConnections = new Vector(initialConnections);
busyConnections = new Vector();
for (int i = 0; i < initialConnections; i++) {
availableConnections.addElement(makeNewConnection());
}
}
public synchronized Connection getConnection() throws SQLException {
System.out.println("jdbc:Get PersonDefine_ConnectionPool...");
if (!availableConnections.isEmpty()) {
Connection existingConnection = (Connection) availableConnections.lastElement();
int lastIndex = availableConnections.size() - 1;
availableConnections.removeElementAt(lastIndex);
// If connection on available list is closed (e.g.,
// it timed out), then remove it from available list
// and repeat the process of obtaining a connection.
// Also wake up threads that were waiting for a
// connection because maxConnection limit was reached.
if (existingConnection.isClosed()) {
notifyAll(); // Freed up a spot for anybody waiting
return (getConnection());
} else {
busyConnections.addElement(existingConnection);
return (existingConnection);
}
} else {
// Three possible cases:
// 1) You haven't reached maxConnections limit. So
// establish one in the background if there isn't
// already one pending, then wait for
// the next available connection (whether or not
// it was the newly established one).
// 2) You reached maxConnections limit and waitIfBusy
// flag is false. Throw SQLException in such a case.
// 3) You reached maxConnections limit and waitIfBusy
// flag is true. Then do the same thing as in second
// part of step 1: wait for next available connection.
if ((totalConnections() < maxConnections) && !connectionPending) {
makeBackgroundConnection();
} else if (!waitIfBusy) {
throw new SQLException("PersonDefine_ConnectionPool limit reached");
}
// Wait for either a new connection to be established
// (if you called makeBackgroundConnection) or for
// an existing connection to be freed up.
try {
wait();
} catch (InterruptedException ie) {
}
// Someone freed up a connection, so try again.
return (getConnection());
}
}
// You can't just make a new connection in the foreground
// when none are available, since this can take several
// seconds with a slow network connection. Instead,
// start a thread that establishes a new connection,
// then wait. You get woken up either when the new connection
// is established or if someone finishes with an existing
// connection.
private void makeBackgroundConnection() {
connectionPending = true;
System.out.println("jdbc:Make Background PersonDefine_ConnectionPool...");
try {
Thread connectThread = new Thread(this);
connectThread.start();
} catch (OutOfMemoryError oome) {
System.out.println("jdbc:PersonDefine_ConnectionPool out of Memory..." + oome);
}
}
public void run() {
try {
System.out.println("jdbc:run PersonDefine_ConnectionPool...");
Connection connection = makeNewConnection();
synchronized (this) {
availableConnections.addElement(connection);
connectionPending = false;
notifyAll();
}
} catch (Exception e) { // SQLException or OutOfMemory
System.out.println("jdbc:PersonDefine_ConnectionPool out of Memory...");
}
}
// This explicitly makes a new connection. Called in
// the foreground when initializing the ConnectionPool,
// and called in the background when running.
private Connection makeNewConnection() throws SQLException {
try {
System.out.println("jdbc:make new PersonDefine_ConnectionPool...");
// Load database dakabase_driver if not already loaded
Class.forName(database_driver);
// Establish network connection to database
Connection connection = DriverManager.getConnection(database_url, username, password);
return (connection);
} catch (ClassNotFoundException cnfe) {
// Simplify try/catch blocks of people using this by
// throwing only one exception type.
System.out.println("jdbc:PersonDefine_ConnectionPool Can't find class for database_driver:");
throw new SQLException("Can't find class for PersonDefine_ConnectionPool: " + database_driver);
}
}
public synchronized void free(Connection connection) {
System.out.println("jdbc:free PersonDefine_ConnectionPool...");
busyConnections.removeElement(connection);
availableConnections.addElement(connection);
// Wake up threads that are waiting for a connection
notifyAll();
}
public synchronized int totalConnections() {
return (availableConnections.size() + busyConnections.size());
}
/**
* Close all the connections. Use with caution: be sure no connections are
* in use before calling. Note that you are not <I>required</I> to call
* this when done with a ConnectionPool, since connections are guaranteed to
* be closed when garbage collected. But this method gives more control
* regarding when the connections are closed.
*/
public synchronized void closeAllConnections() {
System.out.println("jdbc:close all PersonDefine_ConnectionPool...");
closeConnections(availableConnections);
availableConnections = new Vector();
closeConnections(busyConnections);
busyConnections = new Vector();
}
private void closeConnections(Vector connections) {
try {
System.out.println("jdbc:close PersonDefine_ConnectionPool...");
for (int i = 0; i < connections.size(); i++) {
Connection connection = (Connection) connections.elementAt(i);
if (!connection.isClosed()) {
connection.close();
}
}
} catch (SQLException sqle) {
System.out.println("jdbc: PersonDefine_ConnectionPool..." + sqle);
}
}
public synchronized String toString() {
String info = "ConnectionPool(PersonDefine_ConnectionPool)(" + database_url + "," + username + ")" + ", available=" + availableConnections.size() + ", busy="
+ busyConnections.size() + ", max=" + maxConnections;
return (info);
}
}
相关推荐
对于多应用共享同一数据库的系统而言,可在应用层通过数据库连接的配置,实现数据库连接池技术。某一应用最大可用数据库连接数的限制,避免某一应用独占所有数据库资源。 在较为完备的数据库连接池实现中,可根据...
* 数据库连接池特点: * 获取连接时不需要了解连接的名字,连接池内部维护连接的名字 * 支持多线程,保证获取到的连接一定是没有被其他线程正在使用 * 按需创建连接,可以创建多个连接,可以控制连接的数量 * 连接...
C# 数据库连接池 C# 数据库连接池 C# 数据库连接池 C# 数据库连接池
context.xml, 数据库连接池配置文
C#高效数据库连接池源码
达梦7数据库连接池,jdbcDriver,达梦7数据库连接池,jdbcDriver,达梦7数据库连接池,jdbcDriver,达梦7数据库连接池,jdbcDriver,达梦7数据库连接池,jdbcDriver,达梦7数据库连接池,jdbcDriver,
这个文档详细讲述了mysql数据库连接池的配置以及数据库连接池的工作原理。
数据库连接池的例子.doc数据库连接池的例子.doc数据库连接池的例子.doc
Druid为监控而生的数据库连接池,它是阿里巴巴开源平台上的一个项目。Druid是Java语言中最好的数据库连接池,Druid能够提供强大的监控和扩展功能.它可以替换DBCP和C3P0连接池。Druid提供了一个高效、功能强大、可...
提供了数据库连接池的驱动,分别有c3p0、druid、dbcp三种数据库连接池的驱动
Tomcat5的数据库连接池配置Tomcat5的数据库连接池配置Tomcat5的数据库连接池配置Tomcat5的数据库连接池配置Tomcat5的数据库连接池配置Tomcat5的数据库连接池配置Tomcat5的数据库连接池配置Tomcat5的数据库连接池配置...
比较实用的几种数据库连接池详细配置,值得收藏
数据库连接池 数据库连接池 数据库连接池 数据库连接池
c#语言下,使用netcore2.1框架,调用netstandard数据库连接池组件
包含了连接数据库连接池所需的大部分jar包
数据库连接池DBCPjar包,数据库连接时.我们要是用到了数据库连接池,你需要的
java开发,数据库连接池c3p0所需jar包。
JAVA 使用数据库连接池连接Oracle数据库,全代码,附加详细说明
数据库连接池的基本思想就是为数据库连接建立一个“缓冲池”。预先在缓冲池中放入一定数量的连接, 当需要建立数据库连接时,只需从“缓冲池”中取出一个,使用完毕之后再放回去。 我们可以通过设定连接池最大连接数...
数据库连接池的基础学习,针对mysql数据库的数据库连接池在java中的具体实现及应用配置