Tablestore:フィルターの使用

前提条件

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

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

使用上の注意

GetRow、BatchGetRow、または GetRange 操作を呼び出してデータをクエリする場合、フィルターを使用してフィルター条件を満たす行のみを返すことができます。

フィルターには、RelationalCondition と CompositeCondition が含まれます。

• RelationalCondition: 参照列の値のみに基づいて行をフィルタリングするかどうかを決定します。

• CompositeCondition: 複数の参照列の値のフィルター条件を組み合わせて、行をフィルタリングするかどうかを決定します。

制限事項

• フィルター条件は、関係演算子 (=、!=、>、>=、<、および <=) と論理演算子 (NOT、AND、および OR) をサポートしています。フィルター条件には、最大 10 個のサブ条件を含めることができます。

• フィルターで使用される参照列は、返される列に含まれている必要があります。そうでない場合、フィルターは参照列の値をクエリできません。

• GetRow、BatchGetRow、および GetRange 操作にフィルターを使用する場合、これらの操作のネイティブセマンティクスまたは制限は影響を受けません。

  GetRange 操作を呼び出す場合、最大 5,000 行または 4 MB のデータを同時にスキャンできます。

  スキャンされた 5,000 行または 4 MB がフィルター条件と一致しない場合、レスポンスの行は空になります。ただし、nextStartPrimaryKey は空でない場合があります。この場合、nextStartPrimaryKey が空になるまで、nextStartPrimaryKey を使用してデータの読み取りを続ける必要があります。

パラメーター

例

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

    var rowQueryCriteria = new SingleRowQueryCriteria(TableName)
    {
        RowPrimaryKey = primaryKey
    };

    // col0 の値が 5 の場合に、行が返されるように指定します。
    var filter = new RelationalCondition("col0",CompareOperator.EQUAL,new ColumnValue(5))
    {
        PassIfMissing = true
    };

    rowQueryCriteria.Filter = filter.ToFilter();
    rowQueryCriteria.AddColumnsToGet("col0");
    rowQueryCriteria.AddColumnsToGet("col1");

    GetRowRequest request = new GetRowRequest(rowQueryCriteria); 

    // クエリを実行します。
    GetRowResponse response = otsClient.GetRow(request);
    PrimaryKey primaryKeyRead = response.PrimaryKey;
    AttributeColumns attributesRead = response.Attribute;

    Console.WriteLine("読み取られたプライマリキー: ");
    foreach (KeyValuePair<string, ColumnValue> entry in primaryKeyRead)
    {
        Console.WriteLine(entry.Key + ":" + PrintColumnValue(entry.Value));
    }

    Console.WriteLine("読み取られた属性: ");
    foreach (KeyValuePair<string, ColumnValue> entry in attributesRead)
    {
        Console.WriteLine(entry.Key + ":" + PrintColumnValue(entry.Value));
    }

    Console.WriteLine("フィルターを使用した行の取得に成功しました。");
}

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

    var rowQueryCriteria = new SingleRowQueryCriteria(TableName)
    {
        RowPrimaryKey = primaryKey
        };

    // col0 の値が 5 であるか、col1 の値が ff でない場合に、行が返されるように指定します。
    var filter1 = new RelationalCondition("col0",
                                          CompareOperator.EQUAL,
                                          new ColumnValue(5));

    var filter2 = new RelationalCondition("col1", CompareOperator.NOT_EQUAL, new ColumnValue("ff"));

    var filter = new CompositeCondition(LogicOperator.OR);
    filter.AddCondition(filter1);
    filter.AddCondition(filter2);

    rowQueryCriteria.Filter = filter.ToFilter();
    rowQueryCriteria.AddColumnsToGet("col0");
    rowQueryCriteria.AddColumnsToGet("col1");

    GetRowRequest request = new GetRowRequest(rowQueryCriteria); 

    // クエリを実行します。
    GetRowResponse response = otsClient.GetRow(request);
    PrimaryKey primaryKeyRead = response.PrimaryKey;
    AttributeColumns attributesRead = response.Attribute;

    Console.WriteLine("読み取られたプライマリキー: ");
    foreach (KeyValuePair<string, ColumnValue> entry in primaryKeyRead)
    {
        Console.WriteLine(entry.Key + ":" + PrintColumnValue(entry.Value));
    }

    Console.WriteLine("読み取られた属性: ");
    foreach (KeyValuePair<string, ColumnValue> entry in attributesRead)
    {
        Console.WriteLine(entry.Key + ":" + PrintColumnValue(entry.Value));
    }

    Console.WriteLine("フィルターを使用した行の取得に成功しました。");
}