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

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

注意事項

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

前提條件

方法說明

public function batchGetRow(array $request)

$request參數說明

tables（必選）array：批量讀取資料資訊，包含以下參數。

名稱	類型	說明
table_name（必選）	string	資料表名稱。
primary_keys（必選）	array	主鍵資訊，包括主鍵列名稱和主索引值。主鍵列資料類型包括 STRING、INTEGER 和 BINARY。主鍵個數和類型必須與資料表的主鍵保持一致。
max_versions（可選）	int	最大版本數。必須設定最大版本數和版本範圍的其中一個。如果符合查詢條件的資料版本數量超過設定的最大版本數，按從新到舊的順序返回指定版本數量的資料。
time_range（可選）	array	資料版本範圍。必須設定最大版本數和版本範圍的其中一個。 Table Store資料表的每個屬性列可以有不同的資料版本，設定版本範圍後，僅返回版本範圍內的資料。
columns_to_get（可選）	array	指定讀取的資料列，可以是主鍵列或屬性列。不設定columns_to_get時，返回整行資料。設定columns_to_get時，如果讀取的行資料不包含任何指定的資料列，將返回 null。
column_filter（可選）	array	過濾條件，詳情請參見過濾器。如果同時設定columns_to_get和column_filter，先按columns_to_get篩選合格資料行，再按column_filter條件過濾資料。

範例程式碼

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

$table = array (
    'table_name' => 'test_table',
    'max_versions' => 1,
    'primary_keys' => array (
        array ( array('id', 'row1') ),
        array ( array('id', 'row2') )
    )
);

$request = array (
    'tables' => array (
        $table
    )
);

try {
    // 調用 batchGetRow 方法讀取行資料
    $response = $client->batchGetRow ($request);

    // 返回結果處理
    foreach ($response['tables'] as $tableGroup) {
        echo "* Table: " . $tableGroup['table_name'] . "\n";
        foreach ($tableGroup['rows'] as $row) {
            if ($row['is_ok']) {
                if ($row['primary_key'] != null) {
                    echo "Succeeded Row: " . json_encode($row['primary_key']) . json_encode($row['attribute_columns']) . "\n";
                } else {
                    echo "Succeeded Row: This row is not exist." . "\n";
                }
            } else {
                echo "Failed Row: " . $row['error']['code'] . '. ' . $row['error']['message'] . "\n";
            }
        }
    }
} catch (Exception $e){
    echo "Batch get row failed.";
}

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

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

$table1 = array (
    'table_name' => 'orders_small',
    'max_versions' => 1,
    'primary_keys' => array (
        array (
            array('order_id', '90fb478c-1360-11f0-a34d-00163e30a2a9')
        )
    )
);

$request = array (
    'tables' => array (
        $table,
        $table1
    )
);

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

// 設定查詢的資料版本範圍為目前時間往前一天
$table['time_range'] = array (
    'start_time' => intval(microtime(true) * 1000) - 86400 * 1000,
    'end_time' => intval(microtime(true) * 1000)
);

指定讀取的屬性列。

$table['columns_to_get'] = array('col2');

Tablestore：批量讀取資料

注意事項

前提條件

方法說明

範例程式碼

相關文檔