mysql 存儲(chǔ)過程多次插入只有一次成功，請(qǐng)問這是什么原因？

今天碰到一個(gè)奇葩的問題，同樣的批量插入，一個(gè)可以批量插入成功，一個(gè)卻不能插入成功，請(qǐng)大家看看。

以下是偽代碼

-- 存儲(chǔ)過程A (負(fù)責(zé)插入SQL)(有參數(shù)，這里就不寫了，主要用于組裝 SQL 并執(zhí)行)
CREATE PROCEDURE `A`()
  BEGIN
    REPLACE INTO `table` (`num`) 
      SELECT SUM(`num`) AS `num`
      FROM `table`;
  END;

-- 存儲(chǔ)過程B (負(fù)責(zé)循環(huán)處理參數(shù)，傳遞給 A)
CREATE PROCEDURE `B`()
  BEGIN
    WHILE 100 DO
      CALL `A`;
    END WHILE;
  END;

上面的兩個(gè)存儲(chǔ)過程就是我的代碼邏輯，每次 REPLACE INTO ... SELECT ... 大概需要 0.2 秒的時(shí)間。
當(dāng)我調(diào)用 CALL `B` 的時(shí)候，只能第一條插入成功，其他的均無插入，也沒有報(bào)錯(cuò)。
生成的 SQL 語句是無錯(cuò)誤的，因?yàn)榇蛴〉恼Z句可以手動(dòng)批量插入。

更奇葩的是，，我有一個(gè)同樣的功能的其他 REPLACE INTO ... SELECT ... (相對(duì)執(zhí)行時(shí)間短,0.01秒級(jí))，卻可以批量插入成功。

這個(gè)是不是鎖導(dǎo)致的呢，我用的 InnoDB 存儲(chǔ)引擎。

可能有些情況我說的不太明白：

上面的代碼是偽代碼，循環(huán)結(jié)構(gòu)和生成執(zhí)行 SQL 均無問題
這里主要討論三個(gè)問題：
- 是不是行鎖導(dǎo)致的 (按說不應(yīng)該)
- 同樣的表，同樣的查詢結(jié)構(gòu)，為何執(zhí)行時(shí)間短的可以插入(0.001級(jí)別)，執(zhí)行時(shí)間長(zhǎng)的不能插入(0.1級(jí)別)
- 執(zhí)行過程中調(diào)用執(zhí)行過程，是同步執(zhí)行還是異步執(zhí)行 (即是否等 CALL 執(zhí)行完畢后在走流程，還是不等執(zhí)行完畢，就走下一個(gè)循環(huán)流程)

回答

編輯回答

久愛她

你沒有說明表的主鍵和唯一鍵, 猜測(cè)id是主鍵, 但replace into 代入的id始終是0, 所以最終數(shù)據(jù)庫里只能有一條記錄, 如果id 是自增長(zhǎng)的, 試試設(shè)成null, 或改用insert into, 而不是replace into.

EDITED

我試了下, 按你給的存儲(chǔ)過程會(huì)陷入死循環(huán), 因?yàn)?code>while 100一直為真.

可以試試改成這樣:

delimiter $$

CREATE PROCEDURE `A`()
  BEGIN
    REPLACE INTO `sumtable` (`id`,`mysum`) 
      SELECT 0 AS `id`,SUM(`mysum`) AS `mysum`
      FROM `sumtable`;
  END;
$$

-- 存儲(chǔ)過程B (負(fù)責(zé)循環(huán)處理參數(shù)，傳遞給 A)
CREATE PROCEDURE `B`()
  BEGIN
    DECLARE v1 INT DEFAULT 100;
    WHILE v1>0 DO
      CALL `A`;
    SET v1 = v1 - 1;
    END WHILE;
  END;
$$

運(yùn)行

call B()

會(huì)得到100條記錄.

2018年4月9日 10:56

編輯回答

荒城

我想到了一個(gè)原因，正在測(cè)試，如果 CALL 是異步調(diào)用，而我 SQL 執(zhí)行是這樣的：

      SET @sql = $sql;
      PREPARE STMT FROM @sql;
      EXECUTE STMT;
      DEALLOCATE PREPARE STMT;

@sql 會(huì)相互覆蓋?？纯礈y(cè)試結(jié)論吧。

現(xiàn)在代碼是這樣的：

CREATE PROCEDURE `A`()
  BEGIN
    SET $sql = 'REPLACE INTO `table` (`num`) 
      SELECT SUM(`num`) AS `num`
      FROM `table`;';
      SET @sql = $sql;
    PREPARE STMT FROM @sql;
    EXECUTE STMT;
    DEALLOCATE PREPARE STMT;
  END;

CREATE PROCEDURE `B`()
  BEGIN
    WHILE 100 DO
      CALL `A`;
    END WHILE;
  END;

2018年1月15日 17:11