資訊專欄INFORMATION COLUMN
摘要：但是經(jīng)過測試自身的是次秒，是一個相當(dāng)不錯的數(shù)據(jù)，所以我們這里將事務(wù)直接交給，使用存儲過程來降低行級鎖的持有時間。存儲過程代碼使用存儲過程之前必須保證數(shù)據(jù)庫已經(jīng)創(chuàng)建了存儲過程。表示使用在存儲過程中替代最后需要還原回來。
【什么是存儲過程
所謂的存儲過程是指：是一組為了完成特定功能的SQL語句集，經(jīng)編譯后存儲在數(shù)據(jù)庫中，用戶通過指定存儲過程的名字并給定參數(shù)（如果該存儲過程帶有參數(shù)）來調(diào)用執(zhí)行它。可以用控制語句編寫，有很強(qiáng)的靈活性，可以完成復(fù)雜的判斷和較復(fù)雜的運(yùn)算。
【為什么使用存儲過程現(xiàn)在的情況是：由于有update操作，所以需要使用事務(wù)保證操作的原子性，但是現(xiàn)在事務(wù)的控制是交給spring來控制的，那么中間就會有網(wǎng)絡(luò)延時，GC的耗時(GC時會掛起所有線程，并發(fā)數(shù)越高GC越頻繁)操作。而被update的記錄會被行級鎖控制住，所有的操作只能串行所以會大量阻塞，影響用戶體驗。
但是經(jīng)過測試MySQL自身的update是40000次/秒，是一個相當(dāng)不錯的數(shù)據(jù)，所以我們這里將事務(wù)直接交給MySQL，使用存儲過程來降低行級鎖的持有時間。
【存儲過程代碼使用存儲過程之前必須保證數(shù)據(jù)庫已經(jīng)創(chuàng)建了存儲過程。DELIMITER 表示使用‘$$’在存儲過程中替代‘;’,最后需要DELIMITER ;還原回來。我們這里的out r_result表示輸出，而這里的輸出需要和項目中的KillStatus枚舉值對應(yīng)，來表明一次秒殺的結(jié)果。
DELIMITER $$
CREATE PROCEDURE `seckill`.`execute_seckill`
(in v_id VARCHAR(36),in v_kill_product_id VARCHAR(36),in v_mobile BIGINT,in v_kill_time TIMESTAMP,out r_result int)
BEGIN
DECLARE insert_count int DEFAULT 0;
START TRANSACTION;
INSERT IGNORE INTO kill_item(id,kill_product_id,mobile) values(v_id,v_kill_product_id,v_mobile);
SELECT ROW_COUNT() INTO insert_count;
IF(insert_count = 0) THEN
ROLLBACK;
SET r_result = -1;
ELSEIF(insert_count < 0) THEN
ROLLBACK;
SET r_result = -2;
ELSE
UPDATE kill_product SET number = number - 1
WHERE id = v_kill_product_id AND number >= 1 AND end_time > v_kill_time AND start_time < v_kill_time;
SELECT ROW_COUNT() INTO insert_count;
IF(insert_count = 0) THEN
ROLLBACK;
SET r_result = 0;
ELSEIF(insert_count < 0) THEN
ROLLBACK;
SET r_result = -2;
ELSE
COMMIT;
SET r_result = 1;
END IF;
END IF;
END;
$$
DELIMITER ;
【通過springdataJPA調(diào)用存儲過程
Entity上需要標(biāo)明相應(yīng)的注解告訴spring這個Entity擁有相應(yīng)的存儲過程：
import lombok.Data;
import javax.persistence.*;
import java.util.Date;
/**
* 秒殺明細(xì)實(shí)體類
* @author ibm
* @since 0
* @date 2018/3/22
*/
@Entity
@Table(name = "kill_item")
@NamedStoredProcedureQuery(name = "executeSeckill", procedureName = "execute_seckill", parameters = {
@StoredProcedureParameter(mode = ParameterMode.IN, name = "v_id", type = String.class),
@StoredProcedureParameter(mode = ParameterMode.IN, name = "v_kill_product_id", type = String.class),
@StoredProcedureParameter(mode = ParameterMode.IN, name = "v_mobile", type = Long.class),
@StoredProcedureParameter(mode = ParameterMode.IN, name = "v_kill_time", type = Date.class),
@StoredProcedureParameter(mode = ParameterMode.OUT, name = "r_result", type = Integer.class) })
@Data
public class KillItem {
/**
* 記錄ID
*/
@Id
@Column(name = "id")
private String id;
/**
* 秒殺產(chǎn)品id
*/
@Column(name = "kill_product_id")
private String killProductId;
/**
* 用戶手機(jī)號碼
*/
@Column(name = "mobile")
private String mobile;
/**
* 秒殺成功時間
*/
@Column(name = "kill_time")
private Date killTime;
}
對應(yīng)的Repository上也需要告訴方法(executeProcedure)，該方法需要調(diào)用哪一個存儲過程：注意一點(diǎn)這個方法的返回值就是存儲過程的 out ，入?yún)⒕褪谴鎯^程的 in。
