upload the procedure for seckill logic

sql/execute_seckill.sql

@@ -0,0 +1,53 @@
+-- 秒杀执行储存过程
+DELIMITER $$ -- 将定界符从;转换为$$
+-- 定义储存过程
+-- 参数： in输入参数   out输出参数
+-- row_count() 返回上一条修改类型sql(delete,insert,update)的影响行数
+-- row_count:0:未修改数据 ; >0:表示修改的行数； <0:sql错误
+CREATE PROCEDURE `seckill`.`execute_seckill`
+  (IN v_seckill_id BIGINT, IN v_phone BIGINT,
+   IN v_kill_time  TIMESTAMP, OUT r_result INT)
+  BEGIN
+    DECLARE insert_count INT DEFAULT 0;
+    START TRANSACTION;
+    INSERT IGNORE INTO success_killed
+    (seckill_id, user_phone, state)
+    VALUES (v_seckill_id, v_phone, 0);
+    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 seckill
+      SET number = number - 1
+      WHERE seckill_id = v_seckill_id
+	    AND end_time > v_kill_time
+	    AND start_time < v_kill_time
+	    AND number > 0;
+      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 ;
+
+-- 定义一个用户变量r_result
+SET @r_result = -3;
+-- 执行储存过程
+CALL execute_seckill(1003, 13502178891, now(), @r_result);
+-- 获取结果
+SELECT @r_result;