JDBC在springMvc等框架中使用的方式

作者:杏彩彩票app下载

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

复制代码 代码如下:
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();
}
}
}

复制代码 代码如下: package com.groundhog.codingmouse; import java.sql.Connection; import java.sql.Drive...

连接池jar:c3p0

第一部分代码(实体类)

图片 1

package com.wf.entity;

代码结构

public class Hehe{

图片 2

private int hehe_id;

 

private String hehe_name;


private String hehe_gender;

配置文件  config.properties

 

#hibernate.dialect=sy.util.Oracle10gDialect
#driverClassName=oracle.jdbc.driver.OracleDriver
#validationQuery=SELECT 1 FROM DUAL
#jdbc_url=jdbc:oracle:thin:@localhost:1521:orcl
#jdbc_username=bjlyjoa
#jdbc_password=bjlyjoa

public int getHehe_id(){

hibernate.dialect=org.hibernate.dialect.MySQL5InnoDBDialect
driverClass=com.mysql.jdbc.Driver
validationQuery=SELECT 1
jdbcUrl=jdbc:mysql://192.168.232.88:3306/xlzj_sh?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
user=root
password=123456

return hehe_id;

#hibernate.dialect=org.hibernate.dialect.SQLServer2008Dialect
#driverClassName=net.sourceforge.jtds.jdbc.Driver
#validationQuery=SELECT 1
#jdbc_url=jdbc:jtds:sqlserver://127.0.0.1:1433/qx
#jdbc_username=sa
#jdbc_password=123456

}

hibernate.hbm2ddl.auto=none
hibernate.show_sql=false
hibernate.format_sql=false
hibernate.use_sql_comments=false

public void setHehe_id(int heheId){

 

hehe_id=heheId;


}

数据库连接 文件

public String getHehe_name() {
return hehe_name;
}
public void setHehe_name(String heheName) {
hehe_name = heheName;
}
public String getHehe_gender() {
return hehe_gender;
}
public void setHehe_gender(String heheGender) {
hehe_gender = heheGender;
}

package light.mvc.framework.connectUtil;

 

import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;

 

import javax.sql.DataSource;

}

import com.mchange.v2.c3p0.DataSources;

第二部分 BaseDao(增删改查和查唯一)

/**
*
*    
* 项目名称:s4h4s2s   
* 类名称:DataSourceConnUtil   
* 类描述: c3p0连接池管理类  
* 创建人:刘军/jun liu   
* 创建时间:2015-12-19 下午11:40:35   
* 修改人:刘军/shall_liu   
* 修改时间:2015-12-19 下午11:40:35   
* 修改备注:   
* @version    
*    
*/
public class DataSourceConnUtil {

package com.wf.dao;

private static final String JDBC_DRIVER = "driverClass";
private static final String JDBC_URL = "jdbcUrl";

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

private static DataSource ds;
/**
* 初始化连接池代码块
*/
static{
initDBSource();
}

 

/**
* 初始化c3p0连接池
*/
private static final void initDBSource(){
Properties c3p0Pro = new Properties();
try {
//加载配置文件
c3p0Pro.load(DataSourceConnUtil.class.getResourceAsStream("/config.properties"));
//c3p0Pro.load(new FileInputStream(PathUtil.getPath("dabase.properties")));
} catch (Exception e) {
e.printStackTrace();
}

public class BaseDao{

String drverClass = c3p0Pro.getProperty(JDBC_DRIVER);
if(drverClass != null){
try {
//加载驱动类
Class.forName(drverClass);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}

protected static final String DRIVER="com.mysql.jdbc.Driver";

}

protected static final String URL="mysql://localhost:3306/mysql";

Properties jdbcpropes = new Properties();
Properties c3propes = new Properties();
for(Object key:c3p0Pro.keySet()){
String skey = (String)key;
if(skey.startsWith("c3p0.")){
c3propes.put(skey, c3p0Pro.getProperty(skey));
}else{
jdbcpropes.put(skey, c3p0Pro.getProperty(skey));
}
}

protected static final String USER="root";

try {
//建立连接池
DataSource unPooled = DataSources.unpooledDataSource(c3p0Pro.getProperty(JDBC_URL),jdbcpropes);
ds = DataSources.pooledDataSource(unPooled,c3propes);

protected static final String PASSWORD="******";

} catch (SQLException e) {
e.printStackTrace();
}
}

 

/**
* 获取数据库连接对象
* @return 数据连接对象
* @throws SQLException
*/
public static synchronized Connection getConnection() {
Connection conn = null;
try {
conn = ds.getConnection();
conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
conn.setAutoCommit(false);//取消 事务管理:事务提交机制
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
}

protected Connection connection=null;


protected PreparedStatement preparedStatement=null;

package light.mvc.framework.connectUtil;

protected ResultSet resultSet =null;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;

protected void getconnection() throws ClassNotFoundException, SQLException{

import javax.sql.DataSource;

   Class.forName(DRIVER);

import com.mchange.v2.c3p0.DataSources;

   this.connection =DriverManager.getconnection (URL,USER,PASSWORD);

/**
*
*    
* 项目名称:s4h4s2s   
* 类名称:DataSourceConnUtil   
* 类描述: c3p0连接池管理类  
* 创建人:刘军/jun liu   
* 创建时间:2015-12-19 下午11:40:35   
* 修改人:刘军/shall_liu   
* 修改时间:2015-12-19 下午11:40:35   
* 修改备注:   
* @version    
*    
*/
public class DataSourceConnUtil {

}

private static final String JDBC_DRIVER = "driverClass";
private static final String JDBC_URL = "jdbcUrl";

/**
* 通用的增删改方法
* @param sql SQL语句
* @param params 参数数组
* @return 受影响的行数
*/

private static DataSource ds;
/**
* 初始化连接池代码块
*/
static{
initDBSource();
}

protected int executeUpdate(String sql ,String[]params){
int result=-1;
try {
this.getconnection();
this.preparedStatement=this.connection.prepareStatement(sql);
if(null!=params){
for (int i = 0; i < params.length; i++) {

/**
* 初始化c3p0连接池
*/
private static final void initDBSource(){
Properties c3p0Pro = new Properties();
try {
//加载配置文件
c3p0Pro.load(DataSourceConnUtil.class.getResourceAsStream("/config.properties"));
//c3p0Pro.load(new FileInputStream(PathUtil.getPath("dabase.properties")));
} catch (Exception e) {
e.printStackTrace();
}

this.preparedStatement.setString(i+1, params[i]);

String drverClass = c3p0Pro.getProperty(JDBC_DRIVER);
if(drverClass != null){
try {
//加载驱动类
Class.forName(drverClass);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}

}

}

}
result= this.preparedStatement.executeUpdate();
} catch (ClassNotFoundException e) {

Properties jdbcpropes = new Properties();
Properties c3propes = new Properties();
for(Object key:c3p0Pro.keySet()){
String skey = (String)key;
if(skey.startsWith("c3p0.")){
c3propes.put(skey, c3p0Pro.getProperty(skey));
}else{
jdbcpropes.put(skey, c3p0Pro.getProperty(skey));
}
}

e.printStackTrace();
} catch (SQLException e) {

try {
//建立连接池
DataSource unPooled = DataSources.unpooledDataSource(c3p0Pro.getProperty(JDBC_URL),jdbcpropes);
ds = DataSources.pooledDataSource(unPooled,c3propes);

e.printStackTrace();
}finally{
this.close();
}
return result;
}

} catch (SQLException e) {
e.printStackTrace();
}
}

 

/**
* 获取数据库连接对象
* @return 数据连接对象
* @throws SQLException
*/
public static synchronized Connection getConnection() {
Connection conn = null;
try {
conn = ds.getConnection();
conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
conn.setAutoCommit(false);//取消 事务管理:事务提交机制
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
}

/**
* 查询结果集的方法
* @param sql
* @param params
*/
protected void executeQuery(String sql,String[]params){


try {
this.getconnection();
this.preparedStatement=this.connection.prepareStatement(sql);
if(null!=params){
for (int i = 0; i < params.length; i++) {
this.preparedStatement.setString(i+1, params[i]);
}

package light.mvc.framework.connectUtil.jdbcUtl;
/**
*
* @Title: SqlParameter.java 
* @Package light.mvc.framework.connectUtil.jdbcUtl 
* @Description: TODO(存储过程参数类型) 
* @author 刘军
* @date 2016-3-19 下午2:47:02 
* @version V1.0  
*/
public class SqlParameter {

}
this.resultSet=this.preparedStatement.executeQuery();
} catch (ClassNotFoundException e) {

/**
* 参数名称
*/
public String Name;
/**
* 参数值
*/
public Object Value;
/**
* true表示参数为输出类型
*/
public boolean OutPut;
/**
* 参数类型
*/
public int Type;
/**
* 输入类型参数的构造函数
* @param name 存储过程 输入类型 参数名称
* @param value 存储过程 输入类型 参数值
*/
public SqlParameter(String name,Object value){
this.Name = name;
this.Value= value;
}
/**
* 输出类型参数的构造函数
* @param type 存储过程 输出类型 参数类型
* @param name 存储过程 输出类型 参数名称
*/
public SqlParameter(int type,String name){
this.Name = name;
this.OutPut = true;
this.Type = type;
}
/**
* 返回类型参数的构造函数
* @param type 存储过程 返回类型
*/
public SqlParameter(int type){
this.Name = "";
this.OutPut = true;
this.Type = type;
}
}

e.printStackTrace();
} catch (SQLException e) {

本文由杏彩发布,转载请注明来源

关键词: