Tablestore:ローカル トランザクションの構成

startLocalTransaction

    /**
     * ローカル トランザクションを作成し、ローカル トランザクション ID を取得します。
     * @api
     * @param [] $request
     *            リクエスト パラメータ。テーブル名とパーティションキーを含みます。
     * @return [] レスポンス。
     * @throws OTSClientException パラメータエラーが発生した場合、または Tablestore サーバーが検証エラーを返した場合に返される例外。
     * @throws OTSServerException Tablestore サーバーがエラーを返した場合に返される例外。
     * @example "src/examples/StartLocalTransaction.php" 50
     */
    public function startLocalTransaction(array $request)

commitTransaction

    /**
     * ローカル トランザクションをコミットします。
     * @api
     *
     * @param [] $request
     *          リクエスト パラメータ。トランザクション ID です。
     * @return [] レスポンス。
     * @throws OTSClientException パラメータエラーが発生した場合、または Tablestore サーバーが検証エラーを返した場合に返される例外。
     * @throws OTSServerException Tablestore サーバーがエラーを返した場合に返される例外。
     * @example "src/examples/CommitTransaction.php" 50
     */
    public function commitTransaction(array $request)

abortTransaction

    /**
     * ローカル トランザクションを中止します。
     * @api
     *
     * @param [] $request
     *          リクエスト パラメータ。トランザクション ID です。
     * @return [] レスポンス。
     * @throws OTSClientException パラメータエラーが発生した場合、または Tablestore サーバーが検証エラーを返した場合に返される例外。
     * @throws OTSServerException Tablestore サーバーがエラーを返した場合に返される例外。
     * @example "src/examples/AbortTransaction.php" 20
     */
    public function abortTransaction(array $request)

ローカル トランザクション機能を使用してデータ行を書き込む

この例では、テーブルの指定されたパーティションキーに対して作成されたローカル トランザクションにデータ行が書き込まれ、ローカル トランザクションがコミットされます。

// ローカル トランザクション ID を取得します。
$response = $client->startLocalTransaction (array (
    'table_name' => 'TransactionTable',
// 主キーは [PK0:INTEGER,PK1:STRING] です。
    'key' => array(
        array('PK0', 123)
    )
));

$attr = array();
$attr[] = ['col0', 'bbb'];

$request = [
    'table_name' => 'TransactionTable',
    'condition' => RowExistenceExpectationConst::CONST_IGNORE, // condition を IGNORE、EXPECT_EXIST、または EXPECT_NOT_EXIST に設定できます。
// 主キーを指定します。
    'primary_key' => [
        ['PK0', 123],
        ['PK1', 'abc']
    ],
    'attribute_columns' => $attr,
    'transaction_id' => $response['transaction_id']
];
// putRow メソッドを実行してデータを書き込みます。
$client->putRow($request);
// トランザクション内のすべてのデータ変更を有効にするために、トランザクションをコミットします。ローカル トランザクションを破棄して、ローカル トランザクション内のすべてのデータ変更を無効にすることもできます。
$client->commitTransaction(array(
    'transaction_id' => $response['transaction_id']
));
// ローカル トランザクションを中止して、トランザクション内のすべてのデータ変更を無効にします。
// $client->abortTransaction(array(
//     'transaction_id' => $response['transaction_id']
// ));

ローカル トランザクション機能を使用してデータ行を読み取る

この例では、テーブルの指定されたパーティションキーに対して作成されたローカル トランザクションでデータ行が読み取られます。

// ローカル トランザクション ID を取得します。
$response = $client->startLocalTransaction (array (
    'table_name' => 'TransactionTable',
// 主キーは [PK0:INTEGER,PK1:STRING] です。
    'key' => array(
        array('PK0', 123)
    )
));

$request = array(
    'table_name' => 'TransactionTable',
// 主キーを指定します。
    'primary_key' => array (
        array('PK0', 123),
        array('PK1', 'abc')
    ),
    'max_versions' => 1,
    'columns_to_get' => ['col0'],
    'transaction_id' => $response['transaction_id']
);
// getRow メソッドを実行してデータを読み取ります。
$client->getRow($request);
// ローカル トランザクションをコミットまたは中止します。ローカル トランザクションをコミットまたは破棄したときの読み取り操作への影響は同じです。
// トランザクション内のすべてのデータ変更を有効にするために、トランザクションをコミットします。
$client->commitTransaction(array(// トランザクションをコミットします。
    'transaction_id' => $response['transaction_id']
 ));
// ローカル トランザクションを中止して、トランザクション内のすべてのデータ変更を無効にします。
// $client->abortTransaction(array(
//     'transaction_id' => $response['transaction_id']
// ));