[MYSQL] 存储过程动态表名/异常处理/事物回滚/日期

快来打我* 2022-07-10 09:28 202阅读 0赞

\-- Name : insertMember  
\-- Description : 插入会员登陆member  
\-- Explain : 主服务器  
\-- IN : userid BIGINT(30),username VARCHAR(60),usernametype TINYINT(5),md5id CHAR(1)  
\-- OUT : 0 失败/1 成功/2 已存在

\-- 定义结束符号为 $$  
DELIMITER $$

\-- 建立之前先检查是否存在,存在则删除  
DROP PROCEDURE IF EXISTS \`center\`.\`insertMember\` $$

\-- 创建一个存储过程名为insertMember

CREATE PROCEDURE \`insertMember\`(IN userid BIGINT(30),IN username VARCHAR(60),IN usernametype TINYINT(5),IN md5id CHAR(1))  
BEGIN

\-- 创建一个名为test的异常接收23000错误

DECLARE \`test\` CONDITION FOR SQLSTATE '23000';

\-- 当触发此异常时 退出并返回2  
  DECLARE EXIT HANDLER FOR \`test\` SELECT 2;

\-- 开始一个事物  
  START TRANSACTION;  
  INSERT INTO \`member\` (\`pid\`,\`userName\`,\`usernameType\`) VALUE (userid,username,usernametype);

\-- 获取到插入时产生的ID赋值给一个临时变量  
  SELECT @@Identity INTO @insertid;  
  IF @insertid <= 0 THEN

\-- 回滚嘛 只回滚当前ROLLBACK与TRANSACTION之间的操作  
    ROLLBACK;  
    SELECT 0;  
  END IF;

\-- 得到MD5计算出来的分表的表名  
  SET @tab\_name = CONCAT('\`member\_',md5id,'\`');

\-- 设置这个插入语句,由于表名是变量,所以必须用此方式  
  SET @tempsql = CONCAT("INSERT INTO ",@tab\_name," (\`pid\`,\`userName\`,\`usernameType\`) VALUE (",userid,",'",username,"',",usernametype,")");

\-- 执行以上SQL,PREPARE stmt\_name 的作用域是当前客户端连接会话可见。  
  PREPARE mainStmt FROM @tempsql;  
  EXECUTE mainStmt;  
  SELECT @@Identity INTO @insertidan;  
  IF @insertidan <= 0 THEN  
    ROLLBACK;  
  SELECT 0;  
  END IF;

\-- CURRENT\_DATE,CURRENT\_TIME取得日期时间后组合成字符串  
  INSERT INTO \`aaa\` (\`id\`,\`username\`,\`aaaUpdateDatetime\`) VALUE (userid,username,CONCAT(CURRENT\_DATE(),' ',CURRENT\_TIME()));  
  SELECT @@Identity INTO @insertcreditsid;  
  IF @insertcreditsid <= 0 THEN  
    ROLLBACK;  
    SELECT 0;  
  END IF;  
  INSERT INTO \`bbb\` (\`id\`,\`username\`,\`bbbUpdateDatetime\`) VALUE (userid,username,CONCAT(CURRENT\_DATE(),' ',CURRENT\_TIME()));  
  SELECT @@Identity INTO @insertexpsid;  
  IF @insertexpsid <= 0 THEN  
    ROLLBACK;  
    SELECT 0;  
  END IF;  
  INSERT INTO \`ccc\` (\`id\`,\`username\`,\`cccUpdateDatetime\`) VALUE (userid,username,CONCAT(CURRENT\_DATE(),' ',CURRENT\_TIME()));  
  SELECT @@Identity INTO @insertgold\_coinsid;  
  IF @insertgold\_coinsid <= 0 THEN  
    ROLLBACK;  
    SELECT 0;  
  END IF;

INSERT INTO \`sss\` (\`id\`,\`username\`,\`userType\`,\`sssDatetime\`) VALUE (userid,username,usertype,CONCAT(CURRENT\_DATE(),' ',CURRENT\_TIME()));

SELECT @@Identity INTO @insertmbpid;  
  IF @insertmbpid <= 0 THEN  
    ROLLBACK;  
  SELECT 0;  
  END IF;  
  UPDATE \`xxx\` SET \`aaa\` = @insertcreditsid,\`bbb\`=@insertexpsid,\`ccc\`=@insertgold\_coinsid WHERE \`id\`=userid;  
  SELECT ROW\_COUNT() INTO @updaterows;  
  IF @updaterows <= 0 THEN  
    ROLLBACK;  
    SELECT 0;  
  END IF;

\-- 有始有终嘛 提交这个事物  
  COMMIT;  
  SELECT 1;

\-- 结束存储过程  
END $$

\-- 定义结束符为";"号  
DELIMITER ;