Как получить имя пользователя из customRevisionEntity
Мы используем Hibernate-envers 3.6.3.Final, и я получаю таблицы, которые генерируются правильно с @Audited аннотациями. Я использую CustomRevisionEntity для хранения информации о пользователе, а CustomRevisionListenner также хранит информацию о пользователе. Но если я попытаюсь получить "имя пользователя", он вернет следующую ошибку.
org.hibernate.HibernateException: No Hibernate Session bound to thread, and configuration does not allow creation of non-transactional one here
at org.springframework.orm.hibernate3.SpringSessionContext.currentSession(SpringSessionContext.java:64) ~[spring-orm-3.2.6.RELEASE.jar:3.2.6.RELEASE]
Мой класс CustomRevisionEntity,
@Entity
@Table(name = "revision_info")
@RevisionEntity(CustomEnversListener.class)
public class CustomRevisionEntity implements Serializable {
private static final long serialVersionUID = 1L;
@Id
@GeneratedValue
@RevisionNumber
private int id;
@RevisionTimestamp
private long timestamp;
private String username;
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public long getTimestamp() {
return timestamp;
}
public void setTimestamp(long timestamp) {
this.timestamp = timestamp;
}
@Column(name = "username")
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
CustomRevisionListener.java
public class CustomEnversListener implements RevisionListener {
public void newRevision(Object revisionEntity) {
CustomRevisionEntity customRevisionEntity = (CustomRevisionEntity) revisionEntity;
Authentication authentication = SecurityContextHolder.getContext()
.getAuthentication();
customRevisionEntity.setUsername(authentication.getName());
}
}
Моя таблица выглядит следующим образом:
mysql> select * from revision_info;
+----+---------------+-----------------+
| id | timestamp | username |
+----+---------------+-----------------+
| 1 | 1431693146030 | [email protected] |
| 2 | 1431693150805 | [email protected] |
| 3 | 1431693164895 | [email protected] |
+----+---------------+-----------------+
3 rows in set (0.02 sec)
Я могу получить "rev", используя "TimeStamp" и "TimeStamp", используя "rev", используя следующий код,
AuditReader reader = AuditReaderFactory.get(session);
Date timestamp = reader.getRevisionDate(rev);
Number revision = reader.getRevisionNumberForDate(timestamp);
Но я не могу получить всю строку с настраиваемыми полями "имя пользователя" с помощью запроса на спящий режим.
Criteria criteria = sessionFactory.getCurrentSession()
.createCriteria(CustomRevisionEntity.class)
.add(Restrictions.eq("id", rev));
Вышеприведенный запрос возвращает указанную выше ошибку. Как это решить?
Как получить значения из таблицы revision_info?
Полная трассировка стека моей ошибки:
org.hibernate.HibernateException: No Hibernate Session bound to thread, and configuration does not allow creation of non-transactional one here
at org.springframework.orm.hibernate3.SpringSessionContext.currentSession(SpringSessionContext.java:64) ~[spring-orm-3.2.6.RELEASE.jar:3.2.6.RELEASE]
at org.hibernate.impl.SessionFactoryImpl.getCurrentSession(SessionFactoryImpl.java:687) ~[hibernate-core-3.6.3.Final.jar:3.6.3.Final]
at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-3.2.6.RELEASE.jar:3.2.6.RELEASE]
at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:701) ~[spring-aop-3.2.6.RELEASE.jar:3.2.6.RELEASE]
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:150) ~[spring-aop-3.2.6.RELEASE.jar:3.2.6.RELEASE]
at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:91) ~[spring-aop-3.2.6.RELEASE.jar:3.2.6.RELEASE]
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172) ~[spring-aop-3.2.6.RELEASE.jar:3.2.6.RELEASE]
at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:634) ~[spring-aop-3.2.6.RELEASE.jar:3.2.6.RELEASE]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.6.0_31]
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) ~[na:1.6.0_31]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.6.0_31]
at java.lang.reflect.Method.invoke(Method.java:622) ~[na:1.6.0_31]
at ognl.OgnlRuntime.invokeMethod(OgnlRuntime.java:870) ~[ognl-3.0.6.jar:na]
at ognl.OgnlRuntime.callAppropriateMethod(OgnlRuntime.java:1293) ~[ognl-3.0.6.jar:na]
at ognl.ObjectMethodAccessor.callMethod(ObjectMethodAccessor.java:68) ~[ognl-3.0.6.jar:na]
at com.opensymphony.xwork2.ognl.accessor.XWorkMethodAccessor.callMethodWithDebugInfo(XWorkMethodAccessor.java:117) [xwork-core-2.3.20.jar:2.3.20]
at com.opensymphony.xwork2.ognl.accessor.XWorkMethodAccessor.callMethod(XWorkMethodAccessor.java:108) [xwork-core-2.3.20.jar:2.3.20]
at ognl.OgnlRuntime.callMethod(OgnlRuntime.java:1369) ~[ognl-3.0.6.jar:na]
at ognl.ASTMethod.getValueBody(ASTMethod.java:90) ~[ognl-3.0.6.jar:na]
at ognl.SimpleNode.evaluateGetValueBody(SimpleNode.java:212) ~[ognl-3.0.6.jar:na]
at ognl.SimpleNode.getValue(SimpleNode.java:258) ~[ognl-3.0.6.jar:na]
at ognl.Ognl.getValue(Ognl.java:494) ~[ognl-3.0.6.jar:na]
at ognl.Ognl.getValue(Ognl.java:458) ~[ognl-3.0.6.jar:na]
at com.opensymphony.xwork2.ognl.OgnlUtil$2.execute(OgnlUtil.java:309) ~[xwork-core-2.3.20.jar:2.3.20]
at com.opensymphony.xwork2.ognl.OgnlUtil.compileAndExecute(OgnlUtil.java:340) ~[xwork-core-2.3.20.jar:2.3.20]
at com.opensymphony.xwork2.ognl.OgnlUtil.getValue(OgnlUtil.java:307) ~[xwork-core-2.3.20.jar:2.3.20]
at com.opensymphony.xwork2.DefaultActionInvocation.invokeAction(DefaultActionInvocation.java:423) ~[xwork-core-2.3.20.jar:2.3.20]
at com.opensymphony.xwork2.DefaultActionInvocation.invokeActionOnly(DefaultActionInvocation.java:287) ~[xwork-core-2.3.20.jar:2.3.20]
at com.opensymphony.xwork2.DefaultActionInvocation.invoke(DefaultActionInvocation.java:250) ~[xwork-core-2.3.20.jar:2.3.20]
at org.apache.struts2.interceptor.DeprecationInterceptor.intercept(DeprecationInterceptor.java:41) ~[struts2-core-2.3.20.jar:2.3.20]
Моя конфигурация spring выглядит следующим образом:
<bean id="transactionManager"
class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="xxxSessionFactory"/>
</bean>
<tx:advice id="customRevisionEntityAdvice" transaction-manager="transactionManager">
<tx:attributes>
<tx:method name="*" read-only="false" propagation="REQUIRED"/>
</tx:attributes>
</tx:advice>
<aop:config>
<aop:pointcut id="crePointcut"
expression="execution(* bla.bla.CustomRevisionEntity.*(..))"/>
<aop:advisor advice-ref="customRevisionEntityAdvice" pointcut-ref="crePointcut"/>
</aop:config>
my application-content.xml содержит следующее...
<bean id="auditEventListener" class="org.hibernate.envers.event.AuditEventListener" />
<bean id="xxxSessionFactory"
class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
<property name="annotatedClasses">
<list>
<value>bla.bla.domain.Myclass</value>
</list>
</property>
<property name="eventListeners">
<map>
<entry key="post-insert" value-ref="auditEventListener"/>
<entry key="post-update" value-ref="auditEventListener"/>
<entry key="post-delete" value-ref="auditEventListener"/>
<entry key="pre-collection-update" value-ref="auditEventListener"/>
<entry key="pre-collection-remove" value-ref="auditEventListener"/>
<entry key="post-collection-recreate" value-ref="auditEventListener"/>
</map>
</property>
Ответы
Ответ 1
Использование Envers
Вы можете запросить CustomRevisionEntity
с помощью AuditReader
AuditReader auditReader = AuditReaderFactory.get(entityManager);
//Here you find the revision number that you want
Number revisionNumber = getRevisionNumber(auditReader);
//then you use the auditReader :-)
CustomRevisionEntity cRevEntity = auditReader.findRevision(
CustomRevisionEntity.class, revisionNumber );
//Then you can just get your Username
String userName = cRevEntity.getUsername();
Вот подпись метода
/**
* A helper method; should be used only if a custom revision entity is used. See also {@link RevisionEntity}.
* @param revisionEntityClass Class of the revision entity. Should be annotated with {@link RevisionEntity}.
* @param revision Number of the revision for which to get the data.
* @return Entity containing data for the given revision.
* @throws IllegalArgumentException If revision is less or equal to 0 or if the class of the revision entity
* is invalid.
* @throws RevisionDoesNotExistException If the revision does not exist.
* @throws IllegalStateException If the associated entity manager is closed.
*/
<T> T findRevision(Class<T> revisionEntityClass, Number revision) throws IllegalArgumentException,
RevisionDoesNotExistException, IllegalStateException;
Из Hibernate-envers 3.6.3. Исходный источник, это реализовано в строке AuditReaderImpl.java 193:
@SuppressWarnings({"unchecked"})
public <T> T findRevision(Class<T> revisionEntityClass, Number revision) throws IllegalArgumentException,
RevisionDoesNotExistException, IllegalStateException {
checkNotNull(revision, "Entity revision");
checkPositive(revision, "Entity revision");
checkSession();
Set<Number> revisions = new HashSet<Number>(1);
revisions.add(revision);
Query query = verCfg.getRevisionInfoQueryCreator().getRevisionsQuery(session, revisions);
try {
T revisionData = (T) query.uniqueResult();
if (revisionData == null) {
throw new RevisionDoesNotExistException(revision);
}
return revisionData;
} catch (NonUniqueResultException e) {
throw new AuditException(e);
}
}
Обновление - отсутствует Spring Конфигурация
Если вы посмотрите на свою стеклянную структуру, вам не хватает конфигурации транзакции Spring.
Либо используйте декларативную конфигурацию, либо используйте аннотацию.
Декларативная конфигурация
Вам нужно объявить использование транзакции в конфигурации xml, это делается с помощью pointcut AOP. Глядя на это example, вы можете увидеть, что сначала он устанавливает TransactionManager
и DataSource
, а затем объявляет, что каждый метод x.y.service.FooService
потребуется транзакция
<!-- ensure that the above transactional advice runs for any execution
of an operation defined by the FooService interface -->
<aop:config>
<aop:pointcut id="fooServiceOperation" expression="execution(* x.y.service.FooService.*(..))"/>
<aop:advisor advice-ref="txAdvice" pointcut-ref="fooServiceOperation"/>
</aop:config>
Конфигурация AOP отсутствует. Для удобства вы можете настроить каждый класс из определенного пакета для использования транзакции.
<aop:config>
<aop:pointcut id="fooServiceMethods" expression="execution(* x.y.service.*.*(..))"/>
<aop:advisor advice-ref="txAdvice" pointcut-ref="fooServiceMethods"/>
</aop:config>
Посмотрите, что изменяется только expression="execution(* x.y.service.*.*(..))"
.
Использование @Transactional
Spring к счастью предоставляет более простой способ объявить использование метода @Transactional
, просто аннотируя класс, интерфейс или метод как @Transactional
// the service class that we want to make transactional
@Transactional
public class DefaultFooService implements FooService {
Foo getFoo(String fooName);
Foo getFoo(String fooName, String barName);
void insertFoo(Foo foo);
void updateFoo(Foo foo);
}
После этого нам нужно настроить Spring для сканирования нашего кода, ищущего @Transactional, для создания необходимых прокси-серверов beans при необходимости.
<!-- enable the configuration of transactional behavior based on annotations -->
<tx:annotation-driven transaction-manager="txManager"/><!-- a PlatformTransactionManager is still required -->
Вот полный пример для @Transactional и reference для Spring конфигурации транзакций.
Включение конфигурации в спящем режиме 3
Для Hibernate 3 требуется специальная настройка для работы с Envers, вам нужно добавить это на свой persistence.xml
. Пример
<property name="hibernate.ejb.event.post-insert" value="org.hibernate.ejb.event.EJB3PostInsertEventListener,org.hibernate.envers.event.AuditEventListener" />
<property name="hibernate.ejb.event.post-update" value="org.hibernate.ejb.event.EJB3PostUpdateEventListener,org.hibernate.envers.event.AuditEventListener" />
<property name="hibernate.ejb.event.post-delete" value="org.hibernate.ejb.event.EJB3PostDeleteEventListener,org.hibernate.envers.event.AuditEventListener" />
<property name="hibernate.ejb.event.pre-collection-update" value="org.hibernate.envers.event.AuditEventListener" />
<property name="hibernate.ejb.event.pre-collection-remove" value="org.hibernate.envers.event.AuditEventListener" />
<property name="hibernate.ejb.event.post-collection-recreate" value="org.hibernate.envers.event.AuditEventListener" />
Если у вас нет файла persistence.xml или hibernate.cfg.xml, и вы объявляете SessionFactory
, и он просто работает, вам нужно отредактировать конфигурацию Spring что-то вроде this
<bean id="sessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
....
<property name="eventListeners">
<map>
<entry key="post-insert" value-ref="auditListener"/>
<entry key="post-update" value-ref="auditListener"/>
<entry key="post-delete" value-ref="auditListener"/>
<entry key="pre-collection-update" value-ref="auditListener"/>
<entry key="pre-collection-remove" value-ref="auditListener"/>
<entry key="post-collection-recreate" value-ref="auditListener"/>
</map>
</property>
...
</bean>
<bean id="auditListener" class="org.hibernate.envers.event.AuditEventListener"/>
Ответ 2
Эта ошибка чаще всего возникает из-за наличия TransactionManager
и пытается выполнить метод запроса, который не отмечен как @Transactional или, возможно, слишком широкое определение <tx:advice ...
bean. Можете ли вы показать удаленные части вашего spring config?
TL; DR: попробуйте добавить @Transactional
к методу запроса CustomRevisionEntity
и посмотреть, поможет ли это. Если да, приступайте к работе с демаркацией транзакций.
Обновить. Для конфигурации spring необходимы транзакции для всех методов. Вы можете добавить
<tx:method name="read*" read-only="true"/>
чтобы соответствовать вашим методам чтения аудита (измените read*
на что-то разумное, и убедитесь, что "*"
не имеет общего доступа). Вы даже можете добавить атрибут propagation="SUPPORTS"
к этому тегу, чтобы разрешить использование существующей транзакции, если вы запрашиваете в таком контексте.
Кроме того, у вас есть TransactionInterceptor
/auto-proxy где-нибудь?
<bean id="txInterceptor" class="org.springframework.transaction.interceptor.TransactionInterceptor">
<property name="transactionManager" ref="transactionManager"></property>
<property name="transactionAttributeSource" ref="txAttributeSource"/>
</bean>
<bean class="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator">
<property name="beanNames">
<list>
<value>yourServiceName<value>
...
</list>
</property>
<property name="interceptorNames">
<list>
<idref local="txInterceptor"/>
</list>
</property>
</bean>
Приветствия,
Ответ 3
У вас отсутствуют определения pointcuts, как описано здесь.
Потоки помогают определить, где вы хотите, чтобы ваш совет применялся.