Java数据库操作（多语句提交）

package com.wei.db;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.List;

public class DBHelper {
String sDriverName = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
String sDBUrl = "jdbc:sqlserver://localhost:1433;DatabaseName=Test";
String sUser = "sa";
String sPwd = "123456";
private Connection conn = null;

//连接数据库
public boolean connect() {
try {
Class.forName(sDriverName);
try {
conn = DriverManager.getConnection(sDBUrl, sUser, sPwd);
return true;
} catch (SQLException e) {
System.out.println("DBConnect:"+e);
return false;
}
} catch (ClassNotFoundException e) {
System.out.println("connect:"+e);
return false;
}
}

//数据库关闭
public void close() {
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
System.out.println("close:"+e);
}
}
}

//执行多条语句
public boolean executeMore(List<String> sqlList) {
if (conn!=null) {
try {
boolean isAutoCommit=conn.getAutoCommit();
conn.setAutoCommit(false);
Statement statement= conn.createStatement();
for (int i = 0; i < sqlList.size(); i++) {
statement.addBatch(sqlList.get(i));
}
statement.executeBatch();
conn.commit();
conn.setAutoCommit(isAutoCommit);
} catch (Exception e) {
System.out.println("executeMore:"+e);
try {
conn.rollback();
} catch (Exception rollbackError) {
System.out.println("rollback:"+e);
}
return false;
}
}
return false;
}

//执行单条语句
public boolean execute(String sql) {
if (conn!=null) {
try {
PreparedStatement pst=conn.prepareStatement(sql);
pst.executeUpdate();
return true;
} catch (SQLException e) {
System.out.println("execute:"+e);
return false;
}
}
return false;
}

//查询数据
public ResultSet query(String sql){
try {
Statement statement= conn.createStatement();
ResultSet rs=statement.executeQuery(sql);
return rs;
} catch (Exception e) {
System.out.println("query:"+e);
return null;
}
}
}

import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

import com.wei.db.DBHelper;

public class Test {

public static void main(String[] args) {

boolean res=false;

List<String> sqlList=new ArrayList<String>();
for (int i = 1; i < 50; i++) {
String sql="insert into UserInfo(user_name) values('number"+i+"')";
sqlList.add(sql);
}

//添加错误语句
//String errorSql="insert into UserInfo(user_name) values('number',1)";
//sqlList.add(errorSql);

DBHelper helper=new DBHelper();
res=helper.connect();
if (res) {
System.out.println("Connect success...");

//执行所有SQL语句
helper.executeMore(sqlList);

//查询
ResultSet rs=helper.query("select * from UserInfo");
try {
while (rs.next()) {
String name=rs.getString(1);
System.out.println(name);
}
} catch (Exception e) {
System.out.println("ResultSet:"+e);
}

}else {
System.out.println("Connect fail...");
}
helper.close();
}

}