Spring JPA/Hibernate EmptyInterceptor 不注入 Entitymanager/Spring bean

Posted 2023-02-24

【中文标题】Spring JPA/Hibernate EmptyInterceptor 不注入 Entitymanager/Spring bean

【英文标题】：Spring JPA/Hibernate EmptyInterceptor not injecting Entitymanager/Spring beans

【发布时间】：2014-10-06 02:47:03

【问题描述】：

专家/大师/朋友

我们正在使用 Spring 3.2、JPA 2、Hibernate 4.2 组合，并在尝试将任何带有 spring 注释的 bean 注入 EmtyInterceptor 时遇到这个奇怪的空指针问题，如下所示。我们尝试过注释这个 bean 以及一个 spring bean，但没有成功。

非常感谢您在这里解决这个难题的任何帮助。

import javax.inject.Inject;
import javax.inject.Named;
import org.hibernate.EmptyInterceptor;
import org.hibernate.type.Type;
import org.springframework.transaction.annotation.Transactional;
...

@Named
@Transactional
public class AuditEmptyInterceptor extends EmptyInterceptor 

    /**
     * 
     */
    private static final long serialVersionUID = 1L;

    // Didnt inject - Null
    @PersistenceContext
    private EntityManager entityManager;

    // Didnt inject - Null
    //@PersistenceUnit
    //private EntityManagerFactory entityManagerFactory;

    // Didnt inject - Null
    //@Inject
    //private AuditHelper auditHelper;

    @Override
    public boolean onSave(Object entity, Serializable id, Object[] currentState,
            String[] propertyNames, Type[] types) 

        System.out.println("**********inside OnSave() in Audit Empty Interceptor******************");
        if(entity instanceof xxAuditInterface || entity instanceof xxxCompBranchInterface)
            for (int i = 0; i < propertyNames.length; i++) 
         ...
         ...
         // Null entityManager - NPE here
        javax.persistence.Query query = entityManager.createQuery("Select c From CompanyDO c Where c.companyName =:companyName");
        query.setParameter("companyName", xxx);
        CompanyMasterDO companyMasterDO = (CompanyMasterDO) query.getSingleResult();
         ...
         ...
          
         
        

 

在应用程序的其他任何地方，注入都像魅力一样工作，没有任何问题。 这是我们的 applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans default-lazy-init="true" 
xmlns="http://www.springframework.org/schema/beans" 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
xmlns:p="http://www.springframework.org/schema/p"
xmlns:aop="http://www.springframework.org/schema/aop" 
xmlns:context="http://www.springframework.org/schema/context"
xmlns:jee="http://www.springframework.org/schema/jee" 
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:util="http://www.springframework.org/schema/util"
xmlns:sec="http://www.springframework.org/schema/security"
xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd
        http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.2.xsd
        http://www.springframework.org/schema/security http://www.springframework.org/schema/security/spring-security-3.1.xsd
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd
        http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd
        http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.2.xsd
        http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd">


<context:annotation-config></context:annotation-config> 

<context:component-scan base-package="com" />

<context:property-placeholder location="classpath*:hibernate.properties" />
<tx:annotation-driven />

<bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
    <property name="dataSource" ref="dataSource" />
    <property name="packagesToScan" value="com"/>
 </bean>

<bean id="dataSource"
    class="org.springframework.jdbc.datasource.DriverManagerDataSource"
    p:driverClassName="com.mysql.jdbc.Driver" p:url="jdbc:mysql://localhost/rcent_rel_2"
    p:username="root" p:password="root" />

<bean id="entityManagerFactory"
    class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"
    p:dataSource-ref="dataSource" p:jpaVendorAdapter-ref="jpaAdapter">
    <property name="loadTimeWeaver">
        <bean
            class="org.springframework.instrument.classloading.InstrumentationLoadTimeWeaver" />
    </property>
    <property name="persistenceXmlLocation" value="classpath*:META-INF/spring-persistence.xml" />
</bean>

<bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager"
    p:entityManagerFactory-ref="entityManagerFactory" />

<bean id="jpaAdapter"
    class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"
    p:database="MYSQL" 
    p:showSql="false" 
    p:databasePlatform="org.hibernate.dialect.MySQL5Dialect"/>

<\beans>

下面是我们的 spring-persistence.xml。请注意，我在这里添加了 Emptyinceptor 属性。

<?xml version="1.0" encoding="UTF-8"?>

<persistence xmlns="http://java.sun.com/xml/ns/persistence" 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/persistence 
http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd" version="2.0">
<persistence-unit name="xxx" transaction-type="RESOURCE_LOCAL">
    <class>com.xxx</class>
         ...
         ...
    <properties>
           <property name="hibernate.ejb.interceptor"
                       value="com.company.demo.audit.AuditEmptyInterceptor" />           
    </properties>
    </persistence-unit>
</persistence>

让我知道您对此的宝贵想法/提示。再次感谢您花时间阅读这篇文章。

我还阅读了Injecting JPA's Entity Manager in Hibernate's EmptyInterceptor 的帖子。但看起来他们正在手动尝试找到要解析的名称的 bean，我觉得可能还有其他方法。

【问题讨论】：

你在哪里使用AuditEmptyInterceptor 类？您可以发布您（可能）注入该拦截器的源代码吗？

AuditEmptyInterceptor 是一个 EmptyInterceptor，用于从 Hibernate 获取集中回调以进行任何保存或更新。请参阅this 和this 了解。上面的 sn-p 中提到了源代码，这也直接从 Hibernate 获得了回调。

这是来自 Jboss [Hibernate] (docs.jboss.org/hibernate/orm/3.3/reference/en-US/html/…) 的文档。 EmptyInterceptor 实现了拦截器。

对于 Spring 数据库类配置，请参见我的建议：***.com/questions/21801605/…

【参考方案1】：

AuditEmptyInterceptor 不是 Spring 管理的 bean，它是由 Hibernate 实例化的，所以你不能向它注入依赖。

您可以改为使用静态委托：

public class StaticDelegateInterceptor extends EmptyInterceptor 

    private static Interceptor interceptor; 

    public static void setInterceptor(Interceptor interceptor) 
        StaticDelegate.interceptor = interceptor;
    

    public boolean onSave(Object entity, Serializable id, Object[] state, String[] propertyNames, Type[] types) 
      return StaticDelegate.interceptor.onSave(entity, id, state, propertyNames, types);
    
    ...

在persistence.xml上注册StaticDelegateInterceptor

<persistence>
    <persistence-unit name="xxx" transaction-type="RESOURCE_LOCAL">
       <class>com.xxx</class>
       ...
       ...
       <properties>
          <property name="hibernate.ejb.interceptor"
                   value="com.company.demo.audit.StaticDelegateInterceptor" />           
       </properties>
   </persistence-unit>
</persistence>

修改您当前的 AuditEmptyInterceptor，使其向 StaticDelegateInterceptor 注册自己：

@Named
@Transactional
public class AuditEmptyInterceptor extends EmptyInterceptor   

     @PostConstruct
     public void init() 
          StaticDelagateInterceptor.setInterceptor(this);
     
     ...

最后，通过设置depends-on 属性确保您的entityManagerFactory bean 依赖于您的auditEmptyInterceptor：

<bean id="entityManagerFactory"
class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"
p:dataSource-ref="dataSource" p:jpaVendorAdapter-ref="jpaAdapter"
depends-on="auditEmptyInterceptor" >
...
</bean>

【讨论】：

哇.. 谢谢里卡多.. 成功了.. 非常感谢您的快速帮助.. 但它打开了另一个奇怪的例外..

很高兴我能帮上忙。如果您现在看到的奇怪异常与 Spring 有关，请在评论中告诉我，以便我可以尝试更正答案，如果可能的话。

再次感谢里卡多。以下是我得到的异常 .. org.hibernate.AssertionFailure: null id in com.rcent.domain.worklist.WorklistStatusDO 条目（发生异常后不刷新会话）在 org.hibernate.event.internal .DefaultFlushEntityEventListener.checkId(DefaultFlushEntityEventListener.java:79) 在 org.hibernate.event.internal.DefaultFlushEntityEventListener.getValues(DefaultFlushEntityEventListener.java:194) 在

我之前在尝试使用 PreInsertEventListener 设置审计信息时也遇到了这个错误。因此我探索了这个 EmptyInterceptor。但看起来我又遇到了这个 HIbernateAssertionfailure。我得到的异常类似于this post

可以在没有定义 entityManagerFactory bean 的情况下完成吗？我没有在我的应用程序中明确定义它。提前谢谢你。