前提條件

• 已初始化Client。具體操作，請(qǐng)參見初始化OTSClient。

• 已創(chuàng)建數(shù)據(jù)表并寫入數(shù)據(jù)。具體操作，請(qǐng)參見創(chuàng)建數(shù)據(jù)表和寫入數(shù)據(jù)。

使用方法

在通過GetRow、BatchGetRow或GetRange接口查詢數(shù)據(jù)時(shí)，可以使用過濾器只返回符合條件的數(shù)據(jù)行。

過濾器目前包括RelationalCondition和CompositeCondition。

• RelationalCondition：只判斷某個(gè)參考列的列值。

• CompositeCondition：根據(jù)多個(gè)參考列的列值的判斷結(jié)果進(jìn)行邏輯組合，決定是否過濾某行。

限制

• 過濾器的條件支持關(guān)系運(yùn)算（=、!=、>、>=、<、<=）和邏輯運(yùn)算（NOT、AND、OR），最多支持10個(gè)條件的組合。

• 過濾器中的參考列必須在讀取的結(jié)果內(nèi)。如果指定的要讀取的列中不包含參考列，則過濾器無法獲取參考列的值。

• 在GetRow、BatchGetRow和GetRange接口中使用過濾器不會(huì)改變接口的原生語義和限制項(xiàng)。

  使用GetRange接口時(shí)，一次掃描數(shù)據(jù)的行數(shù)不能超過5000行或者數(shù)據(jù)大小不能超過4 MB。

  當(dāng)在該次掃描的5000行或者4 MB數(shù)據(jù)中沒有滿足過濾器條件的數(shù)據(jù)時(shí)，得到的Response中的Rows為空，但是nextStartPrimaryKey可能不為空，此時(shí)需要使用nextStartPrimaryKey繼續(xù)讀取數(shù)據(jù)，直到nextStartPrimaryKey為空。

參數(shù)

示例

public void GetRowWithRelationalCondition(OTSClient otsClient)
{
    //定義行的主鍵，必須與創(chuàng)建表時(shí)的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("Primary key read: ");
    foreach (KeyValuePair<string, ColumnValue> entry in primaryKeyRead)
    {
        Console.WriteLine(entry.Key + ":" + PrintColumnValue(entry.Value));
    }

    Console.WriteLine("Attributes read: ");
    foreach (KeyValuePair<string, ColumnValue> entry in attributesRead)
    {
        Console.WriteLine(entry.Key + ":" + PrintColumnValue(entry.Value));
    }

    Console.WriteLine("Get row with filter succeed.");
}

public void GetRowWithCompositeCondition(OTSClient otsClient)
{
    //定義行的主鍵，必須與創(chuàng)建表時(shí)的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("Primary key read: ");
    foreach (KeyValuePair<string, ColumnValue> entry in primaryKeyRead)
    {
        Console.WriteLine(entry.Key + ":" + PrintColumnValue(entry.Value));
    }

    Console.WriteLine("Attributes read: ");
    foreach (KeyValuePair<string, ColumnValue> entry in attributesRead)
    {
        Console.WriteLine(entry.Key + ":" + PrintColumnValue(entry.Value));
    }

    Console.WriteLine("Get row with filter succeed.");
}