複数の値を返す MySQL ストアド プロシージャ メソッドの例

mysql> desc 注文;
+----------------+-------------+------+------+--------+-------+
| フィールド | タイプ | Null | キー | デフォルト | 追加 |
+----------------+-------------+------+------+--------+-------+
| 注文番号 | int(11) | NO | PRI | NULL | |
| orderDate | 日付 | NO | | NULL | |
| requiredDate | 日付 | NO | | NULL | |
| 出荷日 | 日付 | はい | | NULL | |
| ステータス | varchar(15) | NO | | NULL | |
| コメント | テキスト | はい | | NULL | |
| 顧客番号 | int(11) | NO | MUL | NULL | |
+----------------+-------------+------+------+--------+-------+
7行セット

区切り文字 $$
プロシージャ get_order_by_cust( を作成する
 IN cust_no INT、
 OUT発送済みINT、
 OUTキャンセルINT、
 OUTはINTを解決しました。
 OUT 論争 INT)
始める
 -- 発送済み
 選択
      count(*) 出荷済み
    から
      注文
    どこ
      顧客番号 = cust_no
        AND ステータス = '発送済み';
 -- キャンセル
 選択
      count(*) INTO キャンセル
    から
      注文
    どこ
      顧客番号 = cust_no
        AND ステータス = 'キャンセル';
 -- 解決済み
 選択
      count(*) INTO 解決済み
    から
      注文
    どこ
      顧客番号 = cust_no
        AND ステータス = '解決済み';
 -- 議論の余地あり
 選択
      count(*) INTO 議論中
    から
      注文
    どこ
      顧客番号 = cust_no
        AND ステータス = '異議あり';
終わり

+----------+------------+-----------+-----------+
| @発送済み | @キャンセル済み | @解決済み | @争議中 |
+----------+------------+-----------+-----------+
| 22 | 0 | 1 | 1 |
+----------+------------+-----------+-----------+
セット内の1行

<?php
/**
 * 複数の値を返すストアドプロシージャを呼び出す
 * @param $顧客番号
 */
関数 call_sp($customerNumber)
{
  試す {
    $pdo = 新しい PDO ("mysql:host=localhost;dbname=yiibaidb", 'root', '123456');
    // ストアドプロシージャを実行する
    $sql = 'get_order_by_cust(:no,@shipped,@canceled,@resolved,@disputed) を呼び出します';
    $stmt = $pdo->prepare($sql);
    $stmt->bindParam(':no', $customerNumber, PDO::PARAM_INT);
    $stmt->execute();
    $stmt->カーソルを閉じる();
    // 2番目のクエリを実行してOUTパラメータから値を取得します
    $r = $pdo->query("SELECT @shipped,@canceled,@resolved,@disputed")
         -> フェッチ(PDO::FETCH_ASSOC);
    もし（$r）{
      printf('発送済み: %d、キャンセル済み: %d、解決済み: %d、異議申し立て済み: %d',
        $r['@発送済み'],
        $r['@キャンセル'],
        $r['@解決済み'],
        $r['@disputed']);
    }
  } (PDOException $pe) をキャッチします {
    die("エラーが発生しました:" . $pe->getMessage());
  }
}
コール_sp(141);