是否有Quarkus cassandra客户端进行分页的工作示例？

Question

我仍然使用quarkus cassandra客户端 https://quarkus.io/guides/guides/guides/cassandra 我整天都在尝试完成Quarkus集成的分页，但该文档根本没有帮助。 这里的其他人有一个与Quarkus Cassandra客户分页的示例？ 请与我分享您的知识。 提前致谢。

编辑：这个我的示例项目/游乐场： https：//githbithub.com/Edward-fardward-farkhouri /Quarkus-Cassandra-playground 在这里，您可以找到一个工作示例。

我在此Cassandra文档中找到了一些东西： 并实施了偏置股票，但实际上并不是我正在寻找的...

Answer 1

使用最新的Cassandra Bom，您可以

<dependency>
    <groupId>com.datastax.oss.quarkus</groupId>
    <artifactId>cassandra-quarkus-bom</artifactId>
    <version>1.1.2</version>
    <type>pom</type>
    <scope>import</scope>
</dependency>

使用Docker Cassandra开始工作这些测试，此后您的功能开始工作了

    @Override
    public List<Customer> findPagedCustomerByCustomerNumber(String customerNumber, int pageNumber, int pageSize) {
        List<Customer> result = new ArrayList<>();
        PreparedStatement query = cqlSession.prepare(
                "SELECT * FROM test.customer WHERE customer_number = :customerNumber ORDER BY  creation_date");
        BoundStatement completeStatement = query.bind().setString("customerNumber", customerNumber);
        OffsetPager pager = new OffsetPager(pageSize);
        ResultSet resultSet = cqlSession.execute(completeStatement);
        OffsetPager.Page<Row> page = pager.getPage(resultSet, pageNumber);
        List<Row> pageElements = page.getElements();
        pageElements.forEach(c -> result.add(Customer.builder()
                .customerNumber(c.getString("customer_number"))
                .creationDate(c.getLocalDate("creation_date"))
                .description(c.getString("description"))
                .state(c.getString("state"))
                .build())
        );
        return result;
    }

很长一段时间，所以我还补充说，

public List<Customer> findPagedCustomerByCustomerNumberPaging(String customerNumber, int pageNumber, int pageSize) {
        List<Customer> result = new ArrayList<>();
        Select select = QueryBuilder.selectFrom("test", "customer")
                .columns("customer_number", "creation_date", "description", "state")
                .whereColumn("customer_number").isEqualTo(literal(customerNumber))
                .orderBy("createtion_date", ClusteringOrder.ASC)
                .allowFiltering();

        SimpleStatement completeStatement = select.build();
        OffsetPager pager = new OffsetPager(pageSize);
        ResultSet resultSet = cqlSession.execute(completeStatement);
        OffsetPager.Page<Row> page = pager.getPage(resultSet, pageNumber);
        List<Row> pageElements = page.getElements();
        pageElements.forEach(c -> result.add(Customer.builder()
                .customerNumber(c.getString("customer_number"))
                .creationDate(c.getLocalDate("creation_date"))
                .description(c.getString("description"))
                .state(c.getString("state"))
                .build())
        );
        return result;
    }

我也了解到Cassandra-Quarkus-test-frame-framework会带来Docker，但在情况您没有docker，您可以随时使用 cassandraunit 较轻的doight。所有代码均可找到

Answer 2

Quarkus Cassandra客户端有分页，但是我也无法像我想要的那样使其正常工作。在下面，您可以看到一个示例以获取分页态，其中包含Quarkus文档 https://quarkus.io/guides/guides /cassandra

public PagingFruit getPagingState(String pagingState){
        ByteBuffer state = ByteBuffer.wrap(pagingState.getBytes());
        MutinyMappedReactiveResultSet<Fruit> fruit = this.fruitMapper.fruitDao().findAll(x -> x.setPagingState(state).setPageSize(1000); // here we provide the unary operator that sets the state.  
        var newState = Uni.createFrom().publisher(fruit.getExecutionInfos()).map(ExecutionInfo::getPagingState).await().indefinitely().toString();
        return new PagingFruit(fruit.collect().asList().await().indefinitely(), newState);
}

record PagingFruit(List<Fruit> fruit, String pagingState){}

这使用了mutinyMappedReactiverEsultSet，该群可以使您查询executionInfos。

我目前使用Quarkus实施的问题是，我需要两次查询Cassandra，以实际提供数据和分页。因此，我选择了这样的示例的准备好的陈述：

class PaginatedRepository {

    private final QuarkusCqlSession cqlSession;
    private final PreparedStatement query;
    
    PaginatedRepository(QuarkusCqlSession quarkusCqlSession){
        this.cqlSession = quarkusCqlSession;
        this.query = cqlSession.prepare("SELECT fruit FROM keypace.table");
    }
    
    public Uni<PagingFruit> findFruit(String page) {
        var statement = query
                .bind()
                .setPageSize(1000)
                .setPagingState(PagingState.fromString(page));
    
        return Uni.createFrom().completionStage(cqlSession.executeAsync(statement))
                .map(resultSet -> {
                    var pagingState = resultSet.getExecutionInfo().getSafePagingState();
                    var newCursor = (pagingState == null) ? null : pagingState.toString();
                    var rows = Streams.stream(resultSet.currentPage())
                            .map(row -> row.get(1, Fruit.class)
                            ).filter(Objects::nonNull).toList();
                    return new PagingFruit(rows, newCursor);
                });
    }

这是未经测试的代码，只是应该有效的一般概念。

Answer 3

因此，在我的反对和我的研究中，与Quarkus cassandra客户在Cassandra数据库上进行分页没有令人信服的方法。您必须自己处理。