Mysql數據庫事務實驗以及總結

   爲了作這個實驗，設計個場景，要把用戶2 上帳戶的22塊錢打一塊錢到帳戶1的帳上去。要麼全成功，全失敗，也就是帳要作平。

    代碼以下：

其中最關鍵的是：

updateMoneyByUserId(1, getMoneyByUserId(1) + 1,false); //這條語句是否回滾

updateMoneyByUserId(2, getMoneyByUserId(2) - 1,true); //設置拋出異常,

當用戶2在打錢時拋出異常，沒成功時，用戶1的更新要回滾回來。在mysql connection中默認是自動提交的，須要設置爲手動提交，而後纔可用rollback方法進行回滾。

package com.test.transaction;


import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;


/**
 CREATE TABLE `usermoney` (
  `user_id` int(11) NOT NULL DEFAULT '0',
  `moneyNum` int(11) DEFAULT NULL,
  PRIMARY KEY (`user_id`)
) ENGINE=InnoDB DEFAULT CHARSET=latin1 COMMENT='user for money';


INSERT INTO `usermoney` VALUES (1,11),(2,22),(3,33),(4,44),(5,55);
 * */
public class TranTest {

static Connection connection;
static {
try {
// 加載驅動程序
Class.forName("com.mysql.jdbc.Driver");
// 連續數據庫
connection = DriverManager.getConnection(
"jdbc:mysql://127.0.0.1:3306/banker", "root", "123456");
if (!connection.isClosed()) {
System.out.println("created connetion...:" + connection);
}
} catch (Exception e) {
e.printStackTrace();
}
}


public static void main(String[] args) throws InterruptedException {


try {
//手工設置數據庫爲一個初始狀態，並提交
connection.setAutoCommit(false);//默認爲自動提交
updateMoneyByUserId(1, 11,false);
updateMoneyByUserId(2, 22,false);
connection.commit();

//查詢是不是設置正確1 --11 ； 2 --22
System.out.println("userID=1 & moneyNum=" + getMoneyByUserId(1));
System.out.println("userID=2 & moneyNum=" + getMoneyByUserId(2));

//若是更新是拋異常，須要注意回滾
connection.setAutoCommit(false);
updateMoneyByUserId(1, getMoneyByUserId(1) + 1,false); //這條語句是否回滾

updateMoneyByUserId(2, getMoneyByUserId(2) - 1,true); //設置拋出異常,

//若是拋異常，下面語句再也不執行
System.out.println("userID=1 & moneyNum=" + getMoneyByUserId(1));
System.out.println("userID=2 & moneyNum=" + getMoneyByUserId(2));

//若是不拋異常，不提交會怎樣？(結束時仍是會作一次提交)
connection.commit(); 

} catch (SQLException e) {
try {
e.printStackTrace();
//開始回滾
connection.rollback();
//數據庫是否仍是正確的呢？1==11 ； 2==22
System.out.println("check if userId=1 and moneyNum==11-->userID=1 & moneyNum=" + getMoneyByUserId(1));
System.out.println("check if userId=2 and moneyNum==22-->userID=2 & moneyNum=" + getMoneyByUserId(2));
} catch (SQLException e1) {
e.printStackTrace();
}
}
Thread.sleep(10000L);


}
/**
* 經過UserId獲取Money number
* */
public static int getMoneyByUserId(int userId) throws SQLException {
// 執行SQL語句
Statement statement = connection.createStatement();
// 要執行的SQL語句
String sql = "select user_id,moneyNum from usermoney where user_id="
+ userId;
statement.execute(sql);
ResultSet rs = statement.executeQuery(sql);
rs.next();
return new Integer(rs.getString("moneyNum"));
}
/**
* 更新用戶金額
* */
public static void updateMoneyByUserId(int userId, int moneyNum,boolean showThrow)
throws SQLException {
// 執行SQL語句
if (showThrow) {
throw new SQLException("不讓你存");

}
Statement statement = connection.createStatement();
// 要執行的SQL語句
String sql = "update usermoney set moneyNum=" + moneyNum
+ " where user_id=" + userId;
System.out.println(sql);
statement.executeUpdate(sql);
}
}
經過以上代碼實驗，咱們還能夠得出一個經驗。

在一個方法中同時操做本地數據庫和調用遠程接口時，要先把本地數據庫事務操做完成後，再調用遠程接口。

由於若是先調用接口，再操做本地數據庫事務是拋出異常，再回滾時，本地數據庫就和遠程接口數據不一致了。

若是先操做本地數據庫，拋出異常還能夠本身決定一次是否要調用遠程接口。

如今比較大的項目，經常使用spring來作事務管理，接下來作更多的這方面研究。