Tablestore提供了單行讀取和範圍讀取的查詢方式用於讀取索引表中資料。當返回的屬性列在索引表中時,您可以直接讀取索引表擷取資料,否則請自行反查資料表擷取資料。
前提條件
已初始化Client。具體操作,請參見初始化OTSClient。
已建立二級索引。具體操作,請參見建立二級索引。
注意事項
索引表只能用於讀取資料。
當需要返回的屬性列不在索引表中時,您需要自行反查資料表來擷取資料。
單行讀取資料
調用GetRow介面讀取一行資料。更多資訊,請參見讀取單行資料。
參數
使用GetRow介面讀取索引表中資料時有如下注意事項:
tableName需要設定為索引表名稱。
由於系統會自動將未出現在索引列中的資料表主鍵補齊到索引表主鍵中,所以設定行的主鍵時,需要同時設定索引表索引列和補齊的資料表主鍵。
樣本
以下樣本用於讀取索引表中指定主鍵的行資料。
public static void GetRowfromIndex()
{
OTSClient otsClient = Config.GetClient();
//構造主鍵。構造主鍵時必須帶上補齊到索引表中的資料表主鍵。
PrimaryKey primaryKey = new PrimaryKey
{
{ "col0", new ColumnValue(0) },
{ "pk1", new ColumnValue(0) },
{ "pk2", new ColumnValue("abc") }
};
try
{
//構造查詢請求對象,此處未指定讀取的列,預設讀取整行資料。
var request = new GetRowRequest(IndexName, primaryKey);
//調用GetRow介面查詢資料。
var response = otsClient.GetRow(request);
Console.WriteLine("Primary Key: " + response.PrimaryKey);
Console.WriteLine("Attribute Column: " + response.Columns[0]);
//如果沒有拋出異常,則說明執行成功。
Console.WriteLine("Get row succeeded.");
}
catch (Exception ex)
{
//如果拋出異常,則說明執行失敗,處理異常。
Console.WriteLine("Get row failed, exception:{0}", ex.Message);
}
}
範圍讀取資料
調用GetRange介面讀取一個範圍內的資料。更多資訊,請參見範圍讀取資料。
參數
使用GetRange介面讀取索引表中資料時有如下注意事項:
tableName需要設定為索引表名稱。
由於系統會自動將未出現在索引列中的資料表主鍵補齊到索引表主鍵中,所以設定起始主鍵和結束主鍵時,需要同時設定索引表索引列和補齊的資料表主鍵。
樣本
以下樣本用於讀取索引表中指定主鍵範圍內的資料。其中第一列主鍵col1的列值為0。
public static void GetRangeFromIndexTable()
{
Console.WriteLine("Start getRange from index...");
OTSClient otsClient = Config.GetClient();
//指定第一主鍵Col1的值,進行掃描。
PrimaryKey inclusiveStartPrimaryKey = new PrimaryKey
{
{ "col1", new ColumnValue(0) },
{ "pk1", ColumnValue.INF_MIN },
{ "pk2", ColumnValue.INF_MIN }
};
PrimaryKey exclusiveEndPrimaryKey = new PrimaryKey
{
{ "col1", new ColumnValue(0) },
{ "pk1", ColumnValue.INF_MAX },
{ "pk2", ColumnValue.INF_MAX }
};
GetRangeRequest request = new GetRangeRequest(IndexName, GetRangeDirection.Forward, inclusiveStartPrimaryKey, exclusiveEndPrimaryKey);
GetRangeResponse response = otsClient.GetRange(request);
IList<Row> rows = response.RowDataList;
PrimaryKey nextStartPrimaryKey = response.NextPrimaryKey;
while (nextStartPrimaryKey != null)
{
request = new GetRangeRequest(TableName, GetRangeDirection.Forward, nextStartPrimaryKey, exclusiveEndPrimaryKey);
response = otsClient.GetRange(request);
nextStartPrimaryKey = response.NextPrimaryKey;
foreach (var row in response.RowDataList)
{
rows.Add(row);
}
}
foreach (var row in rows)
{
PrintRow(row);
}
Console.WriteLine("TotalRowsRead: " + rows.Count);
}
private static void PrintRow(Row row)
{
Console.WriteLine("-----------------");
foreach (KeyValuePair<string, ColumnValue> entry in row.GetPrimaryKey())
{
Console.WriteLine(entry.Key + ":" + entry.Value);
}
foreach (Column entry in row.GetColumns())
{
Console.WriteLine(entry.Name + ":" + entry.Value);
}
Console.WriteLine("-----------------");
}