mysql事务的四大特性与简单运用

package mysql;

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Savepoint;
import java.sql.Statement;

import org.junit.Test;

//事物特性ACID
//原子性，指事务中的操作要么都发生，要么都不发生
//一致性。指事务前后数据的完整性必须保持一致(甲乙2人总额2000元，甲转账乙100元后，转账后总额还是2000元)
//隔离性。多个事务并发访问数据库的时候，一个事务间的操作不能干扰其他事务，要相互隔离
//持久性：指事务一旦提交(commit)，对数据库的改变是持久的，即使数据库故障也不应对数据有影响

//数据库的隔离级别Seraializable(串行化，最高级别，能处理各种问题，但数据库效率低下),repeated read,read commit,read uncommit


/*
create table account
(
	id int primary key auto_increment,
	name varchar(20),
	price int
);
/*
 * 事务，要么执行，要不执行
 * start transaction
  update account set price=price-100 where name='a';
  update account set price=price+100 where name='b';
 * sql2语句
 * commit(一定要执行commit才生效，不然回滚)
 */
public class 事务 {

	@Test
	public void test1() throws SQLException
	{
		Statement s=null;
		Connection con=DBHelper.getConnection();
		try{
		con.setAutoCommit(false);//不能一条一条执行sql
		String sql1="update account set price=price-100 where name='a'";
		String sql2="update account set price=price+100 where name='b'";
	    s=con.createStatement();
		s.executeUpdate(sql1);

		int i=8/0;  //这边有错，程序自动回滚
		
		s=con.createStatement();
		s.executeUpdate(sql2);
		
		
		con.commit();
		System.out.println("success....");
		}
		catch (Exception e) {
			con.rollback();//自动回滚
		}
		
  
		
	}
	
	@Test
	public void test2() throws SQLException  //手动回滚事务，假如第二条sql执行错误，程序回滚，让第一条sql正常插入数据库
	{
		Statement s=null;
		Connection con=DBHelper.getConnection();
		Savepoint p=null;
		try{
		con.setAutoCommit(false);//不能一条一条执行sql
		String sql1="update account set price=price-100 where name='a'";
		String sql2="update account set price=price+100 where name='b'";
		String sql3="update account set price=price+100 where name='c'";
	    s=con.createStatement();
		s.executeUpdate(sql1);
  
		 p=con.setSavepoint(); //保存点
		
		 int i=12/0;  //这边出错了，上一条依然插入数据库
		 
		s=con.createStatement();
		s.executeUpdate(sql2);
		
		s=con.createStatement();
		s.executeUpdate(sql3);
		
		con.commit();
		System.out.println("success....");
		}
		catch (Exception e) {
			
			con.rollback(p); //回滚到第一个，第一个要执行
			con.commit();   //手动回滚一定要提交
		}
	}
}