SpringHibernate恩维尔斯：正在修改的捕获实体

Question

是否可以在CustomEntityTrackingListener或CustomRevsionListener中捕获正在修改的实体（Book）？

我试图获取通过API/save book或/update/{id}/{pages}传递的所有信息，而不仅仅是版本信息。

在 envers 审核实体时，它会自动为每个实体创建一个_AUD表和一个修订表，以连接实体及其_AUD表

使用自定义的修订监听程序，我只能得到有关修订的信息，但我想达到实体本身正在被修改和保存。

...
    @PostMapping("/saveBook")
    public Book saveBook(@RequestBody Book book) {
        return repository.save(book);
    }

    @PutMapping("/update/{id}/{pages}")
    public Book updateBook(@PathVariable int id, @PathVariable int pages) {
        Book book = repository.findById(id).get();
        book.setPages(pages);
        return repository.save(book);
    }
...

@Entity
@AllArgsConstructor
@NoArgsConstructor
@Data
@Audited
public class Book {

    @Id
    @GeneratedValue
    private int id;

    private String name;

    private int pages;
}

@Entity
//@RevisionEntity(ExampleListener.class)
@RevisionEntity(CustomEntityTrackingRevisionListener.class)
public class ExampleRevEntity extends DefaultRevisionEntity {


    private String username;


    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    @OneToMany(mappedBy="revision", cascade={CascadeType.PERSIST, CascadeType.REMOVE})
    private Set<ModifiedEntityTypeEntity> modifiedEntityTypes =
            new HashSet<ModifiedEntityTypeEntity>();

}

public class ExampleListener implements RevisionListener {

    @Override
    public void newRevision(Object revisionEntity) {
        ExampleRevEntity exampleRevEntity = (ExampleRevEntity) revisionEntity;
        //Identity identity = (Identity) Component.getInstance("org.jboss.seam.security.identity");

        exampleRevEntity.setUsername("Joaquin");
    }
}

public class CustomEntityTrackingRevisionListener implements EntityTrackingRevisionListener {
    @Override
    public void entityChanged(Class entityClass, String entityName,
                              Serializable entityId, RevisionType revisionType,
                              Object revisionEntity) {

        String type = entityClass.getName();
        //((CustomTrackingRevisionEntity)revisionEntity).addModifiedEntityType(type);
        ((ExampleRevEntity)revisionEntity).addModifiedEntityType(type);
    }

    @Override
    public void newRevision(Object revisionEntity) {

    }

}

Answer 1

有几种方法可以做到这一点。

• 介绍自己的活动听众
• 使用像Debezium这样的CDC（更改数据捕获）技术。

在第一种方法中，您可能希望遵循Envers留档中关于如何进行条件审核的建议，并引入自定义事件侦听器来扩展Envers侦听器，以便推断更改并执行您需要的任何任务。

这可能是一个非常令人生畏和乏味的步骤，因为您必须了解Hibernate如何在事件中发出数据，如何解决差异等。

我相信这里更简单的方法是使用像Debezium这样的工具，它使您能够设置一个监视配置数量的表的作业，在您的用例中，特定_AUD感兴趣的表。每次 Envers 插入到这些表中时，Debezium 都会通过生成一个事件来对插入做出反应，然后您可以异步地对该事件做出反应。

Debezium有几种使用方式，包括嵌入到可能适合您的用例的应用程序中，或者嵌入到独立于应用程序的Kafka Connect实例中，为事件捕获和调度提供冗余和容错。

Answer 2

EntityTrackingRevisionListener.entityChanged（）在对象持久性之后执行，因此您可以使用提供的标识符和实体类，通过EntityManager的find（）方法从持久性上下文中获取它。