封装了一个Java数据库访问管理类

软件编程 java 分类:[default] 更新日期: 2016-05-03
刚刚试着用JDBC,仿着原来C#的写法写了这段代码,自己觉得还是挺粗糙的,还烦请路过的朋友推荐一个写得较好较完整的相关例程以便学习。谢谢!
代码如下:

package com.groundhog.codingmouse;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
/**
* 数据库管理类
* @author CodingMouse
* 2009.2.20
*/
public final class DBManager {
/**
* 数据库连接对象
*/
private Connection dbConnection = null;
/**
* 数据库命令执行对象
*/
private PreparedStatement preStatement = null;
/**
* 结果集对象
*/
private ResultSet rsSet = null;
/**
* 数据库驱动版本号
*/
private static String driverVersion = null;
/**
* 数据库服务器登录用户名和密码字符串常量(默认值均
为'sa')
*/
private static String databaseUser = "sa";
private static String databasePassword = "sa";
/**
* 数据库驱动完整类名字符串常量
*/
private static final String
DRIVER_CLASS_SQLSERVER2000 =
"com.microsoft.jdbc.sqlserver.SQLServerDriver"; // SQL
Server 2000 直连
private static final String
DRIVER_CLASS_SQLSERVER2005 =
"com.microsoft.sqlserver.jdbc.SQLServerDriver"; // SQL
Server 2005 直连
private static final String
DRIVER_CLASS_BRIDGECONNECT = "sun.jdbc.odbc.JdbcOdbcDriver";
// ODBC 桥连
/**
* 数据库连接字符串常量
*/
private static final String
DATABASE_URL_SQLSERVER2000 =
"jdbc:microsoft:sqlserver://127.0.0.1:1433;DatabaseName=stuD
B"; // SQL Server 2000 直连
private static final String
DATABASE_URL_SQLSERVER2005 =
"jdbc:sqlserver://127.0.0.1:1433;DatabaseName=stuDB";
// SQL Server 2005 直连
private static final String
DATABASE_URL_BRIDGECONNECT = "jdbc:odbc:stuDBSource";
// ODBC 桥连
/**
* 定义类自身的实例静态变量(作用于单例[件]模式的应用)
*/
private static DBManager connectionManager = null;
/**
* 私有化默认构造(作用于单例[件]模式的应用,防止类被直
接使用new关键字实例化)
*/
private DBManager() {
super();
}
/**
* 获取数据库连接管理类实例的方法(单例[件]模式的应用)
* @param version 数据库驱动版本号,取值:(version =
2000 | version = 2005 | version = odbc)
* @param user 数据库服务器登录用户名
* @param password 数据库服务器登录密码
* @return 数据库连接管理对象
* @throws Exception 参数错误异常
*/
public static DBManager getInstance(
String version,
String user,
String password)
throws Exception {
if (!(version == "2000" || version == "2005"
|| version == "odbc")) {
throw new Exception("数据库驱动版本号
不正确,取值只能是“2000/2005/odbc”!");
}
// 保存数据库驱动版本号
driverVersion = version;
if (user == null || user.equals("")) {
throw new Exception("数据库服务器登录
用户名不能为空!");
}
// 保存数据库服务器登录用户名和密码
databaseUser = user;
databasePassword = password;
// 应用单例[件]模式确保类本身只有一个实例
if (connectionManager == null) {
connectionManager = new DBManager();
}
// 返回类本身的实例
return connectionManager;
}
/**
* 获取数据库连接的方法
* @return 数据库连接对象
*/
private Connection getConnection() {
try {
Class.forName(
driverVersion ==
"2000"
?
DRIVER_CLASS_SQLSERVER2000
: (driverVersion ==
"2005"
?
DRIVER_CLASS_SQLSERVER2005
:
DRIVER_CLASS_BRIDGECONNECT));
this.dbConnection =
DriverManager.getConnection(
driverVersion ==
"2000"
?
DATABASE_URL_SQLSERVER2000
: (driverVersion ==
"2005"
?
DATABASE_URL_SQLSERVER2005
:
DATABASE_URL_BRIDGECONNECT),
databaseUser,
databasePassword);
} catch (ClassNotFoundException ex) {
System.err.println("未找到SQL Server
" + driverVersion + "数据库驱动类:" + ex.getMessage());
// 在控制台输出异常堆栈信息
// ex.printStackTrace();
} catch (Exception ex) {
System.err.println("获取数据库连接错
误:" + ex.getMessage());
// 在控制台输出异常堆栈信息
// ex.printStackTrace();
}
// 返回数据库连接对象
return this.dbConnection;
}
/**
* 获取数据库命令执行对象的方法
* @param sql 要执行的SQL命令拼装语句字符串
* @return 数据库命令执行对象
*/
private PreparedStatement getPreparedStatement
(String sql) {
try {
// 根据获取的数据库连接对象创建数据库
命令执行对象
this.preStatement = getConnection
().prepareStatement(sql);
} catch (Exception ex) {
System.err.println("获取数据库命令执
行对象错误:" + ex.getMessage());
// 在控制台输出异常堆栈信息
// ex.printStackTrace();
}
// 返回数据库命令执行对象
return this.preStatement;
}
/**
* 执行更新语句(Insert|Update|Delete)
* @param sql 要执行的SQL命令拼装语句字符串
* @return 受影响的行数
*/
public int executeUpdate(String sql){
try {
// 置空结果集对象的原有内容
this.rsSet = null;
// 执行语句并返回受影响行数
return this.getPreparedStatement
(sql).executeUpdate();
} catch (SQLException e) {
System.err.println("更新数据错误:" +
e.getMessage());
return 0;
}finally{
// 关闭数据库连接资源
closeDBResource();
}
}
/**
* 执行查询语句(Select)
* @param sql 要执行的SQL命令拼装语句字符串
* @return 查询后的结果集对象
*/
public ResultSet executeQuery(String sql){
try {
// 置空结果集对象的原有内容
this.rsSet = null;
// 执行sql语句获得结果集
this.rsSet =
this.getPreparedStatement(sql).executeQuery();
} catch (SQLException e) {
System.err.println("查询数据错误:" +
e.getMessage());
}
// 返回结果集对象
return this.rsSet;
}
/**
* 获取执行指定sql语句后的返回结果集的记录条数
* @param sql 要执行的SQL命令拼装语句字符串
* @return 查询结果得到的记录条数
*/
public int getResultSetCount(String sql) {
// 保存得到指定的sql语句执行后返回记录行数的计数器变量
int count = 0;
try {
// 置空结果集对象的原有内容
this.rsSet = null;
// 执行sql语句获得结果集
this.rsSet = this.getPreparedStatement
(sql).executeQuery();
// 遍历结果集并累加计数器
while (this.rsSet.next()) {
count++;
}
} catch (SQLException e) {
e.printStackTrace();
}
return count;
}
/**
* 关闭数据库连接资源(包括结果集对象、命令执行对象、连
接对象)
*/
public void closeDBResource() {
try {
closeResultSet();
closePreparedStatement();
closeConnection();
} catch (SQLException sqlEx) {
System.err.println(sqlEx.getMessage
());
// 在控制台输出异常堆栈信息
// sqlEx.printStackTrace();
}
}
/**
* 关闭结果集对象的方法
* @throws SQLException
*/
private void closeResultSet() throws SQLException {
try {
if (this.rsSet != null) {
this.rsSet.close();
this.rsSet = null;
}
} catch (SQLException sqlEx) {
throw new SQLException("关闭结果集对
象错误:" + sqlEx.getMessage());
// 在控制台输出异常堆栈信息
// sqlEx.printStackTrace();
}
}
/**
* 关闭数据库命令执行对象的方法
* @throws SQLException
*/
private void closePreparedStatement() throws
SQLException {
try {
if (this.preStatement != null) {
this.preStatement.close();
this.preStatement = null;
}
} catch (SQLException sqlEx) {
throw new SQLException("关闭数据库命
令执行对象错误:" + sqlEx.getMessage());
// 在控制台输出异常堆栈信息
// sqlEx.printStackTrace();
}
}
/**
* 关闭数据库连接的方法
* @throws SQLException
*/
private void closeConnection() throws SQLException {
try {
if (this.dbConnection != null && (!
this.dbConnection.isClosed())) {
this.dbConnection.close();
}
} catch (SQLException sqlEx) {
throw new SQLException("关闭数据库连
接错误:" + sqlEx.getMessage());
// 在控制台输出异常堆栈信息
// sqlEx.printStackTrace();
}
}
}

> 本站内容系网友提交或本网编辑转载,其目的在于传递更多信息,并不代表本网赞同其观点和对其真实性负责。如涉及作品内容、版权和其它问题,请及时与本网联系,我们将在第一时间删除内容!

相关文章
  • MongoDB的Master-Slave主从模式配置及主从复制要点解析
    主从复制是数据库运维中一种常见的备份方式,这里我们来看一下MongoDB的Master-Slave主从模式配置及主从复制要点解析,需要的朋友可以参考下主从配置mongodb的master-slave模式配置方式如下1.keyFile生成key_file openssl rand -base64 741 > mongo_key 将mongo_key 分别 ...
  • 将xml文件作为一个小的数据库,进行学生的增删改查的简单实例
    下面小编就为大家带来一篇将xml文件作为一个小的数据库,进行学生的增删改查的简单实例.小编觉得挺不错的,现在就分享给大家,也给大家做个参考.一起跟随小编过来看看吧1.xml文件: <?xml version="1.0" encoding="UTF-8"?><Students> <stude ...
  • 将PHP的session数据存储到数据库中的代码实例
    这里我们将分享两个将PHP的session数据存储到数据库中的代码实例,分别针对PostgreSQL与MySQL,需要的朋友可以参考下一个开发环境有多个网站,需要使用不同的session,解决方案很多.不过这次也高大上一把,用数据库存,方便以后扩展. PostgreSQL版首先是数据库的部分 --drop table php_session create u ...
  • asp.net及javascript判断是否手机访问的方法
    这篇文章主要介绍了asp.net及javascript判断是否手机访问的方法,结合实例形式对比分析了asp.net及javascript实现判断访问端类型的相关技巧,需要的朋友可以参考下本文实例讲述了asp.net及javascript判断是否手机访问的方法.分享给大家供大家参考,具体如下: /// <summary> /// 判断手机用户Use ...
  • ASP.NETWebApi2实现多文件打包并下载文件的实例
    ASP.NETWebApi2实现多文件打包并下载文件的实例
    这篇文章主要介绍了ASP.NET Web Api 2利用ByteArrayContent和StreamContent实现多文件打包并下载的方法,提供源码下载,需要的朋友可以参考下.最近由于工作和个人事务,站点也好久没更新了,但这并不影响我对.NET的热情.站点的更新工作还是得想办法抽时间来完成的. 今天利用中午的时间来写一篇关于Asp.Net Web Api ...
  • php项目开发中用到的快速排序算法分析
    这篇文章主要介绍了php项目开发中用到的快速排序算法,结合实例形式详细分析了php快速排序的原理与使用方法,需要的朋友可以参考下本文实例讲述了php项目开发中用到的快速排序算法.分享给大家供大家参考,具体如下: 实际上在,做web开发,比较少遇到使用一些算法之类的,毕竟不是做搜索引擎,也不是写底层(比如写个类似于mysql这样的数据库,里面需要自己实现排序算 ...
猜你喜欢