休眠信封:如何检查字段是否在两次修订之间发生了更改



我正在使用Hibernate环境来审计应用程序中的实体。我为每个实体都有单独的_audit表,然后在这些表中我有_mod布尔列来指示字段是否已更改。

但是,我不知道如何在查询中使用该列,甚至不知道如何从代码中获得这些数据?

例如,以下代码给出了被审计人员的名单。如何检查哪些数据已更改?

List person = getAuditReader().createQuery()
    .forEntitiesAtRevision(Person.class, 12)
    .getResultList();

您可以遍历给定实体的所有字段,并查看该字段是否已更改。

示例代码片段,用于循环浏览修订号为12的Person实体的所有字段,并查找更新字段的值。

  public void processFields() throws Exception {
    for (Field field : Person.class.getDeclaredFields()) {
      final Person changedEntity = fetchEntityForRevisionWhenPropertyChanged(Person.class, 12, field.getName());
      if (changedEntity != null) {
        // Updated field value for the field. This will list all fields which are changed in given revision.
        final Object fieldValue = getField(changedEntity, field.getName());
      }
    }
  }
  private  <T> Object getField(final T object, final String fieldName) throws Exception {
    return new PropertyDescriptor(fieldName, object.getClass()).getReadMethod().invoke(object);
  }
  private  <T> T fetchEntityForRevisionWhenPropertyChanged(final Class<T> entityClass, final int revisionNumber, final String propertyName) {
    final List<T> resultList = getAuditReader()
        .createQuery()
        .forEntitiesModifiedAtRevision(entityClass, revisionNumber)
        .add(AuditEntity.property(propertyName).hasChanged())
        .addOrder(AuditEntity.id().asc())
        .getResultList();
    if (CollectionUtils.isNotEmpty(resultList)) {
      return resultList.get(0);
    } else {
      return null;
    }
  }

在任何情况下,如果你想找到你的实体以前的修订进行比较,你可以使用以下方法:

  public T getPreviousVersion(final Class<T> entityClass, final Long entityId, final Long currentRevisionNumber) {
    final AuditReader reader = AuditReaderFactory.get(entityManager);
    final Number previousRevision = (Number) reader.createQuery()
        .forRevisionsOfEntity(entityClass, false, true)
        .addProjection(AuditEntity.revisionNumber().max())
        .add(AuditEntity.id().eq(entityId))
        .add(AuditEntity.revisionNumber().lt(currentRevisionNumber))
        .getSingleResult();
    return Optional.ofNullable(previousRevision)
        .map(previousRev -> reader.find(entityClass, entityId, previousRev))
        .orElse(null);
  }

您可以尝试使用Hibernate拦截器。这是一篇关于拦截器的好文章。使用拦截器,您可以创建一个回调,该回调将在实体更新/创建等时执行。它将是这样的smth:

public class EntityInterceptor extends EmptyInterceptor {
    @Override
    public boolean onFlushDirty(Object entity,
                                Serializable id,
                                Object[] currentState,
                                Object[] previousState,
                                String[] propertyNames,
                                Type[] types) {
        if ( entity instanceof YourEntity ) {
            //do update stuff
            return true;
        }
        return false;
    }
}

您可以将currentStatepreviousState

最新更新