Table Store Java SDK 批量讀取資料 - Tablestore

本文介紹如何通過 Java SDK 批量讀取Table Store中的資料，支援查詢多個表的資料。

注意事項

單次批量讀取操作最多支援讀取 100 行資料。

前提條件

方法說明

public BatchGetRowResponse batchGetRow(BatchGetRowRequest batchGetRowRequest) throws TableStoreException, ClientException

BatchGetRowRequest參數說明

criteriasGroupByTable（必選）Map<String, MultiRowQueryCriteria>：批量讀取資料資訊。MultiRowQueryCriteria 包含以下參數。

說明

查詢多個表的資料時，一個表對應一個 MultiRowQueryCriteria，MultiRowQueryCriteria內所有的資料行採用相同的查詢條件。

名稱	類型	說明
tableName（必選）	String	資料表名稱。
rowKeys（必選）	List<PrimaryKey>	主鍵列表。
maxVersions（可選）	OptionalValue<Integer>	最大版本數。必須設定最大版本數和版本範圍的其中一個。如果符合查詢條件的資料版本數量超過設定的最大版本數，按從新到舊的順序返回指定版本數量的資料。
timeRange（可選）	OptionalValue<TimeRange>	資料版本範圍。必須設定最大版本數和版本範圍的其中一個。 Table Store資料表的每個屬性列可以有不同的資料版本，設定版本範圍後，僅返回版本範圍內的資料。
columnsToGet（可選）	Set<String>	指定讀取的資料列，可以是主鍵列或屬性列。不設定columnsToGet時，返回整行資料。設定columnsToGet時，如果讀取的行資料不包含任何指定的資料列，將返回 null。
filter（可選）	OptionalValue<Filter>	過濾條件，詳情請參見過濾器。如果同時設定columnsToGet和filter，先按columnsToGet篩選合格資料行，再按filter條件過濾資料。

範例程式碼

以下範例程式碼用於讀取 test_table 表中主索引值為 row1 和 row2 的兩行資料。

public static void batchGetRowExample(SyncClient client) {
    // 構造查詢條件
    MultiRowQueryCriteria multiRowQueryCriteria = new MultiRowQueryCriteria("test_table");
    // 添加第 1 行主鍵資訊
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("id", PrimaryKeyValue.fromString("row1"));
    multiRowQueryCriteria.addRow(primaryKeyBuilder.build());
    // 添加第 2 行主鍵資訊
    primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("id", PrimaryKeyValue.fromString("row2"));
    multiRowQueryCriteria.addRow(primaryKeyBuilder.build());
    // 設定查詢版本
    multiRowQueryCriteria.setMaxVersions(1);

    // 調用 batchGetRow 方法進行批量資料查詢
    BatchGetRowRequest batchGetRowRequest = new BatchGetRowRequest();
    batchGetRowRequest.addMultiRowQueryCriteria(multiRowQueryCriteria);
    BatchGetRowResponse batchGetRowResponse = client.batchGetRow(batchGetRowRequest);

    // 返回結果處理
    System.out.println("* RequestId: " + batchGetRowResponse.getRequestId());
    System.out.println("* Is all succeeded: " + batchGetRowResponse.isAllSucceed());
    // 列印讀取成功的行
    System.out.println("* Succeeded Rows: ");
    for(BatchGetRowResponse.RowResult rowResult:batchGetRowResponse.getSucceedRows())
        System.out.println(rowResult.getRow());
    // 列印讀取失敗的行
    if(!batchGetRowResponse.isAllSucceed()) {
        System.out.println("* Failed Rows: ");
        for(BatchGetRowResponse.RowResult rowResult:batchGetRowResponse.getFailedRows())
            System.out.println(rowResult.getTableName() + " | " + batchGetRowRequest.getPrimaryKey(rowResult.getTableName(), rowResult.getIndex()) + " | " + rowResult.getError());
    }
}

您可以在批量讀取資料時參考以下範例程式碼進行參數設定。

讀取多張表的資料。批量讀取支援一次讀取多張表的資料，您需要為每張表指定一個MultiRowQueryCriteria。

// 構造第 2 個表的查詢條件
MultiRowQueryCriteria multiRowQueryCriteria1 = new MultiRowQueryCriteria("orders_small");
// 添加第 1 行主鍵資訊
primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
primaryKeyBuilder.addPrimaryKeyColumn("order_id", PrimaryKeyValue.fromString("90fb478c-1360-11f0-a34d-00163e30a2a9"));
multiRowQueryCriteria1.addRow(primaryKeyBuilder.build());
// 設定查詢版本
multiRowQueryCriteria1.setMaxVersions(1);
// Request 添加 MultiRowQueryCriteria
batchGetRowRequest.addMultiRowQueryCriteria(multiRowQueryCriteria1);

設定讀取的資料版本範圍，結果只返回版本範圍內的資料。

// 設定查詢的資料版本範圍為目前時間往前一天
multiRowQueryCriteria.setTimeRange(new TimeRange(System.currentTimeMillis() - 86400*1000, System.currentTimeMillis()));

指定讀取的屬性列。

multiRowQueryCriteria.addColumnsToGet("col1");

Tablestore：批量讀取資料

注意事項

前提條件

方法說明

範例程式碼

相關文檔