我正在寻找一个解决方案，用cassandra（版本 3.11.3 )数据库。我们用的是Spring Boot 2.0.5.RELEASE 与 spring-boot-starter-data-cassandra 作为一种依赖。
作为spring数据的 CassandraRepository<T, ID> 接口不扩展 PagingAndSortingRepository 我们没有像以前那样获得完整的分页功能 JPA .
我阅读了spring数据cassandra文档，可以找到一种可能的方法来实现以cassandra和spring数据为基础的分页 CassandraRepository 接口具有以下可用方法 Slice<T> findAll(Pageable pageable); . 我知道cassandra无法获得特定的页面，并且总是需要page zero来遍历所有页面，正如文档中所记录的那样 CassandraPageRequest :
cassandra特定的{@link pagerequest}实现，提供对{@link pagingstate}的访问。这个类允许创建第一个页面请求，并表示通过cassandra分页是基于获取页面的进度，并且只允许向前导航。访问特定页面需要获取所有页面，直到到达所需页面。
在我的用例中，我们有>1.000.000个数据库条目，并希望在单页应用程序中分页显示它们。
我目前的方法如下：
@RestController
@RequestMapping("/users")
public class UsersResource {
@Autowired
UserRepository userRepository;
@GetMapping
public ResponseEntity<List<User>> getAllTests(
@RequestParam(defaultValue = "0", name = "page") @Positive int requiredPage,
@RequestParam(defaultValue = "500", name = "size") int size) {
Slice<User> resultList = userRepository.findAll(CassandraPageRequest.first(size));
int currentPage = 0;
while (resultList.hasNext() && currentPage <= requiredPage) {
System.out.println("Current Page Number: " + currentPage);
resultList = userRepository.findAll(resultList.nextPageable());
currentPage++;
}
return ResponseEntity.ok(resultList.getContent());
}
}但是使用这种方法，我必须找到请求的页面，同时将所有数据库条目提取到内存中，并进行迭代，直到找到正确的页面。是否有不同的方法来找到正确的页面，或者我必须使用当前的解决方案？
我的cassandra表定义如下所示：
CREATE TABLE user (
id int, firstname varchar,
lastname varchar,
code varchar,
PRIMARY KEY(id)
);
3条答案
按热度按时间c9x0cxw01#
请参见下面的代码。可能会有帮助。
2fjabf4q2#
cassandra支持正向分页，这意味着您可以获取前n行，然后可以获取n+1和2n之间的行，依此类推，直到数据结束，但不能直接获取n+1和2n之间的行。
b09cbbtk3#
我所做的是创建一个包含内容和pagingstate散列的page对象。
在初始页面中，我们有简单的分页
Pageable pageRequest = CassandraPageRequest.of(0,5);一旦找到了我们就得到了切片Slice<Group> slice = groupRepository.findAll(pageRequest);使用切片可以获得分页状态page.setPageHash(getPageHash((CassandraPageRequest) slice.getPageable()));哪里private String getPageHash(CassandraPageRequest pageRequest) { return Base64.toBase64String(pageRequest.getPagingState().toBytes()); }最后返回一个页面对象，其列表内容和pagingstate为pagehash