事務：保證操作的一致性，要麼操作同時成功，要麼同時失敗；

最經典的例子就是轉賬：A向B轉賬，如果轉賬成功，那麼必然A的錢減少，B的錢增多；如果轉賬失敗，那麼必然是A和B的餘額都沒有發生變化；這個例子就用到了事務操作；

Mysql 對事物的支援：

序號          命令                                  描述

1               set autocommit = 0          關閉自動提交

2               set autocommit = 1          開啟自動提交

3               begin                               啟動事務

4               commit                             提交事務        

5               rollback                            回滾

如圖1，先建立一個user表

我們來插入一個數據：

利用：insert into  user(id,password,money) values(1004,'abcdef',999999999);

查一下表發現新增成功，可是畢竟我們普通人沒有10億差一塊這麼多的錢，這個數字輸入錯誤，想回到之前正確的狀態怎麼辦呢，不用想了，肯定回不去了，因為這個值已經寫入硬碟了。為了避免這種情況發生，就需要用到事務了。

首先，設定取消自動提交

set autocommit = 0;

然後開啟事務

begin;

然後插入一條語句

insert into  user(id,password,money) values(1005,'abcdef',999999999);

哎媽呀，發現插錯了怎麼辦呢，別急咱們這次可以回滾

rollback;

這下可以看到，已經滾回去了；

如果提交的是正確的資料怎麼辦，這時就要用commit來提交事務

commit;

現在就已經提交成功了，我們在回滾試試：

rollback;

回滾之後，資料依然存在。

然後再JDBC中使用事務

新建一個Basedao 類，裡面有開啟關閉資料庫連線的方法

package com.yanglf;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.PreparedStatement;
public class Basedao {
	
	final static String driver = "com.mysql.jdbc.Driver";
	final static String dburl = "jdbc:mysql://localhost:3306/db";
	final static String name = "root";
	final static String password = "745412";
	
	Connection con = null;
	PreparedStatement ps = null;
	ResultSet rs = null;
	
	public  void openCon() throws  Exception {
		
		Class.forName(driver);
		con = DriverManager.getConnection(dburl,name,password);
		System.out.println(con);
		
	}
	public void closeCon() throws Exception{
		if(ps!=null){
			ps.close();
		}
		if(rs!=null){
			rs.close();
		}
		if(con!=null){
			con.close();
		
		}
	}

}

package com.yanglf;

import java.sql.SQLException;
import java.sql.Timestamp;
import java.util.Date;

import com.mysql.jdbc.PreparedStatement;

public class GetMessage {

	/**
	 * @param args
	 * @throws SQLException 
	 * @throws Exception 
	 */
	public static void main(String[] args)  {
		Basedao tj = new Basedao();
	
		try {
			
			tj.openCon();
			
			//注意與在資料庫中操作有點不同，資料庫為set autocommit = 0;
			tj.con.setAutoCommit(false);
			//利用佔位符，減少字串拼接的麻煩
			String sql1 = "insert into record (id,date,money,state) values (?,?,?,?);";
		
			//插入一條存入200塊錢的資料
			tj.ps = tj.con.prepareStatement(sql1);
			tj.ps.setInt(1, 1003);
			tj.ps.setLong(2, new Date().getTime());
			tj.ps.setInt(3, 100);
			tj.ps.setString(4, "存入");
		
			//修改新增刪除資訊返回的是受影響行數
			int row = tj.ps.executeUpdate();
			//在同時插入一條取出300的資料記錄
			tj.ps = tj.con.prepareStatement(sql1);
			tj.ps.setInt(1, 1003);
			tj.ps.setLong(2, new Date().getTime());
			tj.ps.setInt(3, 300);
			tj.ps.setString(4, "取出");
			int row2 = tj.ps.executeUpdate();
			
			//提交事務
			tj.con.commit();
		} catch (Exception e) {
			try {
				//回滾
				tj.con.rollback();
			} catch (SQLException e1) {
				
				e1.printStackTrace();
			}
			e.printStackTrace();
		}
		
		
		//然後來查詢下表
		String sql2 = "select * from record;";
		
		
		
		try {
			tj.ps = tj.con.prepareStatement(sql2);
			tj.rs = tj.ps.executeQuery();//查詢結果返回的是表
		} catch (SQLException e1) {
	
			e1.printStackTrace();
		}
		
		
		try {
			while (tj.rs.next()) {
			//控制檯輸出下查詢到的資訊
			System.out.println(tj.rs.getInt("id")+"\t"+new Timestamp(tj.rs.getLong("date"))+"\t"+
			tj.rs.getInt("money")+"\t"+tj.rs.getString("state"));
				
			}
		} catch (SQLException e) {
			
			e.printStackTrace();
		}
		
		
		try {
			tj.closeCon();//關閉資料連線
		} catch (Exception e) {
			
			e.printStackTrace();
		}

	}

}

[email protected]
10012016-05-16 23:28:06.492 322 轉出
10022016-05-16 23:28:06.499 322 轉入
10032016-05-21 00:37:06.895 100 存入
10032016-05-21 00:37:06.898 300 取出

同時也可以修改新增資料，比如將下面的這一句註釋掉，由於資料庫設定存入，取出狀態非空，所以這次插入會報異常

tj.ps.setString(4, "取出");

一句話：事務是為了保證資料的一致性和完整性