Hibernate Envers L2 кэширование - PullRequest
Новая
       18

Hibernate Envers L2 кэширование

0 голосов
/ 31 мая 2018

Я не могу найти какое-либо прямое решение для этого, поэтому я скорее спрашиваю также о будущем справочнике:

Как мне кэшировать вызовы в Hibernate Envers AuditReader?

Я настроил Hazelcast как L2провайдер кэша для Hibernate в моем проекте, и теперь я вижу в журнале Postgresql в основном вызовы Envers, выполняемые в базе данных.

Это мой класс, который предоставляет некоторые (для меня) полезные сведения о ревизии для сущностей:

@Service
public class RevisionProvider {
    private final Logger log = LoggerFactory.getLogger(this.getClass());

    @PersistenceContext(name = Vedantas.PU_NAME, type = PersistenceContextType.TRANSACTION)
    private EntityManager entityManager;

    private AuditReader auditReader;

    @Transactional(readOnly = true)
    public OperationCtx getCreationRevisionFor(Class aClass, long id) {
        auditReader = AuditReaderFactory.get(entityManager);

        log.info(new LogModel("getting creation revision for entity class: {}; id: {}").toString(), aClass.getName(), id);

        final Object[] array = (Object[]) auditReader.createQuery()
                .forRevisionsOfEntity(aClass, false, false)
                .add(AuditEntity.revisionType().eq(RevisionType.ADD))
                .add(AuditEntity.id().eq(id))
                .setMaxResults(1)
                .getSingleResult();

        return ((OperationCtx) array[1]);
    }

    @Transactional(readOnly = true)
    public OperationCtx getLastRevisionFor(Class aClass, long id) {

        log.info(new LogModel("getting last revision for entity class: {}; id: {}").toString(), aClass.getName(), id);

        auditReader = AuditReaderFactory.get(entityManager);
        final Object[] array = (Object[]) auditReader.createQuery()
                .forRevisionsOfEntity(aClass, false, false)
                .add(AuditEntity.id().eq(id))
                .add(AuditEntity.revisionNumber().maximize()
                        .computeAggregationInInstanceContext()
                )
                .addOrder(AuditEntity.revisionNumber().desc())
                .setMaxResults(1)
                .getSingleResult();

        OperationCtx lastchg = (OperationCtx) array[1];
        OperationCtx creation = getCreationRevisionFor(aClass, id);

        if (creation.getId() == lastchg.getId())
            return new OperationCtx();

        return lastchg;
    }

    @Transactional(readOnly = true)
    public List getHistoryFor(Class aClass, String pk, String val) {

        log.info(new LogModel("getting history for entity class: {}; on primaryKey: {}, with value: {}").toString(), aClass.getName(), pk, val);

        auditReader = AuditReaderFactory.get(entityManager);
        List res = auditReader.createQuery()
                .forRevisionsOfEntity(aClass, false, false)
                .add(AuditEntity.property(pk).eq(val))
                .getResultList();

        return res;
    }

    @Transactional(readOnly = true)
    public void setManipulationCtx(FindDTO dto, long id) {
        OperationCtx cctx = getCreationRevisionFor(DocVersion.class, id);
        OperationCtx lctx = getLastRevisionFor(Metadata.class, dto.metadata.getId());


        dto.createCtx = cctx;

        if (Strings.isNullOrEmpty(lctx.getUserId()))
            lctx = cctx;

        dto.lastChangeCtx = lctx;
    }
}

В основном я вызываю setManipulationCtx, чтобы какой-то объект DTO получил создание и последнюю редакцию изменений.Ревизия создания не изменится во времени.Кэшированная ревизия последнего изменения может быть кеширована и удалена при изменении объекта.

Так что я думаю, что мне нужен какой-то способ, чтобы вручную поместить объект в кеш в первый раз, а затем запросить кеш в первую очередь при последующих вызовах..

Как мне это сделать?

Спящий режим: 5.2.9.Final;

Обработка: 5.2.12.Final;

Hazelcast: 3.10.1;

Спасибо за советы!

1 Ответ

0 голосов
/ 31 мая 2018

К сожалению, Envers на самом деле не предоставляет способ взаимодействия и использования 2LC;однако я мог видеть, что это полезная функция для добавления.Я добавил ЧЧХ-12652 в качестве продолжения.

...