如何使用Hibernate Envers审核数据，包括用户名信息

清疚 2023-09-25 13:13 52阅读 0赞

最近，我一直在一个项目中工作，该项目需要审核所有数据库事务，包括用户名。为此，我一直在使用[Hibernate ORM Envers][]，它旨在实现持久类的简单审计/版本控制。

为了在这篇文章中展示如何使用Hibernate Envers，我基于这个Spring boot JPA项目构建[了一个示例项目][Link 1]。Spring Boot 可以轻松创建独立的、生产级的基于 Spring 的应用程序，您可以“直接运行”。在这种情况下，它非常方便，因为它包括：嵌入式雄猫，“入门”POM以简化您的Maven配置，以及随时可用的REST Web服务。

这篇文章的结构分为 5 个简单的步骤，但是，最后 2 个步骤仅在您想将用户名（或任何其他信息）添加到修订版时才有用。

[1. 配置休眠模拟器][1.]

[2. 审计表][2.]

[3. 阅读修订版][3.]

[4. 为每个修订版添加用户名信息][4.]

[5. 阅读修订版，包括用户名][5.]

### 1.配置休眠版本 ###

首先，您需要将 Hibernate Envers 依赖项添加到您的项目中。当我使用 Maven 来管理我的依赖项时，我需要做的就是将依赖项添加到我的[pom][]文件中：

<dependency>
                <groupId>org.hibernate</groupId>
                <artifactId>hibernate-envers</artifactId>
                <version>5.6.14.Final</version>
            </dependency>

### 2. 审计表 ###

为了能够审核实体表，您只需要有一个具有主键的实体并使用注释@Audited。您可以在类的顶部使用注释@Audited（这将审核类的所有字段），也可以仅在要审核的字段中使用注释。

添加@Audited注释后，您将看到将为每个实体创建一个后缀为“\_AUD”的新表。此外，您还会发现已创建一个名为 REVINFO 的新表，其中包含所有修订信息。默认情况下，此表仅包含修订版的 id 和时间戳，尽管在第 4 节和第 5 节中，我将向您展示如何向此表添加更多数据，例如用户名。

下面是一个经过审核的 Java 类的示例：

@Entity
    @Audited
    public class City implements Serializable {
    
    private static final long serialVersionUID = 1L;
    
    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    private Long id;
    
    @Column
    private String name;
    
    @Column
    private String state;
    
    @Column
    private String country;
    
    @Column
    private String map;
    
    //getters and setters
    
    }

在这种情况下，我们将在数据库中自动拥有 2 个表，一个称为 City，另一个称为 City\_AUD，其中包括所有 city 字段以及修订标识符和修订类型（创建、更新、删除）。

### 3. 阅读修订版 ###

如果您已经在项目中配置了 Hibernate Envers，那么现在每次在数据库中添加或更新对象时，您都会看到另一行将添加到审核表中。现在我们想获得特定对象的不同修订。

Hibernate Envers包含一个名为Audit Reader的类，它使任何修订都更容易阅读。您只需要使用实体管理器对其进行初始化。然后，您可以使用 find 方法查找任何修订版本：

**AuditReader reader = AuditReaderFactory.get（entityManager）;  
reader.find（class， object id， revision id）;**

下面是创建和更新 City 对象然后检查修订[的示例][Link 2]：

final static String WRONG_STATE = “Wrong State”;
    final static String OXFORDSHIRE_STATE = “Oxfordshire”;
    
    @PersistenceContext
    private EntityManager entityManager;
    
    @Autowired
    private Transactor transactor;
    
    long cityId;
    
    @Test
    public void testSaveAndUpdateCity(){
    transactor.perform(() -> {
    addCity();
    });
    transactor.perform(() -> {
    updateCity(cityId);
    });
    
    transactor.perform(() -> {
    checkRevisions(cityId);
    });
    
    }
    
    private void addCity(){
    City city = new City(“Oxford”, “UK”);
    city.setState(WRONG_STATE);
    entityManager.persist(city);
    entityManager.flush();
    cityId = city.getId();
    }
    
    private void updateCity(long cityId) {
    City updateCity = entityManager.find(City.class, cityId);
    updateCity.setState(OXFORDSHIRE_STATE);
    entityManager.persist(updateCity);
    entityManager.flush();
    }
    
    private void checkRevisions(long cityId){
    AuditReader reader = AuditReaderFactory.get(entityManager);
    
    City city_rev1 = reader.find(City.class, cityId, 1);
    assertThat(city_rev1.getState(), is(WRONG_STATE));
    
    City city_rev2 = reader.find(City.class, cityId, 2);
    assertThat(city_rev2.getState(), is(OXFORDSHIRE_STATE));
    }

事务处理器是一个自定义类，用于在单个[事务][Link 3]中运行一段代码。正如您在checkRevisions函数中看到的，我们正在使用AuditReader来获取同一城市的不同修订。

AuditReader 具有更多方法，可让您更轻松地查找任何修订版，请查看[API][]以获取更多信息。

### 4. 为每个修订版添加用户名信息 ###

如果您遵循了前 3 个步骤，您应该能够审核和阅读任何修订，对于某些项目，这就是您所需要的。但是，在其他情况下，您将需要审核更多信息，例如进行交易的人的用户名。为此，您需要实现以下 2 个类：

*  修订实体
 *  修订侦听器

修订实体是包含您要在每个事务中审核的数据的类。此类必须包含修订号和修订时间戳，您可以手动添加这两个字段，也可以扩展已包含它们的 DefaultRevisionEntity 类。

下面是我的[修订][Link 4]实体的示例，它扩展了 DefaultRevisionEntity 并具有用户名的属性：

@Entity
    @RevisionEntity(UserRevisionListener.class)
    public class UserRevEntity extends DefaultRevisionEntity {
    
    private String username;
    
    public String getUsername() { return username; }
    public void setUsername(String username) { this.username = username; }
    }

请注意，该类包含 @RevisionEntity（UserRevisionListener.class） 注释。修订侦听器是您需要在其中指定如何将其他数据填充到修订中的类。此类需要实现 RevisionListener 接口，该接口只有一个称为 newRevin 的方法。

让我们[看一个例子：][Link 5]

public class UserRevisionListener implements RevisionListener {
    
    public final static String USERNAME = “Suay”;
    
    @Override
    public void newRevision(Object revisionEntity) {
    UserRevEntity exampleRevEntity = (UserRevEntity) revisionEntity;
    exampleRevEntity.setUsername(USERNAME);
    }
    }

在此示例中，我正在审核具有相同用户名（“SUAY”）的任何事务，但在实际环境中，您应该从用户服务或用于记录用户的任何其他方法获取用户名。

### 5. 阅读修订版，包括用户名 ###

为了获取用户信息，我使用方法“forRevisionsOfEntity”运行查询，该方法将返回三元组对象：实体，实体修订信息，最后是修订类型。只有第二个对象是我感兴趣的对象，因为它包含用户名信息。请[看以下示例：][Link 2]

@Test
    public void testUserRevisions() throws Exception{
    transactor.perform(() -> {
    addCity();
    });
    transactor.perform(() -> {
    checkUsers();
    });
    }
    
    private void checkUsers(){
    AuditReader reader = AuditReaderFactory.get(entityManager);
    AuditQuery query = reader.createQuery()
    .forRevisionsOfEntity(City.class, false, false);
    
    //This return a list of array triplets of changes concerning the specified revision.
    // The array triplet contains the entity, entity revision information and at last the revision type.
    Object[] obj = (Object[]) query.getSingleResult();
    
    //In this case we want the entity revision information object, which is the second object of the array.
    UserRevEntity userRevEntity = (UserRevEntity) obj[1];
    
    String user = userRevEntity.getUsername();
    assertThat(user, is(UserRevisionListener.USERNAME));
    
    }

### 运行示例项目 ###

这篇文章中使用的所有代码都可以在[github][Link 1]中找到。

如果你想运行这个项目，你只需运行[SampleDataJpaApplication][]。

[Hibernate ORM Envers]: http://hibernate.org/orm/envers/
[Link 1]: https://github.com/ignacioSuay/hibernate-envers-sample
[1.]: https://ignaciosuay.com/how-to-use-hibernate-envers-to-audit-data-including-username/#configure
[2.]: https://ignaciosuay.com/how-to-use-hibernate-envers-to-audit-data-including-username/#audit
[3.]: https://ignaciosuay.com/how-to-use-hibernate-envers-to-audit-data-including-username/#read
[4.]: https://ignaciosuay.com/how-to-use-hibernate-envers-to-audit-data-including-username/#username
[5.]: https://ignaciosuay.com/how-to-use-hibernate-envers-to-audit-data-including-username/#readUsername
[pom]: https://github.com/ignacioSuay/hibernate-envers-sample/blob/master/pom.xml
[Link 2]: https://github.com/ignacioSuay/hibernate-envers-sample/blob/master/src/test/java/sample/data/jpa/service/CityRepositoryIntegrationTests.java
[Link 3]: https://github.com/ignacioSuay/hibernate-envers-sample/blob/master/src/main/java/sample/data/jpa/config/Transactor.java
[API]: https://docs.jboss.org/hibernate/orm/3.5/api/org/hibernate/envers/AuditReader.html
[Link 4]: https://github.com/ignacioSuay/hibernate-envers-sample/blob/master/src/main/java/sample/data/jpa/revision/UserRevEntity.java
[Link 5]: https://github.com/ignacioSuay/hibernate-envers-sample/blob/master/src/main/java/sample/data/jpa/revision/UserRevisionListener.java
[SampleDataJpaApplication]: https://github.com/ignacioSuay/hibernate-envers-sample/blob/master/src/main/java/sample/data/jpa/SampleDataJpaApplication.java