e代剑客——温柔一刀
生活就像海洋,只有意志坚强的人,才能到达彼岸
::
首页
::
新随笔
::
联系
::
聚合
::
管理
::
76 随笔 :: 7 文章 :: 215 评论 :: 0 Trackbacks
随笔分类
(78)
Agile(3)
(rss)
java相关(33)
(rss)
ROR(2)
(rss)
web相关(1)
(rss)
其他(11)
(rss)
开源框架(19)
(rss)
数据库相关(8)
(rss)
生活点滴(1)
(rss)
随笔档案
(76)
2010年10月 (1)
2007年12月 (3)
2007年7月 (1)
2007年4月 (1)
2007年2月 (4)
2006年12月 (2)
2006年11月 (1)
2006年10月 (9)
2006年9月 (3)
2006年8月 (27)
2006年7月 (14)
2006年6月 (1)
2006年4月 (9)
java源码
java examples
java学习源代码检索中心
java开源大全
spring源码学习
友情连接
e代剑客—JavaEye
(rss)
开发文档
hibernate中文文档
Java2 API 规范
javascript参考手册
MySQL中文参考手册
Spring参考手册
spring进阶-IT实验室
XPath 教程
搜索
最新评论
1. re: Java应用iText动态生成PDF文件
e21e12eeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee
--eq23r
2. re: Toad for oracle 教程[未登录]
多谢!!!
--啊啊
3. re: Toad for oracle 教程
谢了
--后来者
4. re: Toad for oracle 教程
好人多
--hzlxm
5. re: Toad for oracle 教程
谢谢!
--stophy
阅读排行榜
1. Toad for oracle 教程(11272)
2. spring 生成Excel和PDF文件(7308)
3. javascript获取客户端网卡MAC地址和IP地址和计算机名(7282)
4. 最简单的iBatis入门例子(6603)
5. JXL操作Excel(6467)
评论排行榜
1. Toad for oracle 教程(109)
2. spring、ibatis控制oracle分页的问题 (23)
3. 最简单的iBatis入门例子(16)
4. 德比软件(DerbySoft)诚聘java工程师(上海)(10)
5. spring 生成Excel和PDF文件(7)
javaBean数据库连接池
/** */
/**
*
@author
zhupan(温柔一刀) Creation date: 06-10-2006
*/
package
com.zhupan.StrutsArticle.Utils;
import
java.sql.Connection;
public
class
DBConnection
{
public
static
synchronized
Connection getConnection()
throws
Exception
{
Connection conn
=
null
;
DBConnectionManager dbc;
try
{
dbc
=
DBConnectionManager.getInstance();
conn
=
dbc.getConnection(
"
idb
"
);
}
catch
(Exception e)
{
}
return
conn;
}
}
/** */
/**
*
@author
zhupan(温柔一刀) Creation date: 05-01-2006
*/
package
com.zhupan.StrutsArticle.Utils;
import
java.io.FileWriter;
import
java.io.IOException;
import
java.io.InputStream;
import
java.io.PrintWriter;
import
java.sql.Connection;
import
java.sql.Driver;
import
java.sql.DriverManager;
import
java.sql.SQLException;
import
java.util.Date;
import
java.util.Enumeration;
import
java.util.Hashtable;
import
java.util.Properties;
import
java.util.StringTokenizer;
import
java.util.Vector;
/** */
/**
连接池
* 管理类DBConnectionManager支持对一个或多个由属性文件定义的数据库连接
* 池的访问.客户程序可以调用getInstance()方法访问本类的唯一实例.
*/
public
class
DBConnectionManager
{
static
private
DBConnectionManager instance;
//
唯一实例
static
private
int
clients;
private
Vector drivers
=
new
Vector();
private
PrintWriter log;
private
Hashtable pools
=
new
Hashtable();
/** */
/**
* 返回唯一实例.如果是第一次调用此方法,则创建实例
*
*
@return
DBConnectionManager 唯一实例
*/
static
synchronized
public
DBConnectionManager getInstance()
{
if
(instance
==
null
)
{
instance
=
new
DBConnectionManager();
}
clients
++
;
return
instance;
}
/** */
/**
* 建构函数私有以防止其它对象创建本类实例
*/
private
DBConnectionManager()
{
init();
}
/** */
/**
* 将连接对象返回给由名字指定的连接池
*
*
@param
name 在属性文件中定义的连接池名字
*
@param
con 连接对象
*/
public
void
freeConnection(String name, Connection con)
{
DBConnectionPool pool
=
(DBConnectionPool) pools.get(name);
if
(pool
!=
null
)
{
pool.freeConnection(con);
}
}
/** */
/**
* 获得一个可用的(空闲的)连接.如果没有可用连接,且已有连接数小于最大连接数
* 限制,则创建并返回新连接
*
*
@param
name 在属性文件中定义的连接池名字
*
@return
Connection 可用连接或null
*/
public
Connection getConnection(String name)
{
DBConnectionPool pool
=
(DBConnectionPool) pools.get(name);
if
(pool
!=
null
)
{
return
pool.getConnection();
}
return
null
;
}
/** */
/**
* 获得一个可用连接.若没有可用连接,且已有连接数小于最大连接数限制,
* 则创建并返回新连接.否则,在指定的时间内等待其它线程释放连接.
*
*
@param
name 连接池名字
*
@param
time 以毫秒计的等待时间
*
@return
Connection 可用连接或null
*/
public
Connection getConnection(String name,
long
time)
{
DBConnectionPool pool
=
(DBConnectionPool) pools.get(name);
if
(pool
!=
null
)
{
return
pool.getConnection(time);
}
return
null
;
}
/** */
/**
* 关闭所有连接,撤销驱动程序的注册
*/
public
synchronized
void
release()
{
//
等待直到最后一个客户程序调用
if
(
--
clients
!=
0
)
{
return
;
}
Enumeration allPools
=
pools.elements();
while
(allPools.hasMoreElements())
{
DBConnectionPool pool
=
(DBConnectionPool) allPools.nextElement();
pool.release();
}
Enumeration allDrivers
=
drivers.elements();
while
(allDrivers.hasMoreElements())
{
Driver driver
=
(Driver) allDrivers.nextElement();
try
{
DriverManager.deregisterDriver(driver);
log(
"
撤销JDBC驱动程序
"
+
driver.getClass().getName()
+
"
的注册
"
);
}
catch
(SQLException e)
{
log(e,
"
无法撤销下列JDBC驱动程序的注册:
"
+
driver.getClass().getName());
}
}
}
/** */
/**
* 根据指定属性创建连接池实例.
*
*
@param
props 连接池属性(温柔一刀)
*/
private
void
createPools(Properties props)
{
Enumeration propNames
=
props.propertyNames();
while
(propNames.hasMoreElements())
{
String name
=
(String) propNames.nextElement();
if
(name.endsWith(
"
.url
"
))
{
String poolName
=
name.substring(
0
, name.lastIndexOf(
"
.
"
));
String url
=
props.getProperty(poolName
+
"
.url
"
);
if
(url
==
null
)
{
log(
"
没有为连接池
"
+
poolName
+
"
指定URL
"
);
continue
;
}
String user
=
props.getProperty(poolName
+
"
.user
"
);
String password
=
props.getProperty(poolName
+
"
.password
"
);
String maxconn
=
props.getProperty(poolName
+
"
.maxconn
"
,
"
0
"
);
int
max;
try
{
max
=
Integer.valueOf(maxconn).intValue();
}
catch
(NumberFormatException e)
{
log(
"
错误的最大连接数限制:
"
+
maxconn
+
"
.连接池:
"
+
poolName);
max
=
0
;
}
DBConnectionPool pool
=
new
DBConnectionPool(poolName, url, user, password, max);
pools.put(poolName, pool);
log(
"
成功创建连接池
"
+
poolName);
}
}
}
/** */
/**
* 读取属性完成初始化(温柔一刀)
*/
private
void
init()
{
InputStream is
=
getClass().getResourceAsStream(
"
db.properties
"
);
Properties dbProps
=
new
Properties();
try
{
dbProps.load(is);
}
catch
(Exception e)
{
System.err.println(
"
不能读取属性文件.
"
+
"
请确保db.properties在CLASSPATH指定的路径中
"
);
return
;
}
String logFile
=
dbProps.getProperty(
"
logfile
"
,
"
DBConnectionManager.log
"
);
try
{
log
=
new
PrintWriter(
new
FileWriter(logFile,
true
),
true
);
}
catch
(IOException e)
{
System.err.println(
"
无法打开日志文件:
"
+
logFile);
log
=
new
PrintWriter(System.err);
}
loadDrivers(dbProps);
createPools(dbProps);
}
/** */
/**
* 装载和注册所有JDBC驱动程序(温柔一刀)
*
*
@param
props 属性
*/
private
void
loadDrivers(Properties props)
{
String driverClasses
=
props.getProperty(
"
drivers
"
);
StringTokenizer st
=
new
StringTokenizer(driverClasses);
while
(st.hasMoreElements())
{
String driverClassName
=
st.nextToken().trim();
try
{
Driver driver
=
(Driver)
Class.forName(driverClassName).newInstance();
DriverManager.registerDriver(driver);
drivers.addElement(driver);
log(
"
成功注册JDBC驱动程序
"
+
driverClassName);
}
catch
(Exception e)
{
log(
"
无法注册JDBC驱动程序:
"
+
driverClassName
+
"
, 错误:
"
+
e);
}
}
}
/** */
/**
* 将文本信息写入日志文件(温柔一刀)
*/
private
void
log(String msg)
{
log.println(
new
Date()
+
"
:
"
+
msg);
}
/** */
/**
* 将文本信息与异常写入日志文件(温柔一刀)
*/
private
void
log(Throwable e, String msg)
{
log.println(
new
Date()
+
"
:
"
+
msg);
e.printStackTrace(log);
}
/** */
/**
* 此内部类定义了一个连接池.它能够根据要求创建新连接,直到预定的最
* 大连接数为止.在返回连接给客户程序之前,它能够验证连接的有效性.(温柔一刀)
*/
class
DBConnectionPool
{
private
int
checkedOut;
private
Vector freeConnections
=
new
Vector();
private
int
maxConn;
private
String name;
private
String password;
private
String URL;
private
String user;
/** */
/**
* 创建新的连接池
*
*
@param
name 连接池名字
*
@param
URL 数据库的JDBC URL
*
@param
user 数据库帐号,或 null
*
@param
password 密码,或 null(温柔一刀)
*
@param
maxConn 此连接池允许建立的最大连接数
*/
public
DBConnectionPool(String name, String URL, String user, String password,
int
maxConn)
{
this
.name
=
name;
this
.URL
=
URL;
this
.user
=
user;
this
.password
=
password;
this
.maxConn
=
maxConn;
}
/** */
/**
* 将不再使用的连接返回给连接池(温柔一刀)
*
*
@param
con 客户程序释放的连接
*/
public
synchronized
void
freeConnection(Connection con)
{
//
将指定连接加入到向量末尾
freeConnections.addElement(con);
checkedOut
--
;
notifyAll();
}
/** */
/**
* 从连接池获得一个可用连接.如没有空闲的连接且当前连接数小于最大连接
* 数限制,则创建新连接.如原来登记为可用的连接不再有效,则从向量删除之,
* 然后递归调用自己以尝试新的可用连接.(温柔一刀)
*/
public
synchronized
Connection getConnection()
{
Connection con
=
null
;
if
(freeConnections.size()
>
0
)
{
//
获取向量中第一个可用连接
con
=
(Connection) freeConnections.firstElement();
freeConnections.removeElementAt(
0
);
try
{
if
(con.isClosed())
{
log(
"
从连接池
"
+
name
+
"
删除一个无效连接
"
);
//
递归调用自己,尝试再次获取可用连接
con
=
getConnection();
}
}
catch
(SQLException e)
{
log(
"
从连接池
"
+
name
+
"
删除一个无效连接
"
);
//
递归调用自己,尝试再次获取可用连接
con
=
getConnection();
}
}
else
if
(maxConn
==
0
||
checkedOut
<
maxConn)
{
con
=
newConnection();
}
if
(con
!=
null
)
{
checkedOut
++
;
}
return
con;
}
/** */
/**
* 从连接池获取可用连接.可以指定客户程序能够等待的最长时间
* 参见前一个getConnection()方法.
*
*
@param
timeout 以毫秒计的等待时间限制
*/
public
synchronized
Connection getConnection(
long
timeout)
{
long
startTime
=
new
Date().getTime();
Connection con;
while
((con
=
getConnection())
==
null
)
{
try
{
wait(timeout);
}
catch
(InterruptedException e)
{}
if
((
new
Date().getTime()
-
startTime)
>=
timeout)
{
//
wait()返回的原因是超时
return
null
;
}
}
return
con;
}
/** */
/**
* 关闭所有连接(温柔一刀)
*/
public
synchronized
void
release()
{
Enumeration allConnections
=
freeConnections.elements();
while
(allConnections.hasMoreElements())
{
Connection con
=
(Connection) allConnections.nextElement();
try
{
con.close();
log(
"
关闭连接池
"
+
name
+
"
中的一个连接
"
);
}
catch
(SQLException e)
{
log(e,
"
无法关闭连接池
"
+
name
+
"
中的连接
"
);
}
}
freeConnections.removeAllElements();
}
/** */
/**
* 创建新的连接(温柔一刀)
*/
private
Connection newConnection()
{
Connection con
=
null
;
try
{
if
(user
==
null
)
{
con
=
DriverManager.getConnection(URL);
}
else
{
con
=
DriverManager.getConnection(URL, user, password);
}
log(
"
连接池
"
+
name
+
"
创建一个新的连接
"
);
}
catch
(SQLException e)
{
log(e,
"
无法创建下列URL的连接:
"
+
URL);
return
null
;
}
return
con;
}
}
}
db.properties文件(温柔一刀)
drivers=com.mysql.jdbc.Driver
logfile=C:\\StrutsArticle.log
idb.url=jdbc:mysql://localhost/StrutsArticle?useUnicode=true
&characterEncoding
=gb2312
idb.maxconn=100
idb.user=root
idb.password=
posted on 2006-07-09 04:35
温柔一刀
阅读(433)
评论(0)
编辑
收藏
所属分类:
java相关
新用户注册
刷新评论列表
只有注册用户
登录
后才能发表评论。
网站导航:
博客园
IT新闻
Chat2DB
C++博客
博问
管理
相关文章:
德比软件(DerbySoft)诚聘java工程师(上海)
jpivot中输出pdf打印汉字、excel导出中文方法
Ant+Tomcat自动部署的小问题
FCKeditor-2.3在线编辑器,可以直接用的(java版)
Eclipse快捷键指南
Java应用iText动态生成PDF文件
将Excel文件内容写入到数据库
JXL操作Excel
件上传组件commons-fileupload用户指南
随机生成验证码
Powered by:
BlogJava
Copyright © 温柔一刀
联系偶
zhupanjava@gmail.com
温柔一刀