Java-SDK的多行数据操作

表格存储的 SDK 提供了 BatchGetRow、BatchWriteRow、GetRange 和 GetByIterator 等多行操作的接口。

批量读（BatchGetRow）


批量读取一个或多个表中的若干行数据。
BatchGetRow 操作可视为多个 GetRow 操作的集合，各个操作独立执行，独立返回结果，独立计算服务能力单元。
与执行大量的 GetRow 操作相比，使用 BatchGetRow 操作可以有效减少请求的响应时间，提高数据的读取速率。

接口/**
     * 从多张表（Table）中获取多行数据。
     *
     * @param batchGetRowRequest   执行BatchGetRow操作所需参数的封装。
     * @return                                   BatchGetRow操作的响应内容。
     * @throws OTSException             OTS访问返回错误消息
     * @throws ClientException          请求的返回结果无效， 或由于网络原因请求失败， 或访问超时。
     */
    public BatchGetRowResult batchGetRow(BatchGetRowRequest batchGetRowRequest)
            throws OTSException, ClientException;




示例


批量一次读 10 行。 try
    {
        // 构造BatchGetRow对象和参数
        BatchGetRowRequest request = new BatchGetRowRequest();
        MultiRowQueryCriteria tableRows = new MultiRowQueryCriteria(tableName);
        for (int j = 0; j < 10; ++j) {
            RowPrimaryKey primaryKeys = new RowPrimaryKey();
            primaryKeys.addPrimaryKeyColumn("pk0", PrimaryKeyValue.fromLong(j));
            primaryKeys.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromLong(j)));
            tableRows.addRow(primaryKeys);
        }
        // 只返回col0和col1列
        tableRows.addColumnsToGet(new String[] {"col0", "col1"});
        request.addMultiRowQueryCriteria(tableRows);
        // 调用batchGetRow接口
        BatchGetRowResult result = client.batchGetRow(request);
        // 统计是否有某些行执行失败，如果有，则重试
        BatchGetRowRequest failedOperations = null;
        List<Row> succeedRows = new ArrayList<Row>();
        int retryCount = 0;
        do {
            failedOperations = new BatchGetRowRequest();
            Map<String, List<BatchGetRowResult.RowStatus>> status = result.getTableToRowsStatus();
            for (Entry<String, List<BatchGetRowResult.RowStatus>> entry : status.entrySet()) {
                tableName = entry.getKey();
                tableRows = new MultiRowQueryCriteria(tableName);
                List<BatchGetRowResult.RowStatus> statuses = entry.getValue();
                for (int index = 0; index < statuses.size(); index++) {
                    BatchGetRowResult.RowStatus rowStatus = statuses.get(index);
                    if (!rowStatus.isSucceed()) {
                        // 操作失败， 需要放到重试列表中再次重试
                        // 需要重试的操作可以从request中获取参数
                        tableRows.addRow(request.getPrimaryKey(tableName, index));
                    } else {
                        succeedRows.add(rowStatus.getRow());
                        System.out.println("Read row:");
                        System.out.println("pk0：" + rowStatus.getRow().getColumns().get("pk0"));
                        System.out.println("pk1：" + rowStatus.getRow().getColumns().get("pk1"));
                        System.out.println("col0：" + rowStatus.getRow().getColumns().get("col0"));
                    }
                }
                if (!tableRows.getRowKeys().isEmpty()) {
                    tableRows.addColumnsToGet(new String[] {"col0", "col1"});
                    failedOperations.addMultiRowQueryCriteria(tableRows);
                }
            }
            if (failedOperations.isEmpty() || ++retryCount > 3) {
                // 如果所有操作都成功了或者重试次数达到上线， 则不再需要重试。
                break;
            }
            // 如果有需要重试的操作， 则稍微等待一会后再次重试， 否则继续出错的概率很高。
            try {
                // 100ms后继续重试
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            request = failedOperations;
            result = client.batchGetRow(request);
        } while (true);
        System.out.println(String.format("Get row finish, succeeded count:%d", succeedRows.size()));
    } catch (ClientException ex) {
        System.out.println("Batch get row failed.");
    } catch (OTSException ex) {
        System.out.println("Batch get row failed.");
    }

提示：

• 
  批量读也支持通过条件语句过滤。
• 
  详细代码：batchGetRow@GitHub。

• 
  批量写也支持条件语句。
• 
  详细代码：batchWriteRow@GitHub。

• 
  按范围读也支持通过条件语句过滤。
• 
  详细代码：GetRange@GitHub。

• 详细代码：GetByIterator@GitHub。