JAVA中处理事务的程序--多条更新SQL语句的执行(包括回滚) .

简介: 转自:http://blog.csdn.net/fafeiboy/article/details/2734889  在与数据库操作时,如果执行多条更新的SQL语句(如:update或insert语句),在执行第一条后如果出现异常或电脑断电, 则后面的SQL语句执行不了,这时候设定我们自己提交SQL语句,不让JDBC自动提交,格式为: conn.

转自:http://blog.csdn.net/fafeiboy/article/details/2734889

 在与数据库操作时,如果执行多条更新的SQL语句(如:update或insert语句),在执行第一条后如果出现异常或电脑断电,

则后面的SQL语句执行不了,这时候设定我们自己提交SQL语句,不让JDBC自动提交,格式为:

conn.setAutoCommit(false);

执行多条SQL语句;

conn.commit();

//恢复自动提交模式

conn.setAutoCommit(true);

代码示例:

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();
   }
  }
 }

}

相关文章
|
2天前
|
监控 负载均衡 Java
如何设计高可用性的Java Web应用程序
如何设计高可用性的Java Web应用程序
|
6天前
|
SQL 安全 Java
java的SQL注入与XSS攻击
java的SQL注入与XSS攻击
23 2
|
3天前
|
Java
【Java】程序练习1(数组)
【Java】程序练习1(数组)
|
6天前
|
SQL 缓存 Java
Java框架之MyBatis 07-动态SQL-缓存机制-逆向工程-分页插件
Java框架之MyBatis 07-动态SQL-缓存机制-逆向工程-分页插件
|
7天前
|
Java UED 开发者
JVM逃逸分析原理解析:优化Java程序性能和内存利用效率
JVM逃逸分析原理解析:优化Java程序性能和内存利用效率
|
7天前
|
机器学习/深度学习 并行计算 搜索推荐
程序技术好文:桶排序算法及其Java实现
程序技术好文:桶排序算法及其Java实现
|
8天前
|
机器学习/深度学习 Java 程序员
Java递归函数:穿越程序世界的神奇之门
Java递归函数:穿越程序世界的神奇之门
|
10天前
|
人工智能 Java BI
Java程序代码实现的实例总结
Java程序代码实现的实例总结
13 0
|
10天前
|
SQL 关系型数据库 MySQL
省市区SQL(mysql、postgrel)-接口实现(java)
省市区SQL(mysql、postgrel)-接口实现(java)
17 0
|
10天前
|
人工智能 算法 搜索推荐
Java算法编程详解和程序实例
Java算法编程详解和程序实例
15 0