package main.java.util;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Hashtable;
public class DbHelper {
/**
* 常见错误
* 1、在ResultSet迭代的时候，没有用<=导致没有获得当前数据行的列的最后的一列数据，
* 这个错误会导致，在获取之以后给实体bean对象赋值的时候抛出空指针异常
* 2、pstmt.setObject(i + 1, params.get(i));正确的
* pstmt.setObject(i, params.get(i));错误的写法没有把数据参数的索引从1开始
*
*
*/
// 连接数据库
private static Connection connection;
// 执行带预处理的sql语句
private static PreparedStatement pstmt;
// 接受数据的查询的返回结果集
private static ResultSet rs;
// jdbc:jtds:sqlserver://<hostname>[:<port>]/<dbname>
private static String sqlurlString = "jdbc:jtds:sqlserver://localhost:1433/First";
private static String dbname = "card";
private static String dbpwd = "card";
/**
*
* 获得数据库的连接的方法
*
* @return
*/
public static Connection getConnction() {
// 获得驱动连接数据库
try {
//Class.forName("net.sourceforge.jtds.jdbc.Driver");
Class.forName("oracle.jdbc.OracleDriver");
connection = java.sql.DriverManager.getConnection(sqlurlString, dbname, dbpwd);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}
/**
* 执行查询的通用方法
* @param sql
* @param params
* @return
*/
public static ArrayList<Hashtable<String, Object>> executeQuery(String sql,
ArrayList<Object> params) {
ArrayList<Hashtable<String, Object>> resultArrayList = null;
// 执行查询，必须先判断是否有正常的数据连接
try {
if (null == connection || connection.isClosed()) {
getConnction();
}
pstmt = connection.prepareStatement(sql);
if (null != params) {
if (params.size() > 0) {
for (int i = 0; i < params.size(); i++) {
//System.out.println(params.set(1, 0));
//预处理的pstmt对象设置值
pstmt.setObject(i + 1, params.get(i));
}
}
}
rs = pstmt.executeQuery();
if (null != rs) {
resultArrayList = new ArrayList<Hashtable<String, Object>>();
while (rs.next()) {
// 获得数据库表的结构
ResultSetMetaData rsmdData = rs.getMetaData();
Hashtable<String, Object> rowHashtable = new Hashtable<String, Object>();
for (int j = 1; j <= rsmdData.getColumnCount(); j++) {
rowHashtable.put(rsmdData.getColumnName(j)
.toLowerCase(), rs.getObject(j));
}
resultArrayList.add(rowHashtable);
}
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
closeAll();
}
return resultArrayList;
}
/**
* 该方法执行数据库数据的添加，删除，和修改的操作
* @param sql 执行的T-SQL 语句，也就是结构化查询语句
* @param params 执行sql语句有可能用到的参数的集合
* @return int
*/
public static int executeSave(String sql, ArrayList<Object> params){
int result = 0;
/**
* 1、判断数据库的连接状态，如果没有连接则连接数据库，先获得数据库的连接
* 2、执行预处理的sql语句对象，PreparedStatement，有可能该sql有相关的参数
* 3、判断是否有参数，如果有则进行参数的绑定
* 4、执行sql语句，获得返回的执行结果，会是int返回数据中受影响的行数
* 5、执行资源的回收
*
*/
try {
//1、判断数据库的连接状态，如果没有连接则连接数据库，先获得数据库的连接
if(null == connection || connection.isClosed()){
getConnction();
}
//2、执行预处理的sql语句对象，PreparedStatement，有可能该sql有相关的参数
//执行该对象，需要一个有效的SQL语句
pstmt = connection.prepareStatement(sql);
//3、判断是否有参数，如果有则进行参数的绑定
if(null != params){
if(params.size()>0){
for(int i=0; i<params.size();i++){
pstmt.setObject(i+1, params.get(i));
}
}
}
//4、执行sql语句，获得返回的执行结果，会是int返回数据中受影响的行数
result = pstmt.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}finally{
//5、执行资源的回收
closeAll();
}
return result;
}
public static void closeAll() {
try {
if (null != rs) {
rs.close();
rs = null;
}
if(null !=pstmt){
pstmt.close();
pstmt = null;
}
if (null != connection) {
connection.close();
connection= null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
1 个解决方案
#1
没有人回答吗，要求很简单的，就是批量处理多条update语句，假如失败一条之前的全部回滚而已，由于之前的数据库操作全是用的这个DBhelper所以想请各位帮我在这个DBhelper中添加一个方法，我能直接传入一个SQL集合然后返回成功失败就行
#1
没有人回答吗，要求很简单的，就是批量处理多条update语句，假如失败一条之前的全部回滚而已，由于之前的数据库操作全是用的这个DBhelper所以想请各位帮我在这个DBhelper中添加一个方法，我能直接传入一个SQL集合然后返回成功失败就行