Skip to content

SimpleCassandraRepository.deleteAllById removing only first element #1298

@Veermove

Description

@Veermove

Hi, recently i found, what i believe to be a bug. While using ReactiveCassandraRepository i found that while using a composite key, the method deleteAllById deleted only the first element from provided Iterable. The setup looked like this:

interface ReactiveCassandraRepository<Center, CenterKey>
@Table("center")
class Center {
    @PrimaryKeyColumn(type = PrimaryKeyType.CLUSTERED, ordinal = 0)
    private String id;
    @PrimaryKeyColumn(type = PrimaryKeyType.PARTITIONED)
    private Boolean active;
    @PrimaryKeyColumn(type = PrimaryKeyType.CLUSTERED, ordinal = 1)
    private String countryCode;
    private String description;
}
class CenterKey extends BasicMapId {
 ... 
}

When providing List<CenterKey> to the dleteAllById, i found that only first element was deleted.

I belive this issue is in SimpleReactiveCassandraRepository, where, if using composite key, we provide Flux publisher to the method, deleteById, but this method later does Mono.from(publisher).

Metadata

Metadata

Assignees

Labels

Type

No type

Projects

No projects

Relationships

None yet

Development

No branches or pull requests

Issue actions