Tablestore:条件付き更新の実行

前提条件

• OTSClient インスタンスが初期化されていること。詳細については、OTSClient インスタンスの初期化を参照してください。

• データテーブルが作成され、データがデータテーブルに書き込まれます。詳細については、データテーブルの作成とデータの書き込みを参照してください。

使用上の注意

PutRow、UpdateRow、DeleteRow、またはBatchWriteRow 操作を呼び出してデータテーブル内のデータを更新する場合、行の有無条件と列ベースの条件を指定して条件付き更新を実行できます。データテーブル内のデータは、条件が満たされた場合にのみ更新されます。

条件付き更新は、行の有無条件と列ベースの条件に基づいて実行できます。

• 行の有無条件として、IGNORE、EXPECT_EXIST、EXPECT_NOT_EXIST がサポートされています。

  データテーブルを更新すると、Tablestore はまず行の有無条件が満たされているかどうかを確認します。行の有無条件が満たされていない場合、更新は失敗し、エラーが報告されます。

• 列ベースの条件には、RelationalCondition と CompositeCondition が含まれ、1 つ以上の列の値に基づいて条件が満たされているかどうかを判断するために使用されます。

  列ベースの条件では、=, !=, >, >=, <, <= などの関係演算子がサポートされています。また、NOT、AND、OR などの論理演算子もサポートされています。条件付き更新では、最大 10 個の列ベースの条件を指定できます。

  • RelationalCondition を使用すると、列と定数を比較できます。2 つの列または 2 つの定数の比較はサポートされていません。

  • CompositeCondition は、複数の RelationalCondition または CompositeCondition で構成されます。サブ条件間の論理関係を指定する必要があります。

条件付き更新を実行して、オプティミスティック ロックを実装できます。行を更新する場合は、特定の列の値を取得し、その列の値に基づいて行の更新条件を指定する必要があります。たとえば、行の列 A の値を 2 に更新する場合、列 A の値を取得する必要があります。この例では、取得した値は 1 です。次に、列 A の値が 1 の場合にのみ行を更新できるように指定する必要があります。指定された条件が満たされると、更新は成功します。 行が別のクライアントによって更新された場合、更新は失敗します。

パラメーター

例

次のサンプルコードは、列ベースの条件に基づいてデータを更新する方法の例を示しています。col0 列の値が 5 に等しい場合、データは更新されます。それ以外の場合、データの更新は失敗します。

    // 行のプライマリキーを指定します。プライマリキーは、テーブルの作成時に TableMeta で指定されたプライマリキーと同じである必要があります。
    PrimaryKey primaryKey = new PrimaryKey();
    primaryKey.Add("pk0", new ColumnValue(0));
    primaryKey.Add("pk1", new ColumnValue("abc"));

    // 行の属性列を指定します。
    AttributeColumns attribute = new AttributeColumns();
    attribute.Add("col0", new ColumnValue(0));
    attribute.Add("col1", new ColumnValue("a"));
    attribute.Add("col2", new ColumnValue(true));

    PutRowRequest request = new PutRowRequest(tableName, new Condition(RowExistenceExpectation.IGNORE), primaryKey, attribute);

    // 他の条件が構成されていない場合は PutRow 操作を呼び出します。操作は成功すると予想されます。
    try
    {
        otsClient.PutRow(request);

        Console.WriteLine("Put row succeeded.");
    } catch (Exception ex)
    {
        Console.WriteLine("Put row failed. error:{0}", ex.Message);
    }

    // col0 列の値が 5 と等しくない場合は、PutRow 操作を再度呼び出して元の値を上書きします。操作は成功すると予想されます。
    try
    {
        request.Condition.ColumnCondition = new RelationalCondition("col0",
                                            CompareOperator.NOT_EQUAL,
                                            new ColumnValue(5));
        otsClient.PutRow(request);

        Console.WriteLine("Put row succeeded.");
    } catch (Exception ex)
    {
        Console.WriteLine("Put row failed. error:{0}", ex.Message);
    }

    // col0 列の値が 5 と等しい場合は、PutRow 操作を再度呼び出して元の値を上書きします。操作は成功すると予想されます。
    try
    {
        // col0 列の値が 5 と等しいという新しい条件を追加します。
        request.Condition.ColumnCondition = new RelationalCondition("col0",
                                            CompareOperator.EQUAL,
                                            new ColumnValue(5));
        otsClient.PutRow(request);

        Console.WriteLine("Put row succeeded.");
    }
    catch (OTSServerException)
    {
        // 条件が満たされないため、OTSServerException が返されます。
        Console.WriteLine("Put row failed  because condition check failed. but expected");
    }
    catch (Exception ex)
    {
        Console.WriteLine("Put row failed. error:{0}", ex.Message);
    }