目前使用的JAVA数据库链接管理类
2006-09-15 22:27
507 查看
好吧，直入主题。
首先需要设置好数据库连接池，参见Javaworld@TW出的wiki
由于我们的服务器上仅有一个应用，使用的是在web.xml中添加一个随容器启动的servlet来实现加载连接池的方法，该servlet通过读取WEB-INF/config/proxool.xml完成proxool的初始化。如下：
<servlet-name>ServletConfigurator</servlet-name>
<servlet-class>org.logicalcobwebs.proxool.configuration.ServletConfigurator</servlet-class>
<init-param>
<param-name>xmlFile</param-name>
<param-value>WEB-INF/config/proxool.xml</param-value>
</init-param>
<load-on-startup>1</load-on-startup>
</servlet>
proxool.xml文件，注意 <alias>ems</alias>这项，将是DriverManager.getConnection()的参数
用户名和密码也需注意，下面的参数尚未经过严格测试，可能存在性能瓶颈，欢迎请高手指教
<?xml version="1.0" encoding="UTF-8"?>
<!-- the proxool configuration can be embedded within your own application's.
Anything outside the "proxool" tag is ignored.-->
<proxool-config>
<proxool>
<alias>ems</alias>
<driver-url>
jdbc:jtds:sqlserver://localhost:1433/ems
</driver-url>
<driver-class>net.sourceforge.jtds.jdbc.Driver</driver-class>
<driver-properties>
<property name="user" value="user" />
<property name="password" value="user" />
</driver-properties>
<!--最少保持的空闲连接数-->
<prototype-count>5</prototype-count>
<!--允许最大连接数,超过了这个连接，再有请求时，就排在队列中-->
<maximum-connection-count>100</maximum-connection-count>
<!--最小连接数-->
<minimum-connection-count>10</minimum-connection-count>
<!--最大的等待请求数,即因没有空闲连接可以分配而在队列中等候的最大请求数,超过这个请求数的用户连接就不会被接受-->
<proxool.simultaneous-build-throttle>
200
</proxool.simultaneous-build-throttle>
<!--Test SQL-->
<house-keeping-test-sql>
SELECT getDate()
</house-keeping-test-sql>
<!--自动侦察各个连接状态的时间间隔(毫秒),侦察到空闲的连接就马上回收,超时的销毁-->
<house-keeping-sleep-time>90000</house-keeping-sleep-time>
</proxool>
至此，准备工作已经完成，接下来就是DatabaseManagerjava
每个方法均有注释，需要commons.logging包，用于输出log
package com.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
/**
* 数据库管理器:与数据库建立连接、断开连接、执行查询和更新操作
*
* @author Kryptonum
* @version 1.2
*
*/
public class DatabaseManager {
private static final Log logger = LogFactory.getLog(DatabaseManager.class);
public DatabaseManager() {
}
/**
* 获得一个数据库连接
*
* @return Connection对象
*
*/
public Connection getConnection() {
Connection conn = null;
try {
Class.forName("org.logicalcobwebs.proxool.ProxoolDriver");
conn = DriverManager.getConnection("proxool.ems");
} catch (ClassNotFoundException e) {
// 在classpath中未找到合适的驱动
logger.error("No suitable driver found");
logger.error(e.getMessage());
return null;
} catch (SQLException e) {
// 获取连接失败
logger
.error("Get connection failed, check the proxool configuration file and web.xml");
logger.error(e.getMessage());
return null;
}
if (conn != null) {
if (logger.isDebugEnabled()) {
logger.debug("Connected");
}
}
return conn;// 返回该Connection
}
/**
* 传入执行查询的语句，返回结果集
*
* @param conn
* Connection连接对象
* @param sql
* String类型的sql语句
* @return 结果集 ResultSet
*/
public ResultSet executeQuery(Connection conn, String sql) {
Statement stmt = null;// 声明Statement stmt
ResultSet rs = null;// 声明ResultSet rs
if (conn != null) {
// Connection 不为null，执行查询
// 若debug模式开启，则输出debug 信息
if (logger.isDebugEnabled()) {
logger.debug(sql);
}
try {
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
ResultSet.CONCUR_READ_ONLY);// 通过Connection创建一个Statemet
rs = stmt.executeQuery(sql);// 执行查询语句，
} catch (SQLException sqlex) {
logger.error("Execute query failed: [" + sql + "]");
logger.error(sqlex.getMessage());
return null;
}
return rs;
} else {
// Connection 为null，输出info信息，返回null
logger.info("Connection is null, execute sql query: [" + sql
+ "] failed");
return null;
}
}
/**
* 传入执行数据更新的语句，返回更新结果，成功执行为真
*
* @param conn
* Connection连接对象
* @param sql
* String类型的sql语句
* @return 执行结果，布尔型
*/
public boolean executeUpdate(Connection conn, String sql) {
boolean status = false;// 执行结果，默认为false
Statement stmt = null;// 声明Statement stmt
if (conn != null) {
// Connection 不为null，执行更新
// 若debug模式开启，则输出debug 信息
if (logger.isDebugEnabled()) {
logger.debug(sql);
}
try {
stmt = conn.createStatement();// 通过Connection创建一个Statemet
int count = stmt.executeUpdate(sql);// 执行更新数据操作，返回影响的行数
// 根据count值,判断执行的成功或失败
if (count > 0)
status = true;
} catch (SQLException sqlex) {
logger.error("Execute update failed: [" + sql + "]");
logger.error(sqlex.getMessage());
}
} else {
// Connection 为null，输出info信息，返回false
logger.info("Connection is null, execute sql update: [" + sql
+ "] failed");
}
return status;
}
/**
* 释放从连接池取得的连接
*
* @param conn
* Connection连接对象
*/
public void releaseConnection(Connection conn) {
// 释放连接
if (conn != null) {
try {
conn.close();
if (logger.isDebugEnabled()) {
logger.debug("Connection released");
}
} catch (SQLException sqlex) {
logger.error("Release connection failed");
} finally {
conn = null;
}
}
}
}
代码的应用，举两个例子
1、查询
package ttm.bean;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import com.util.DatabaseManager;
public class ScoreTypeDAO {
private DatabaseManager dm = null;
private Connection conn = null;
/**
* 构造函数，初始化DatabaseManager对象
*
*/
public ScoreTypeDAO() {
dm = new DatabaseManager();
}
/**
* 获取所有成绩类型编号
*
* @return 所有成绩类型编号
*/
public ArrayList<String> getAllScoreTypeId() {
ArrayList<String> sctpId = new ArrayList<String>();
String sql = "select SCORE_TP_ID from TC_SCORE_TP;";
try {
// 建立连接
conn = dm.getConnection();
ResultSet rst = dm.executeQuery(conn, sql);
while (rst.next()) {
// new a string
String str = new String();
str = rst.getString(1);// 成绩类型名称
sctpId.add(str);
}
} catch (SQLException sqlex) {
sqlex.printStackTrace();
} finally {
dm.releaseConnection(conn);
}
return sctpId;
}
}
2、删除
package ttm.bean;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import com.util.DatabaseManager;
public class CrswreDAO {
private DatabaseManager dm = null;
private Connection conn = null;
public CrswreDAO() {
dm = new DatabaseManager();
}
/**
* 删除给定id的课件
*
* @param crswreid
*/
public void delCrswre(String crswreid) {
String sql = "delete from TC_EDU_CRSWRE where ISN = '" + crswreid + "'";
try {
// 建立连接
conn = dm.getConnection();
dm.executeUpdate(conn, sql);
} finally {
dm.releaseConnection(conn);
}
}
总结：简化的目的基本打到了，但是离我的目标还是有很大的差距。首先try...catch...finally还是存在，代码依然很繁杂；其次就是异常没有被很好的进行管理。
这是第一次自己做工具的类尝试，虽然不是非常成功，却还是让我有很大的收获。独力完成如spring中的jdbc助手类般的代码对我而言似乎还太远，不过理解spring中的方法已经没有太大问题，接下来合理运用spring提供的基础架构是我和Pheonix要钻研的。
首先需要设置好数据库连接池，参见Javaworld@TW出的wiki
由于我们的服务器上仅有一个应用，使用的是在web.xml中添加一个随容器启动的servlet来实现加载连接池的方法，该servlet通过读取WEB-INF/config/proxool.xml完成proxool的初始化。如下：
<servlet-name>ServletConfigurator</servlet-name>
<servlet-class>org.logicalcobwebs.proxool.configuration.ServletConfigurator</servlet-class>
<init-param>
<param-name>xmlFile</param-name>
<param-value>WEB-INF/config/proxool.xml</param-value>
</init-param>
<load-on-startup>1</load-on-startup>
</servlet>
proxool.xml文件，注意 <alias>ems</alias>这项，将是DriverManager.getConnection()的参数
用户名和密码也需注意，下面的参数尚未经过严格测试，可能存在性能瓶颈，欢迎请高手指教
<?xml version="1.0" encoding="UTF-8"?>
<!-- the proxool configuration can be embedded within your own application's.
Anything outside the "proxool" tag is ignored.-->
<proxool-config>
<proxool>
<alias>ems</alias>
<driver-url>
jdbc:jtds:sqlserver://localhost:1433/ems
</driver-url>
<driver-class>net.sourceforge.jtds.jdbc.Driver</driver-class>
<driver-properties>
<property name="user" value="user" />
<property name="password" value="user" />
</driver-properties>
<!--最少保持的空闲连接数-->
<prototype-count>5</prototype-count>
<!--允许最大连接数,超过了这个连接，再有请求时，就排在队列中-->
<maximum-connection-count>100</maximum-connection-count>
<!--最小连接数-->
<minimum-connection-count>10</minimum-connection-count>
<!--最大的等待请求数,即因没有空闲连接可以分配而在队列中等候的最大请求数,超过这个请求数的用户连接就不会被接受-->
<proxool.simultaneous-build-throttle>
200
</proxool.simultaneous-build-throttle>
<!--Test SQL-->
<house-keeping-test-sql>
SELECT getDate()
</house-keeping-test-sql>
<!--自动侦察各个连接状态的时间间隔(毫秒),侦察到空闲的连接就马上回收,超时的销毁-->
<house-keeping-sleep-time>90000</house-keeping-sleep-time>
</proxool>
至此，准备工作已经完成，接下来就是DatabaseManagerjava
每个方法均有注释，需要commons.logging包，用于输出log
package com.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
/**
* 数据库管理器:与数据库建立连接、断开连接、执行查询和更新操作
*
* @author Kryptonum
* @version 1.2
*
*/
public class DatabaseManager {
private static final Log logger = LogFactory.getLog(DatabaseManager.class);
public DatabaseManager() {
}
/**
* 获得一个数据库连接
*
* @return Connection对象
*
*/
public Connection getConnection() {
Connection conn = null;
try {
Class.forName("org.logicalcobwebs.proxool.ProxoolDriver");
conn = DriverManager.getConnection("proxool.ems");
} catch (ClassNotFoundException e) {
// 在classpath中未找到合适的驱动
logger.error("No suitable driver found");
logger.error(e.getMessage());
return null;
} catch (SQLException e) {
// 获取连接失败
logger
.error("Get connection failed, check the proxool configuration file and web.xml");
logger.error(e.getMessage());
return null;
}
if (conn != null) {
if (logger.isDebugEnabled()) {
logger.debug("Connected");
}
}
return conn;// 返回该Connection
}
/**
* 传入执行查询的语句，返回结果集
*
* @param conn
* Connection连接对象
* @param sql
* String类型的sql语句
* @return 结果集 ResultSet
*/
public ResultSet executeQuery(Connection conn, String sql) {
Statement stmt = null;// 声明Statement stmt
ResultSet rs = null;// 声明ResultSet rs
if (conn != null) {
// Connection 不为null，执行查询
// 若debug模式开启，则输出debug 信息
if (logger.isDebugEnabled()) {
logger.debug(sql);
}
try {
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
ResultSet.CONCUR_READ_ONLY);// 通过Connection创建一个Statemet
rs = stmt.executeQuery(sql);// 执行查询语句，
} catch (SQLException sqlex) {
logger.error("Execute query failed: [" + sql + "]");
logger.error(sqlex.getMessage());
return null;
}
return rs;
} else {
// Connection 为null，输出info信息，返回null
logger.info("Connection is null, execute sql query: [" + sql
+ "] failed");
return null;
}
}
/**
* 传入执行数据更新的语句，返回更新结果，成功执行为真
*
* @param conn
* Connection连接对象
* @param sql
* String类型的sql语句
* @return 执行结果，布尔型
*/
public boolean executeUpdate(Connection conn, String sql) {
boolean status = false;// 执行结果，默认为false
Statement stmt = null;// 声明Statement stmt
if (conn != null) {
// Connection 不为null，执行更新
// 若debug模式开启，则输出debug 信息
if (logger.isDebugEnabled()) {
logger.debug(sql);
}
try {
stmt = conn.createStatement();// 通过Connection创建一个Statemet
int count = stmt.executeUpdate(sql);// 执行更新数据操作，返回影响的行数
// 根据count值,判断执行的成功或失败
if (count > 0)
status = true;
} catch (SQLException sqlex) {
logger.error("Execute update failed: [" + sql + "]");
logger.error(sqlex.getMessage());
}
} else {
// Connection 为null，输出info信息，返回false
logger.info("Connection is null, execute sql update: [" + sql
+ "] failed");
}
return status;
}
/**
* 释放从连接池取得的连接
*
* @param conn
* Connection连接对象
*/
public void releaseConnection(Connection conn) {
// 释放连接
if (conn != null) {
try {
conn.close();
if (logger.isDebugEnabled()) {
logger.debug("Connection released");
}
} catch (SQLException sqlex) {
logger.error("Release connection failed");
} finally {
conn = null;
}
}
}
}
代码的应用，举两个例子
1、查询
package ttm.bean;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import com.util.DatabaseManager;
public class ScoreTypeDAO {
private DatabaseManager dm = null;
private Connection conn = null;
/**
* 构造函数，初始化DatabaseManager对象
*
*/
public ScoreTypeDAO() {
dm = new DatabaseManager();
}
/**
* 获取所有成绩类型编号
*
* @return 所有成绩类型编号
*/
public ArrayList<String> getAllScoreTypeId() {
ArrayList<String> sctpId = new ArrayList<String>();
String sql = "select SCORE_TP_ID from TC_SCORE_TP;";
try {
// 建立连接
conn = dm.getConnection();
ResultSet rst = dm.executeQuery(conn, sql);
while (rst.next()) {
// new a string
String str = new String();
str = rst.getString(1);// 成绩类型名称
sctpId.add(str);
}
} catch (SQLException sqlex) {
sqlex.printStackTrace();
} finally {
dm.releaseConnection(conn);
}
return sctpId;
}
}
2、删除
package ttm.bean;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import com.util.DatabaseManager;
public class CrswreDAO {
private DatabaseManager dm = null;
private Connection conn = null;
public CrswreDAO() {
dm = new DatabaseManager();
}
/**
* 删除给定id的课件
*
* @param crswreid
*/
public void delCrswre(String crswreid) {
String sql = "delete from TC_EDU_CRSWRE where ISN = '" + crswreid + "'";
try {
// 建立连接
conn = dm.getConnection();
dm.executeUpdate(conn, sql);
} finally {
dm.releaseConnection(conn);
}
}
总结：简化的目的基本打到了，但是离我的目标还是有很大的差距。首先try...catch...finally还是存在，代码依然很繁杂；其次就是异常没有被很好的进行管理。
这是第一次自己做工具的类尝试，虽然不是非常成功，却还是让我有很大的收获。独力完成如spring中的jdbc助手类般的代码对我而言似乎还太远，不过理解spring中的方法已经没有太大问题，接下来合理运用spring提供的基础架构是我和Pheonix要钻研的。
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- java 代码实现使用Druid 链接池获取数据库链接
- Java 链接Mysql 数据库时使用变量插入数据方法
- Java Web开发使用配置文件链接数据库
- java 代码实现使用Druid 链接池获取数据库链接
- java解析配置文件config.propertie 使用JDBC链接数据库
- java的JDBC驱动使用链接数据库
- Java使用jdbc链接数据库的MySQL 5.5.45+以及SSL错误解决办法
- Java中使用连接池技术链接数据库
- java 使用jdbc 链接数据库
- Java JDBC链接数据库使用方式 java JDBC链接SQlServer数据库
- Java使用JDBC编写解耦链接数据库
- Java中链接MS SQL 数据库用法详解
- java使用list实现数据库的like功能
- Java链接数据库的基本步骤
- oracle 数据库的管理工具 PL/SQL_Developer 的简易使用 与Java 连接并查询显示出数据
- java使用jdbc连接数据库工具类和jdbc连接mysql数据示例
- java 链接数据库实现登录验证
- java自定义动态链接数据库示例
- 使用C编写的动态链接库为PostgreSQL数据库添加自定义函数
- 使用python链接wamp或者xamp中的数据库