Astyanax的EntityPersister和集合更新

Question

背景

Astyanax的实体持久器将实体的Map保存在多个列中。格式是mapVariable.key

问题：

在更新实体中的Map时，astyanax的实体持久器不会从cassandra中删除已删除的键/值对

我现在使用的解决方案(糟糕的方法)

我要删除整行，然后重新插入

更多信息

我使用astyanax的实体持久器(com.netflix.astyanax.entitystore)将java对象保存在cassandra中。

我注意到的是，当一个实体的Map持久化时，比如两个值: testkey:testvalue &testkey 2:testvalue 2，而下次同一个实体的Map用一个值持久化时(删除了一个键/值对)：testkey:testvalue，没有从列家族中删除testkey 2:testvalue 2。

因此，作为一个解决方案，我需要删除整行，然后重新插入它。

我的插入代码：

        final EntityManager<T, String> entityManager = new DefaultEntityManager.Builder<T, String>()
            .withEntityType(clazz)
            .withKeyspace(getKeyspace())
            .withColumnFamily(columnFamily)
            .build();
    entityManager.put(entity);

我遗漏了什么？这是非常低效的，我认为astyanax的实体持久器应该自己来处理这个问题。

有什么想法吗？

Answer 1

你什么都没错过。

所发生的事情如下: 1. Astyanax为序列化下实体的每个字段创建一个ColumnMappers列表。2.然后，ColumnMappers依次填充突变批。3.地图采用MapColumnMapper。如果您查看它的代码，您将看到它只是将键:值对添加到突变批处理中。4.当数据在cassandra中排行时，会添加来自批处理的新列，覆盖现有的列，不幸的是，旧列仍然是相同的。

这里的一个解决方案是为您的映射编写一个自定义序列化程序，并将其保存在一个字段中。

Answer 2

看看https://github.com/deanhiller/playorm为cassandra、hbase和其他几个nosql数据库提供的orm映射器。它在保存时从集合中删除项。它也更容易使用，然后astyanax。