DBオペレーション – 更新登録（複数レコード）
最終更新日:2023年05月19日
データベースに対して更新キーにマッチしたデータを一括更新するサンプルプログラムです。
また、マッチしなかった場合、データを登録します。
レコードは最大1000行まで更新登録が可能です。 本サンプルプログラムは外部呼出し（スパイラル以外のサーバから動作させる場合）と内部呼出し（スパイラル内部で動作させる場合）と分けて記載をしています。
利用する用途によって使用するサンプルプログラムの使い分けを行ってください。
※外部呼出しに利用するサンプルプログラムにはスパイラル内のWebコンポーネントで使用できない関数などが含まれる場合がありますのでご注意ください。
使用できないPHPの関数について、PHP利用時の注意事項をご覧ください。
※内部呼出しを利用する場合はアカウント内APIの設定を「ON」に変更する必要があります。
外部呼出しを利用する場合
<?php
/**
* [ 概要 ]
* スパイラルのAPIを使ったサンプルプログラムです。
*
* [ サンプルで行う事 ]
* - 検索条件にマッチしたデータを一括更新します。
* - 検索条件にマッチしなかった場合、データを複数行登録します。
*
* UTF8で保存してください。
*/
/**
* [サンプルを動かすための準備]
*
* 1. PHPにcurlライブラリが組み込まれている必要があります。
* 参考：http://www.php.net/manual/ja/intro.curl.php
*
* 2. スパイラルの操作画面の「ＤＢグループ」「通常ＤＢ管理」で、以下のような構成でＤＢを発行します。
*
* DBタイトル：
* member
*
* フィールド：
* No1 フィールド名 ：登録日時
* フィールドタイプ：登録日時
* 差替えキーワード：registDate
*
* No2 フィールド名 ：メールアドレス
* フィールドタイプ：メールアドレス（大・小文字を無視）
* 差替えキーワード：email
*
* No3 フィールド名 ：メンバーID
* フィールドタイプ：数字・記号・アルファベット(32 bytes)
* 差替えキーワード：member_id
*
* No4 フィールド名 ：パスワード
* フィールドタイプ：メッセージダイジェスト（SHA256）
* 差替えキーワード：pass
*
* No5 フィールド名 ：氏名
* フィールドタイプ：テキストフィールド(64 bytes)
* 差替えキーワード：name
*
*/
// ロケータのURL (変更の必要はありません)
$locator = "https://www.pi-pe.co.jp/api/locator";
// スパイラルの操作画面で発行したトークンを設定します。
$TOKEN = "XXXXXXXXXXXXXXXXXXXXXXXXXXX";
$SECRET = "XXXXXXXXXXXXXXXXXXXXXXXXXXX";
// API用のHTTPヘッダ
$api_headers = array(
"X-SPIRAL-API: locator/apiserver/request",
"Content-Type: application/json; charset=UTF-8",
);
// 送信するJSONデータを作成
$parameters = array();
$parameters["spiral_api_token"] = $TOKEN; //トークン
// 送信用のJSONデータを作成します。
$json = json_encode($parameters);
// curlライブラリを使って送信します。
$curl = curl_init($locator);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($curl, CURLOPT_POST, true);
curl_setopt($curl, CURLOPT_POSTFIELDS, $json);
curl_setopt($curl, CURLOPT_HTTPHEADER, $api_headers);
curl_exec($curl);
// エラーがあればエラー内容を表示
if (curl_errno($curl)) echo curl_error($curl);
$response = curl_multi_getcontent($curl);
curl_close($curl);
$response_json = json_decode($response, true);
// サービス用のURL
$APIURL = $response_json['location'];
// -----------------------------------------------------------------------------
// 一括更新登録
// -----------------------------------------------------------------------------
// API用のHTTPヘッダ
$api_headers = array(
"X-SPIRAL-API: database/bulk_upsert/request",
"Content-Type: application/json; charset=UTF-8",
);
// リクエストデータを作成
$parameters = array();
$parameters["spiral_api_token"] = $TOKEN; //トークン
$parameters["db_title"] = "member"; //DBのタイトル
$parameters["key"] = "member_id"; //更新キー
$parameters["passkey"] = time(); //エポック秒
// 登録するフィールドを設定します。
$parameters["columns"] = array("registDate", "email", "member_id", "pass", "name");
// 更新登録したいデータを設定します（複数）
// 改行は改行コード("\n")を指定します。JSONデータは "\n" の文字へエスケープされます。
$parameters["data"] = array(
array("now", "test001@example.com", "1111", "hogehoge", "佐藤 桃子"),
array("now", "test002@example.com", "2222", "hogehoge", "山本 桃子"),
array("now", "test003@example.com", "3333", "hogehoge", "高橋 桃子"),
);
// 署名を付けます
$key = $parameters["spiral_api_token"] . "&" . $parameters["passkey"];
$parameters["signature"] = hash_hmac('sha1', $key, $SECRET, false);
// JSON形式にエンコードします
$json = json_encode($parameters);
echo "===> bulk_upsert\n";
// curlライブラリを使って送信します。
$curl = curl_init($APIURL);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($curl, CURLOPT_POST, true);
curl_setopt($curl, CURLOPT_POSTFIELDS, $json);
curl_setopt($curl, CURLOPT_HTTPHEADER, $api_headers);
curl_exec($curl);
// エラーがあればエラー内容を表示
if (curl_errno($curl)) echo curl_error($curl);
$response = curl_multi_getcontent($curl);
curl_close($curl);
// 画面に表示
// 配列にしたい時は json_decode($response, true); とします。
print_r(json_decode($response, true));
?>内部呼出しを利用する場合
<?php
/**
* [ 概要 ]
* スパイラルのAPIを使ったサンプルプログラムです。
*
* [ サンプルで行う事 ]
* - 検索条件にマッチしたデータを一括更新します。
* - 検索条件にマッチしなかった場合、データを複数行登録します。
*
* UTF8で保存してください。
*/
/**
* [サンプルを動かすための準備]
*
* スパイラルの操作画面の「ＤＢグループ」「通常ＤＢ管理」で、以下のような構成でＤＢを発行します。
*
* DBタイトル：member
*
* フィールド：
* No1 フィールド名 ：登録日時
* フィールドタイプ：登録日時
* 差替えキーワード：registDate
*
* No2 フィールド名 ：メールアドレス
* フィールドタイプ：メールアドレス（大・小文字を無視）
* 差替えキーワード：email
*
* No3 フィールド名 ：メンバーID
* フィールドタイプ：数字・記号・アルファベット(32 bytes)
* 差替えキーワード：member_id
*
* No4 フィールド名 ：パスワード
* フィールドタイプ：メッセージダイジェスト（SHA256）
* 差替えキーワード：pass
*
* No5 フィールド名 ：氏名
* フィールドタイプ：テキストフィールド(64 bytes)
* 差替えキーワード：name
*
*/
// -----------------------------------------------------------------------------
// 一括更新登録
// -----------------------------------------------------------------------------
// データを１件更新登録します
$db = $SPIRAL->getDataBase("member");
$response = $db->doBulkUpsert(
"member_id",
array("member_id", "registDate", "email", "pass", "name"),
array(
array("1111", "now", "test001@example.com", "hogehoge", "佐藤 桃子"),
array("2222", "now", "test002@example.com", "hogehoge", "山本 桃子"),
array("3333", "now", "test003@example.com", "hogehoge", "高橋 桃子"),
)
);
print_r($response);
?>