PHPからmysqlのプロシージャを呼び出した際に、処理が途中で終わってしまう現象を解決したいです。

Question

• 起きている現象

  1. phpからプロシージャを呼び出す
  2. 呼び出された(データ登録用の)プロシージャが走り、mysqlのテーブル上にデータ登録がされる
  3. テーブルの結果を確認してみるとプロシージャで登録されるはずの30件のデータが、2件しか登録されていない
  4. プロシージャを実行直後に、sleepを入れると30件すべて登録される。

• 備考

  • 実行されるプロシージャについて
    • 受け渡されるパラメータによってデータ登録するプロシージャです。
  • 他に試したこと
    • execute関数ではなく、exec関数を使用してみた。

• ソースコード

$a = 2022;
$b = 333;
$c = "test";

// プロシージャの呼び出し
$sql = "call insert_Data(?,?,?);";
$stmt = $this->db->prepare($sql);
$stmt->bindParam(1, $a, \PDO::PARAM_INT);
$stmt->bindParam(2, $b, \PDO::PARAM_INT);
$stmt->bindParam(3, $c, \PDO::PARAM_STR|\PDO::PARAM_INPUT_OUTPUT, 20);
$xxx = $stmt->execute();

// ここにsleepを入れると動く
sleep(10);  

// プリントデバッグ------------------------------------------------------------------------------------------------------------------------
ob_start();
$aaa = "ここから-----------------------------------------x";
$bbb = "ここまで-----------------------------------------x";
var_dump($aaa);
var_dump($xxx);
var_dump(date("Y/m/d H:i:s"));
var_dump($bbb);
$str = ob_get_contents();//バッファの内容を取得
ob_end_clean();
~(以下省略)
* ```

Comments

[yambejp]

insert_Dataの仕様次第では？
そもそもこれがinsert処理なら戻り値はありません
（insertしてselectするプロシージャ？）
サンプルを見る限り複数のデータ登録をしているようには見えませんが・・
トランザクションはどうしているのでしょうかね・・・

[porzoe]

yambejpさん、回答ありがとうございます！
トランザクションは今は組んでおりません。後に組み込む予定です。

プロシージャでは
プロシージャに受け渡されるパラメータを元に、テーブルにinsertのみ実行されるプロシージャです。
正確に言うとmysql側で、プロシージャとは別にファンクションを定義しており、実際のinsert処理はファンクションで行われていて、プロシージャの中でinserts処理をするファンクションを呼び出している形になります。

[yambejp]

ちょっと認識のズレがありそうです。
プロシージャはインサート後に表示させる処理があるのですね？
複数データが挿入できないというのも相変わらず不明です。

[porzoe]

* プロシージャについて
insertだけの用途で使いたいので、表示するためのselect文は、PHP側で別で用意するつもりです。

* 複数データが挿入できない件について
DBクライアント(DBeaver)上で、直接プロシージャを実行すると30件データ(30個ではなく、30行)が入り正常の動きをするのですが、PHP側のプログラムから呼び出すと、恐らくプロシージャ実行中に処理が途中で終わってしまい2行しかデータが入っておりません。

PHP側のでプロシージャ呼び出し直後に、sleepで処理をある程度待たせてあげると正常に30行のデータが登録される形になります。
(私の複数データの説明の書き方が良くなかったですね....)

[yambejp]

$a,$b,$cを渡すと30個データがつくられるということですか？
スリープ云々がどうからんでいるかは今の開示された情報ではなんともいえませんが
よほど重い処理でないかぎり途中できれることは無いと思います
後回ししているトランザクションの処理を実装してみるとよいかもしれません

[porzoe]

$a,$b,$cを渡すと30個データがつくられるということですか？
→その通りです！
そこまで重たい処理ではないので、トランザクションを先に実装してみて試してみます！
ご回答ありがとうございます！

[yambejp]

もしプロシージャ内でなんどもinsert文を発行しているようでしたら
バルクインサートで一括登録を検討ください
その内容で回答してあります

Answer 1

参考

create table tbl(id int not null,num int not null,unique(id,num));

drop procedure if exists insert_data;
delimiter //
create procedure insert_data(arg int)
begin
declare x int;
declare y int;
set x=0,y=10;
set @sql:="insert ignore into tbl values";
while x < y do
if x>0 then
   set @sql:=concat(@sql,',');
end if;
set @sql:=concat(@sql,'(',arg,',',x,')');
set x = x + 1;
end while;
prepare stmt from @sql;
execute stmt;
end
//
delimiter ;

insert処理をまとめて行えば途中で切れる（一部だけ挿入される）ことは無いと思います

//実行

call insert_data(10);