JDBC中处理事务，小Demo

事务的四大特性（ACID）：

 

 原子性（Atomicity）：事务中所有操作是不可再分割的原子单位。事务中所有操作要么全部执行成功，要么全部执行失败。

 一致性（Consistency）：事务执行后，数据库状态与其它业务规则保持一致。如转账业务，无论事务执行成功与否，参与转账的两个账号余额之和应该是不变的。

 隔离性（Isolation）：隔离性是指在并发操作中，不同事务之间应该隔离开来，使每个并发中的事务不会相互干扰。

 持久性（Durability）：一旦事务提交成功，事务中所有的数据操作都必须被持久化到数据库中，即使提交事务后，数据库马上崩溃，在数据库重启时，也必须能保证通过某种机制恢复数据。

      在默认情况下，每执行一条SQL语句，都是一个单独的事务。如果需要在一个事务中包含多条SQL语句，那么需要开启事务和结束事务。

 开启事务：start transaction；
 结束事务：commit或rollback。

      在执行SQL语句之前，先执行strat transaction，这就开启了一个事务（事务的起点），然后可以去执行多条SQL语句，最后要结束事务，commit表示提交，即事务中的多条SQL语句所做出的影响会持久化到数据库中。或者rollback，表示回滚，即回滚到事务的起点，之前做的所有操作都被撤消了！

 

Connection的三个方法与事务相关：

（1） setAutoCommit(boolean)：设置是否为自动提交事务，如果true（默认值就是true）表示自动提交，也就是每条执行的SQL语句都是一个单独的事务。

             如果设置false，那么就相当于开启了事务了；con.setAutoCommit(false)表示开启事务。

（2） commit()：提交结束事务；con.commit();表示提交事务。

（3） rollback()：回滚结束事务。con.rollback();表示回滚事务。

jdbc处理事务的代码格式：

try {
  con.setAutoCommit(false);//开启事务…
  ….
  …
  con.commit();//try的最后提交事务
} catch() {
  con.rollback();//回滚事务
}

 

首先做一些准备工作：

（1）配置数据源，确定使用的数据库。详细信息见http://blog.csdn.net/qq_25827845/article/details/50836362

（2）在数据库中建立表account，并且插入数据

create table account
(
  id int,
  balance int,
)
select * from account
insert into account values (1,1000)
insert into account values (2,1000)

如图所示：

在程序中，首先是程序没有发生异常，则，转账成功。

当程序发生异常时，查询数据库，则会发现转账操作并没有完成。符合ACID特性。

Demo代码展示：

package com.ywq;

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

public class Dao {
	/**
	 * 修改指定用户的余额！
	 * @param ct
	 * @param id
	 * @param balance
	 */
	
	//同一事务中必须使用同一个Connection对象，所以此处的Connection对象由调用处传入。
	public void updateBalance(Connection ct,int id,int balance){
		
		
		try {
			String sql="update account set balance=balance+? where id=?";
			PreparedStatement pt=ct.prepareStatement(sql);
			
			pt.setInt(1, balance);
			pt.setInt(2, id);
			
			pt.executeUpdate();
			
		} catch (SQLException e) {
			
			throw new RuntimeException(e);
		}
		
		
	}

}

 

package com.ywq;

import java.sql.*;

public class Demo {

	public static void main(String[] args) {
		zhuanZhang(1, 2, 100);

	}
	
	public static void zhuanZhang(int from, int to, int money) {
		// 对事务的操作必须使用Connection对象!
		Connection ct = null;
		try {
			 Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");  
			 ct=DriverManager.getConnection("jdbc:odbc:ywq");  
			 System.out.println(ct);
			
			//开启事务
			ct.setAutoCommit(false);

			Dao dao = new Dao();
			dao.updateBalance(ct, from, -money);//给from减去相应金额
			
			if(true) {
//把此处的if语句块注释掉，则转账成功 	throw new RuntimeException("不好意思，此处发生了异常，但是转账操作进行了一半，请观察结果");
			}
			
			dao.updateBalance(ct, to, money);//给to加上相应金额
			
			//提交事务
			ct.commit();
			ct.close();
		} catch(Exception e) {
			//回滚事务
			try {
				ct.rollback();
				ct.close();
			} catch (SQLException e1) {
			}
			throw new RuntimeException(e);
		}
	}
	

}