JAVA中处理事务的程序--多条更新SQL语句的执行(包括回滚) .
2012-07-02 14:08
701 查看
在与数据库操作时,如果执行多条更新的SQL语句(如:update或insert语句),在执行第一条后如果出现异常或电脑断电,
则后面的SQL语句执行不了,这时候设定我们自己提交SQL语句,不让JDBC自动提交,格式为:
conn.setAutoCommit(false);
执行多条SQL语句;
conn.commit();
//恢复自动提交模式
conn.setAutoCommit(true);
代码示例:
[Java]
view plaincopyprint?
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class TestTransaction {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
Connection con = null;
Statement stmt = null;
ResultSet rs = null;
PreparedStatement ps = null;
try {
Class.forName("com.mysql.jdbc.Driver");
con = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/mydb", "root", "root");
System.out.println("连接数据库成功!");
stmt = con.createStatement();
// JAVA默认为TRUE,我们自己处理需要设置为FALSE,并且修改为手动提交,才可以调用rollback()函数
con.setAutoCommit(false);
stmt.addBatch("insert into people values(078,'ding','duo')");
stmt.addBatch("insert into people values(30,'nokia','ddd')");
stmt.executeBatch();
// 事务提交
con.commit();
// 设置为自动提交,改为TRUE
con.setAutoCommit(true);
/*
* String sql = "select * from people"; rs = stmt.executeQuery(sql);
* while(rs.next()){ System.out.println(rs.getString("id") + " " +
* rs.getString("name")); }
*/
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException se) {
se.printStackTrace();
try {
// 产生的任何SQL异常都需要进行回滚,并设置为系统默认的提交方式,即为TRUE
if (con != null) {
con.rollback();
con.setAutoCommit(true);
}
} catch (SQLException se1) {
se.printStackTrace();
}
} finally {
try {
if (rs != null) {
rs.close();
rs = null;
}
if (stmt != null) {
stmt.close();
stmt = null;
}
if (con != null) {
con.close();
con = null;
}
} catch (SQLException se) {
se.printStackTrace();
}
}
}
}
<PRE>
则后面的SQL语句执行不了,这时候设定我们自己提交SQL语句,不让JDBC自动提交,格式为:
conn.setAutoCommit(false);
执行多条SQL语句;
conn.commit();
//恢复自动提交模式
conn.setAutoCommit(true);
代码示例:
[Java]
view plaincopyprint?
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class TestTransaction {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
Connection con = null;
Statement stmt = null;
ResultSet rs = null;
PreparedStatement ps = null;
try {
Class.forName("com.mysql.jdbc.Driver");
con = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/mydb", "root", "root");
System.out.println("连接数据库成功!");
stmt = con.createStatement();
// JAVA默认为TRUE,我们自己处理需要设置为FALSE,并且修改为手动提交,才可以调用rollback()函数
con.setAutoCommit(false);
stmt.addBatch("insert into people values(078,'ding','duo')");
stmt.addBatch("insert into people values(30,'nokia','ddd')");
stmt.executeBatch();
// 事务提交
con.commit();
// 设置为自动提交,改为TRUE
con.setAutoCommit(true);
/*
* String sql = "select * from people"; rs = stmt.executeQuery(sql);
* while(rs.next()){ System.out.println(rs.getString("id") + " " +
* rs.getString("name")); }
*/
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException se) {
se.printStackTrace();
try {
// 产生的任何SQL异常都需要进行回滚,并设置为系统默认的提交方式,即为TRUE
if (con != null) {
con.rollback();
con.setAutoCommit(true);
}
} catch (SQLException se1) {
se.printStackTrace();
}
} finally {
try {
if (rs != null) {
rs.close();
rs = null;
}
if (stmt != null) {
stmt.close();
stmt = null;
}
if (con != null) {
con.close();
con = null;
}
} catch (SQLException se) {
se.printStackTrace();
}
}
}
}
<PRE>
相关文章推荐
- JAVA中处理事务的程序--多条更新SQL语句的执行(包括回滚)
- JAVA中处理事务的程序--多条更新SQL语句的执行(包括回滚) .
- JAVA中处理事务的程序--多条更新SQL语句的执行(包括回滚)
- C# 执行多条SQL更新语句,实现数据库事务
- (C#)执行多条SQL语句,事务处理
- .net 事务问题,执行多条更新语句,如果有一条出异常,全部回滚
- 用 p6spy 来观察 Java 程序中执行的所有 SQL 语句(三. 定制输出)
- 教您用事务一次处理多条SQL语句
- Java-mybatis-一次执行多条SQL语句
- 在EF4.1的DBContext中实现事务处理(BeginTransaction)和直接执行SQL语句的示例
- 用事务一次处理多条SQL语句
- 在EF4.1的DBContext中实现事务处理(BeginTransaction)和直接执行SQL语句的示例
- .java 执行多条 sql 语句
- 在EF4.1的DBContext中实现事务处理(BeginTransaction)和直接执行SQL语句的示例
- 用事务一次处理多条SQL语句
- ORACLE DML LOCK时找出对应SESSION正在执行的SQL语句(ORA-12841,无法变更事务处理中的会话并行 DML 状态)
- 事务一次处理多条SQL语句
- 使用事务一次处理多条SQL语句
- T-SQL 存储过程中使用事务并回滚出错的SQL语句(C#事务处理)
- Java一次执行多条SQL语句