0

我用于删除基于索引列的行的当前方法

  1. 选择限制为 100 的查询。
  2. 如果有行,将所有获取的行一一删除。
  3. 刷新实体管理器。
  4. 转到步骤 1。

使用 cassandra 2.1.8 和 kundera-cassandra-ds-driver 从 cassandra 获取行。

有什么方法可以从 Kundera 触发删除查询。

4

1 回答 1

1

您可以执行以下操作:

Query findQuery = entityManager.createQuery("Delete from PersonCassandra p where p.age = 10",
            PersonCassandra.class);
findQuery.setMaxResults(5000);
findQuery.executeUpdate();

PS:Cassandra 不允许基于非主键删除行,Kundera 在内部以与您类似的方式处理此问题。

于 2016-01-13T08:56:07.683 回答