資訊專欄INFORMATION COLUMN
摘要：但是經過測試自身的是次秒，是一個相當不錯的數據，所以我們這里將事務直接交給，使用存儲過程來降低行級鎖的持有時間。存儲過程代碼使用存儲過程之前必須保證數據庫已經創建了存儲過程。表示使用在存儲過程中替代最后需要還原回來。
【什么是存儲過程
所謂的存儲過程是指：是一組為了完成特定功能的SQL語句集，經編譯后存儲在數據庫中，用戶通過指定存儲過程的名字并給定參數（如果該存儲過程帶有參數）來調用執行它。可以用控制語句編寫，有很強的靈活性，可以完成復雜的判斷和較復雜的運算。
【為什么使用存儲過程現在的情況是：由于有update操作，所以需要使用事務保證操作的原子性，但是現在事務的控制是交給spring來控制的，那么中間就會有網絡延時，GC的耗時(GC時會掛起所有線程，并發數越高GC越頻繁)操作。而被update的記錄會被行級鎖控制住，所有的操作只能串行所以會大量阻塞，影響用戶體驗。
但是經過測試MySQL自身的update是40000次/秒，是一個相當不錯的數據，所以我們這里將事務直接交給MySQL，使用存儲過程來降低行級鎖的持有時間。
【存儲過程代碼使用存儲過程之前必須保證數據庫已經創建了存儲過程。DELIMITER 表示使用‘$$’在存儲過程中替代‘;’,最后需要DELIMITER ;還原回來。我們這里的out r_result表示輸出，而這里的輸出需要和項目中的KillStatus枚舉值對應，來表明一次秒殺的結果。
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調用存儲過程
Entity上需要標明相應的注解告訴spring這個Entity擁有相應的存儲過程：
import lombok.Data;
import javax.persistence.*;
import java.util.Date;
/**
* 秒殺明細實體類
* @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;
/**
* 秒殺產品id
*/
@Column(name = "kill_product_id")
private String killProductId;
/**
* 用戶手機號碼
*/
@Column(name = "mobile")
private String mobile;
/**
* 秒殺成功時間
*/
@Column(name = "kill_time")
private Date killTime;
}
對應的Repository上也需要告訴方法(executeProcedure)，該方法需要調用哪一個存儲過程：注意一點這個方法的返回值就是存儲過程的 out ，入參就是存儲過程的 in。
