MySQL中的隔离级别和悲观锁及乐观锁示例

IdiotXue 2014-07-17

MySQL中的隔离级别和悲观锁及乐观锁示例

 

1,MySQL的事支持 
MySQL的事务支持不是绑定在MySQL服务器本身,而是与存储引擎相关:

 

  1. MyISAM:不支持事务,用于只读程序提高性能   
  2. InnoDB:支持ACID事务、行级锁、并发   
  3. Berkeley DB:支持事务  


2隔离级别
隔离级别决定了一个session中的事务可能对另一个session的影响、并发session对数据库的操作、一个session中所见数据的一致性 
ANSI标准定义了4个隔离级别,MySQL的InnoDB都支持:

Java代码

  1. READ UNCOMMITTED:最低级别的隔离,通常又称为dirty read,它允许一个事务读取还没commit的数据,这样可能会提高性能,但是dirty read可能不是我们想要的   
  2. READ COMMITTED:在一个事务中只允许已经commit的记录可见,如果session中select还在查询中,另一session此时insert一条记录,则新添加的数据不可见   
  3. REPEATABLE READ:在一个事务开始后,其他session对数据库的修改在本事务中不可见,直到本事务commit或rollback。在一个事务中重复select的结果一样,除非本事务中update数据库。   
  4. SERIALIZABLE:最高级别的隔离,只允许事务串行执行。为了达到此目的,数据库会锁住每行已经读取的记录,其他session不能修改数据直到前一事务结束,事务commit或取消时才释放锁。  

可以使用如下语句设置MySQL的session隔离级别:

 

[c-sharp] view plaincopy
 
  1. 1.  SET TRANSACTION ISOLATION LEVEL {READ UNCOMMITTED | READ COMMITTED | REPEATABLE READ | SERIALIZABLE}   

 

 

MySQL默认的隔离级别是REPEATABLE READ,在设置隔离级别为READ UNCOMMITTED或SERIALIZABLE时要小心,READ UNCOMMITTED会导致数据完整性的严重问题,而SERIALIZABLE会导致性能问题并增加死锁的机率

 

 

3,隔离级别
乐观所和悲观锁策略: 
悲观锁:在读取数据时锁住那几行,其他对这几行的更新需要等到悲观锁结束时才能继续 
乐观所:读取数据时不锁,更新时检查是否数据已经被更新过,如果是则取消当前更新 
一般在悲观锁的等待时间过长而不能接受时我们才会选择乐观锁 
悲观锁的例子:

 

[c-sharp] view plaincopy
 
  1. CREATE PROCEDURE tfer_funds     
  2.        (from_account INT, to_account INT,tfer_amount NUMERIC(10,2),     
  3.         OUT status INT, OUT message VARCHAR(30))     
  4. BEGIN     
  5.     DECLARE from_account_balance NUMERIC(10,2);     
  6.     
  7.     START TRANSACTION;     
  8.     
  9.     
  10.     SELECT balance     
  11.       INTO from_account_balance     
  12.       FROM account_balance     
  13.      WHERE account_id=from_account     
  14.        FOR UPDATE;     
  15.     
  16.     IF from_account_balance>=tfer_amount THEN     
  17.     
  18.          UPDATE account_balance     
  19.             SET balance=balance-tfer_amount     
  20.           WHERE account_id=from_account;     
  21.     
  22.          UPDATE account_balance     
  23.             SET balance=balance+tfer_amount     
  24.           WHERE account_id=to_account;     
  25.          COMMIT;     
  26.     
  27.          SET status=0;     
  28.          SET message='OK';     
  29.     ELSE     
  30.          ROLLBACK;     
  31.          SET status=-1;     
  32.          SET message='Insufficient funds';     
  33.     END IF;     
  34. END;    

 

乐观锁的例子:

 

[c-sharp] view plaincopy
 
  1. CREATE PROCEDURE tfer_funds     
  2.     (from_account INT, to_account INT, tfer_amount NUMERIC(10,2),     
  3.         OUT status INT, OUT message VARCHAR(30) )     
  4.     
  5. BEGIN     
  6.     
  7.     DECLARE from_account_balance    NUMERIC(8,2);     
  8.     DECLARE from_account_balance2   NUMERIC(8,2);     
  9.     DECLARE from_account_timestamp1 TIMESTAMP;     
  10.     DECLARE from_account_timestamp2 TIMESTAMP;     
  11.     
  12.     SELECT account_timestamp,balance     
  13.         INTO from_account_timestamp1,from_account_balance     
  14.             FROM account_balance     
  15.             WHERE account_id=from_account;     
  16.     
  17.     IF (from_account_balance>=tfer_amount) THEN     
  18.     
  19.         -- Here we perform some long running validation that     
  20.         -- might take a few minutes */     
  21.         CALL long_running_validation(from_account);     
  22.     
  23.         START TRANSACTION;     
  24.     
  25.         -- Make sure the account row has not been updated since     
  26.         -- our initial check     
  27.         SELECT account_timestamp, balance     
  28.             INTO from_account_timestamp2,from_account_balance2     
  29.             FROM account_balance     
  30.             WHERE account_id=from_account     
  31.             FOR UPDATE;     
  32.     
  33.         IF (from_account_timestamp1 <> from_account_timestamp2 OR     
  34.             from_account_balance    <> from_account_balance2)  THEN     
  35.             ROLLBACK;     
  36.             SET status=-1;     
  37.             SET message=CONCAT("Transaction cancelled due to concurrent update",     
  38.                 " of account"  ,from_account);     
  39.         ELSE     
  40.             UPDATE account_balance     
  41.                 SET balance=balance-tfer_amount     
  42.                 WHERE account_id=from_account;     
  43.     
  44.             UPDATE account_balance     
  45.                 SET balance=balance+tfer_amount     
  46.                 WHERE account_id=to_account;     
  47.     
  48.             COMMIT;     
  49.     
  50.             SET status=0;     
  51.             SET message="OK";     
  52.         END IF;     
  53.     
  54.     ELSE     
  55.         ROLLBACK;     
  56.         SET status=-1;     
  57.         SET message="Insufficient funds";     
  58.     END IF;     
  59. END$$    

相关推荐