2017-02-15 58 views
1

我对Spring很新。我正在使用spring批处理执行一项工作。我配置了一切,它工作正常。 但我有一个问题。从XML配置我打电话给JobListener类来更新批量启动信息。弹簧批次从监听器类调用DAO类

从XML配置我能够能够调用JobListener并初始化datasoure和jobID。但是我需要从JobListener类调用称为JobDAO的类来插入批处理状态。 有没有可能在xml中配置,或者我需要为JobDAO类创建对象并调用它。

对不起,这种问题。 Kinldy帮助我。

<batch:job id="txn-det" > 
    <batch:step id="step1"> 
     // Item reader & Item writer 
    </batch:step> 
    <batch:listeners> 
     <batch:listener ref="jobListener" /> 
    </batch:listeners> 
</batch:job>   

<bean id="jobListener" class="com.JobListener" > 
    <property name="dataSource" ref="dataSource"/> 
    <property name="jobID" value="TXN01"/> 
</bean> 

JobListener.java

public class JobListener implements JobExecutionListener { 

    @Autowired 
    DataSource dataSource; 
    String jobID = null; 

    @Autowired 
    JobDAO jobDAO = null; 

    @Autowired 
    public void setDataSource(DataSource dataSource){ 
     this.dataSource = dataSource; 
    } 

    public void setjobID(String jobID) { 
     this.jobID = jobID; 
    } 

    @Override 
    public void beforeJob(JobExecution jobExecution) { 
     startTime = new Date(); 
     System.out.println("Job starts at :"+startTime); 
     // TODO Call DAO to insert Job status 
     jobDAO.logJobStatus(); // Null pointer is throwing here 

    } 

    @Override 
    public void afterJob(JobExecution jobExecution) { 
    } 
} 

回答

0

试试看这样。

在JobListener.java

@Autowired 
JobDAO jobDAO = null; 

@Override 
public void beforeJob(JobExecution jobExecution) { 
    startTime = new Date(); 
    System.out.println("Job starts at :"+startTime); 
    jobDAO.log() 

} 

从XML配置:

<bean id="jobListener" class="com.JobListener" > 
     <property name="dataSource" ref="dataSource"/> 
     <property name="jobID" value="TXN01"/> 
     <property name="jobDAO" ref="jobDAO" /> 
</bean> 

<bean id="jobDAO" class="com.JobDAO" />