:ページングクエリを活用する方法

制約

従来のリレーショナルデータベースでサポートされていたページングクエリとは異なり、 NoSQL データモデルと API のページ機能には次の制約があります。

• 範囲全体の行数を取得できません。つまり、合計ページ数を計算することはできません。
• オフセット・フィルターをクライアント上で実行し、サーバーがスキャンして読み取ったデータが固定されているため、ページ・ジャンプにオフセットを設定することはお勧めしません。オフセット値が大きすぎると、クエリに時間がかかることがあります。
• シーケンシャルページングのみがサポートされています。

サンプルコード

以下は、ページングされた読み込み API を実装するためのサンプルコードです。この API には、オフセットフィルタが含まれ、指定された数のページのデータが読み込まれます。

    /**
     * Query data in the specified range, return data on pages of specified numbers, and skip some rows according to the offset value.
     */
    private static Pair<List<Row>, RowPrimaryKey> readByPage(OTSClient client, String tableName, 
            RowPrimaryKey startKey, RowPrimaryKey endKey, int offset, int pageSize) {
        Preconditions.checkArgument(offset >= 0, "Offset should not be negative.");
        Preconditions.checkArgument(pageSize > 0, "Page size should be greater than 0.");
        List<Row> rows = new ArrayList<Row>(pageSize);
        int limit = pageSize;
        int skip = offset;
        RowPrimaryKey nextStart = startKey;
        // If too much data needs to be queried, not all the data is returned through one request. You must perform stream query to obtain the data.
        while (limit > 0 && nextStart != null) {
            // Construct a query parameter of GetRange.
            // NOTE: Set the startPrimaryKey to the last point that has been read, so that the steam query continues from the point that has not been read yet in the previous operation.
            RangeRowQueryCriteria criteria = new RangeRowQueryCriteria(tableName);
            criteria.setInclusiveStartPrimaryKey(nextStart);
            criteria.setExclusiveEndPrimaryKey(endKey);
            // Correctly set the limit. The number of data rows expected to be read is at most a complete page of data and data that needs to be filtered (offset).
            criteria.setLimit(skip + limit);
            GetRangeRequest request = new GetRangeRequest();
            request.setRangeRowQueryCriteria(criteria);
            GetRangeResult response = client.getRange(request);
            for (Row row : response.getRows()) {
                if (skip > 0) {
                    skip--; // Data before offset must be filtered out. The policy is reading the data first and then filtering the data on the client.
                } else {
                    rows.add(row);
                    limit--;
                }
            }
            // Set the start point for the next query.
            nextStart = response.getNextStartPrimaryKey();
        }
        return new Pair<List<Row>, RowPrimaryKey>(rows, nextStart);
    }

以下は、上記の API を使用して、指定された範囲内のすべてのデータをページ単位で読み取る例です。

    private static void readByPage(OTSClient client, String tableName) {
        int pageSize = 8;
        int offset = 33;
        RowPrimaryKey startKey = new RowPrimaryKey();
        startKey.addPrimaryKeyColumn(COLUMN_GID_NAME, PrimaryKeyValue.INF_MIN);
        startKey.addPrimaryKeyColumn(COLUMN_UID_NAME, PrimaryKeyValue.INF_MIN);
        RowPrimaryKey endKey = new RowPrimaryKey();
        endKey.addPrimaryKeyColumn(COLUMN_GID_NAME, PrimaryKeyValue.INF_MAX);
        endKey.addPrimaryKeyColumn(COLUMN_UID_NAME, PrimaryKeyValue.INF_MAX);
        // Start reading data of the row with offset = 33 in the range on the first page.
        Pair<List<Row>, RowPrimaryKey> result = readByPage(client, tableName, startKey, endKey, offset, pageSize);
        for (Row row : result.getKey()) {
            System.out.println(row.getColumns());
        }
        System.out.println("Total rows count: " + result.getKey().size());
        // Read data on the following pages in sequence until all the data in the range is read.
        startKey = result.getValue();
        while (startKey != null) {
            System.out.println("============= start read next page ==============");
            result = readByPage(client, tableName, startKey, endKey, 0, pageSize);
            for (Row row : result.getKey()) {
                System.out.println(row.getColumns());
            }
            startKey = result.getValue();
            System.out.println("Total rows count: " + result.getKey().size());
        }
    }

注： こちらをクリックして完全な例をダウンロードしてください。