Spring-batch实体管理器初始化后变为空

Question

我目前正在实施一个 Spring-batch，它可以读取和写入文件，但还需要对数据库执行 CRUD 操作。

我试图在我的 xml 配置中简单地定义一个实体管理器，并在我的 DAO class 中使用它。但是，就在初始化之后，EntityManager 变为空。

谁能帮我解决这个问题？（通过可用的解决方案或 link 将是完美的）。

我的batchContext.xml

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
    <property name="driverClassName" value="${batch.datasource.driverClassName}"/>
    <property name="url" value="${batch.datasource.url}"/>
    <property name="username" value="${batch.datasource.username}"/>
    <property name="password" value="${batch.datasource.password}"/>
    <property name="testOnBorrow" value="true"/>
    <property name="testOnReturn" value="true"/>
    <property name="testWhileIdle" value="true"/>
    <property name="timeBetweenEvictionRunsMillis" value="1800000"/>
    <property name="numTestsPerEvictionRun" value="3"/>
    <property name="minEvictableIdleTimeMillis" value="1800000"/>
</bean>

<bean id="entityManagerFactory" name="entTransactionMgr" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
    <!-- <property name="persistenceXmlLocation" value="classpath:/META-INF/spring/persistence.xml" /> -->
    <property name="persistenceUnitName" value="persistenceUnit"/>
    <property name="packagesToScan" value="${jpa.scan.packages}"/>
    <property name="dataSource" ref="dataSource"/>
    <property name="jpaVendorAdapter">
        <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"/>
    </property>
    <property name="loadTimeWeaver">
        <bean class="org.springframework.instrument.classloading.InstrumentationLoadTimeWeaver" />
    </property>

    <!-- Custom jpaDialect pour le deuxieme batch:job-repository-->
<property name="jpaDialect">
    <bean class="fr.mma.soecm.batchfacade.util.CustomHibernateJpaDialect" />
</property>
    <property name="jpaProperties">
        <props>
            <!-- multiple props here-->
        </props>
    </property>
</bean>

<bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
    <property name="entityManagerFactory" ref="entityManagerFactory"/>
</bean>

<!-- mode="aspectj" -->
<tx:annotation-driven  transaction-manager="transactionManager"/>

<batch:job-repository id="jobRepository" data-source="dataSource" transaction-manager="transactionManager"/>

<!-- Jobs held separatelly -->
<import resource="batchContext-job.xml"/>

我的 DAO

@Repository("batchJobDao")
@Transactional
public class BatchJobDaoImpl implements BatchJobDao{

@PersistenceContext(unitName="persistenceUnit")
@Autowired
private EntityManager entityManager;

//    @PersistenceContext(unitName="persistenceUnit", type=PersistenceContextType.EXTENDED)
//    public void setEntityManager(EntityManager entityManager) {
//        System.out.println("Setting Entity Manager :" + entityManager);
//        this. entityManager = entityManager;
//    }

@PostConstruct
public void init(){
    if (entityManager == null){
        System.out.println(" Entity Manager is null");
    } else {
        System.out.println(" Entity Manager is not null");
        getAllJobExecutions();
    }
}

private static final String RECHERCHER_JOB_EXECUTION = "Select bje from BatchJobExecution bje";

@SuppressWarnings("unchecked")
@Override
@Transactional("transactionManager")
public List<BatchJobExecution> getAllJobExecutions(){

//      EntityManagerFactory emf=Persistence.createEntityManagerFactory("entTransactionMgr");
//      EntityManager em=emf.createEntityManager();

    Query query = entityManager.createQuery(RECHERCHER_JOB_EXECUTION, BatchJobExecution.class);
    List<BatchJobExecution> executions = (List<BatchJobExecution>) query.getResultList();
    System.out.println("EXES : " + executions);
    return executions;
}
}

有些代码被注释掉了，因为我尝试了多种方法（更改持久性上下文类型、恢复实体管理器 "manually"、为实体管理器创建 persistence.xml 文件）但都没有成功。

当运行作业时我的输出是（没有所有额外的行..）：

Entity Manager is not null
EXES : [fr.mma.soecm.batchfacade.domain.BatchJobExecution@10e6c33,...]
[BatchService] - Synchronous job launch
[AbstractStep] - Encountered an error executing the step
Caused by: java.lang.NullPointerException

当我在我的 DAO 中调用 "createQuery" 时，EntityManager 在调试时抛出空指针为空。

感谢您的帮助。我会继续寻找我的结束..上帝速度！

Answer 1

如上面的评论所述，我的明显问题是由于我试图在步骤的构造函数中调用服务或 DAO。

在 "doRead()" 方法中移动服务调用后，我可以使用 EntityManager 执行所有 CRUD 操作。

如果有人对this/and如何让它工作有任何疑问，请告诉我，因为自从我上周开始搜索以来，我在互联网上没有找到任何解释。

Spring-batch实体管理器初始化后变为空

Spring-batch Entity Manager becomes null after init

entitymanager

spring-batch