Kundera cassandra - 事务回滚和实体更新

Question

我使用 Kundera-Cassandra 3.2，想使用 Kundera 的事务管理。

我的处理方式是这样的：

EntityManager manager = repo.getEntityManagerFactory().createEntityManager(CassandraRepository.getProperties());

try{
    manager.getTransaction().begin();

    this.repo.update(account1, manager); //calls the merge method of the Entitymanager
    this.repo.save(account2, manager); //calls the persist method of the Entitymanager

    manager.getTransaction().commit();

} catch(Exception e){
    if(manager.getTransaction().isActive()){
        manager.getTransaction().rollback();
    }
} finally {
    manager.clear();
    manager.close();
}

当this.repo.save(account2, manager);发生错误时，管理器回滚了事务，但没有做update语句，他为merge方法做了delete语句。这样做的原因是，在调用 merge 方法时，kundera 创建了一个插入语句而不是更新。但是怎么说昆德拉做一个更新回滚事务也用一个更新。

日志：

12:42:41.185 [http-bio-8080-exec-3] INFO com.impetus.client.cassandra.CassandraClientBase - Returning delete query DELETE FROM "account" WHERE "id" = 'MCSP-000000000004'.
12:42:41.211 [http-bio-8080-exec-3] INFO com.impetus.client.cassandra.CassandraClientBase - Returning delete query DELETE FROM "account" WHERE "id" = 'MCSP-000000000005'.

编辑（我的存储库）：

public class CassandraRepository<T> {

    @PersistenceUnit
    private EntityManagerFactory entityManagerFactory;

    public static Map<String, String> getProperties() {
        final Map<String, String> properties = new HashMap<String, String>();
        properties.put(CassandraConstants.CQL_VERSION, CassandraConstants.CQL_VERSION_3_0);
        return properties;
    }



    public void update(T entity, EntityManager manager) throws Exception{
        try {
            manager.merge(entity);
        } catch (Exception e) {
            e.printStackTrace();
            throw e;
        }
    }

    public void save(T entity, EntityManager manager) throws Exception{
        try {
            manager.persist(entity);
        } catch (Exception e) {
            e.printStackTrace();
            throw e;
        }
    }
}

Answer 1

根据 JPA，要更新实体，您必须先将其置于托管状态（通过获取）

示例：-

        PersonCassandra p = entityManager.find(PersonCassandra.class, "2");

        entityManager.getTransaction().begin();
        p.setMonth(Month.JAN);
        entityManager.merge(p);
        entityManager.persist(p3);
        entityManager.getTransaction().commit();

问题不在于 INSERT 和 UPDATE 语句，因为两者对于 Cassandra 来说都是相似的。

Kundera cassandra - 事务回滚和实体更新

Kundera cassandra - Transaction rollback and Entity update

java

cassandra

kundera