java - Spring Data Cassandra:InvalidQueryException:UUID 应为 16 或 0 字节 (20)
问题描述
实体
@Builder
@Getter @Setter
@ToString(doNotUseGetters = true)
@EqualsAndHashCode(doNotUseGetters = true)
@Table(value = "entity")
public class Entity implements Serializable {
@PrimaryKeyColumn(name = "id", ordinal = 0, type = PrimaryKeyType.PARTITIONED)
@CassandraType(type = DataType.Name.UUID)
private UUID Id;
@Column("list_name")
@CassandraType(type = DataType.Name.TEXT)
private String name;
@Column("type")
@CassandraType(type = DataType.Name.TINYINT)
private Byte type;
实体回购
@Repository
public interface EntityRepo extends BaseRepo<Entity, UUID> {
@Query("SELECT * FROM entity WHERE id IN (:id)")
Collection<ListEntity> findByIds(@Param("id") Collection<UUID> listIds);
@Query("SELECT * FROM entity WHERE list_id = :id")
ListEntity findById(@Param("id") UUID id);
}
询问
listRepo.findByListId(UUIDs.random())
listRepo.findByListIds(Arrays.asList(UUIDs.random())
两者都导致
CassandraInvalidQueryException/InvalidQueryException
org.springframework.data.cassandra.CassandraInvalidQueryException: Query; CQL
[SELECT * FROM lists WHERE list_id IN (?)]; UUID should be 16 or 0 bytes (20);
nested exception is com.datastax.driver.core.exceptions.`InvalidQueryException: UUID should be 16 or 0 bytes (20)
这里有什么遗漏吗?有人可以帮忙吗?
解决方案
这是我的工作。
使用:findAllBy[object-property]In其中 [object-property] 是 MyModel UUID 的属性名称。
@Table("example")
public class MyModel {
@PrimaryKeyColumn(name = "uuid", type = PrimaryKeyType.PARTITIONED)
private UUID uuid;
@Column("...")
...
}
public interface MyRepository extends CassandraRepository<MyModel, UUID> {
List<Restaurant> findAllByUuidIn(Collection<UUID> uuidButIfYouWant);
}
// It is OK
return this.myRepository.findAllByUuidIn(Set.of(
UUID.randomUUID(),
UUID.randomUUID()
));
// Throw Error: no viable alternative at input '<EOF>' (SELECT * FROM example WHERE [uuid] IN...)
return this.myRepository.findAllByUuidIn(Set.of());
所以如果不包含 uuid:
Collection<UUID> search = Set.of();
if(search.size() == 0) {
return List.of();
}
return this.myRepository.findAllByUuidIn(search);