使用Reactive Cassandra无法访问含复合键的Cassandra表求助

以下是针对你使用Spring Reactive + Reactive Cassandra访问复合主键表无数据返回问题的排查与解决步骤：

1. 校验实体与表结构的映射一致性 #

• 确认UserConfig的@Table(value = "user_table")指定的表名与Cassandra中实际表名完全一致（注意Cassandra默认列名、表名均为小写，若创建表时使用了引号区分大小写，需保证注解中名称完全匹配）。
• 检查UserKey中@PrimaryKeyColumn的name属性是否与表中分区键、聚类键的列名完全一致，比如user_name和department_name是否和表结构定义一致。

2. 修复主键类的序列化问题 #

@PrimaryKeyClass标记的类必须实现Serializable接口，否则Spring Data Cassandra无法正确处理主键的序列化与反序列化，导致查询时无法匹配数据。修改UserKey类：

@Getter
@PrimaryKeyClass
@AllArgsConstructor
public class UserKey implements Serializable { // 新增Serializable接口
    @PrimaryKeyColumn(name = "user_name", ordinal = 0, type = PrimaryKeyType.PARTITIONED)
    private String userName;
    @PrimaryKeyColumn(name = "department_name", ordinal = 1, type = PrimaryKeyType.CLUSTERED)
    private String departmentName;
}

3. 调整Repository查询逻辑 #

• 先尝试使用ReactiveCassandraRepository自带的findById方法测试，传入完整的UserKey对象：

  // 调用示例
  UserKey queryKey = new UserKey("test_user", "test_dept");
  userRepository.findById(queryKey)
      .doOnNext(user -> System.out.println("查询到数据：" + user.getAddress()))
      .doOnError(err -> System.err.println("查询失败：" + err.getMessage()))
      .subscribe();
  

• 如果findById能正常返回数据，说明自定义方法命名可能存在解析问题，可改用@Query注解手动指定CQL语句：

  @Repository
  public interface UserRepository extends ReactiveCassandraRepository<UserConfig, UserKey> {
      @Query("SELECT * FROM user_table WHERE user_name = ?0 AND department_name = ?1")
      Mono<UserConfig> findByUserNameAndDepartmentName(String userName, String departmentName);
  }
  

4. 验证Cassandra配置正确性 #

• 确认CassandraConfig中的localDatacenter与Cassandra集群的实际数据中心名称完全一致，该配置错误会导致查询请求无法正确路由到对应节点，出现无数据返回的情况。
• 检查schemaAction配置：若设置为CREATE/CREATE_IF_NOT_EXISTS，可查看自动生成的表结构是否与预期一致；若为NONE，则需确保手动创建的表结构与实体类字段完全匹配。

5. 确认数据存在性与查询条件 #

直接在Cassandra客户端（如cqlsh）执行CQL查询，验证数据是否存在：

SELECT * FROM user_table WHERE user_name = '你的测试用户名' AND department_name = '你的测试部门名';

如果客户端能查到数据但代码查不到，聚焦代码层面的映射问题；如果客户端也查不到，需确认数据是否已正确写入或查询条件是否有误。

内容的提问来源于stack exchange，提问作者mang4521