无法使用 Spring Batch 框架连接到 Oracle 数据源答案

【问题标题】：Not able to connect to Oracle datasource using Spring Batch framework无法使用 Spring Batch 框架连接到 Oracle 数据源
【发布时间】：2019-01-18 11:31:09
【问题描述】：

我有一个用于学习 Spring Batch 的小项目。我想从 Oracle 数据库中读取数据并写入 XML 文件，但出现错误：

创建名为“step1”的 bean 时出错：在设置 bean 属性“jobRepository”时无法解析对 bean“jobRepository”的引用；嵌套异常是 org.springframework.beans.factory.BeanCreationException：在类路径资源 [Spring/batch/config/spring-batch-contextOriginal.xml] 中定义名称为“jobRepository”的 bean 创建错误：设置属性值时出错；嵌套异常是 org.springframework.beans.NotWritablePropertyException：bean 类 [org.springframework.batch.core.repository.support.MapJobRepositoryFactoryBean] 的属性“dataSource”无效：Bean 属性“dataSource”不可写或设置方法无效。 setter的参数类型和getter的返回类型是否匹配？

我想我把所有东西都放了，但我认为这个错误最重要的是：spring-batch-context.xml 和spring-datasource.xml。我错过了什么还是有什么问题？如果您需要更多详细信息，请告诉我。谢谢你。（我在不使用数据库的情况下尝试了该示例，并且效果很好。）

spring-batch-context.xml：

    <?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" 
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
       xsi:schemaLocation="http://www.springframework.org/schema/beans   
                           http://www.springframework.org/schema/beans/spring-beans-3.2.xsd">

 <import resource="../jobs/jobPerson.xml"/>
  <import resource="../config/spring-datasource.xml" /> 

   <!--  <context:annotation-config />
    <tx:annotation-driven transaction-manager="transactionManager"/>a PlatformTransactionManager is still required
     -->

    <!-- JobRepository and JobLauncher are configuration/setup classes -->
    <bean id="jobRepository" class="org.springframework.batch.core.repository.support.MapJobRepositoryFactoryBean" >
       <property name="dataSource" ref="dataSource" /> 
       <property name="transactionManager" ref="transactionManager" />
       <property name="databaseType" value="oracle" /> 
    </bean>

    <bean id="jobLauncher"   class="org.springframework.batch.core.launch.support.SimpleJobLauncher">
        <property name="jobRepository" ref="jobRepository" />
    </bean>


    <!-- Optional ItemProcessor to perform business logic/filtering on the input records -->
    <bean id="itemProcessor" class="springBatch.ExamResultItemProcessor" />

    <!-- Optional JobExecutionListener to perform business logic before and after the job -->
    <bean id="jobListener" class="springBatch.ExamResultJobListener" />

    <!-- Step will need a transaction manager -->
    <bean id="transactionManager" class="org.springframework.batch.support.transaction.ResourcelessTransactionManager" />

</beans>

spring-datasource.xml：

 <?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" 
       xmlns:jdbc="http://www.springframework.org/schema/jdbc" 
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
       xsi:schemaLocation="http://www.springframework.org/schema/beans    
                           http://www.springframework.org/schema/beans/spring-beans-3.2.xsd   
                           http://www.springframework.org/schema/jdbc    
                           http://www.springframework.org/schema/jdbc/spring-jdbc-3.2.xsd">

   <!-- Info to connect To Database -->
   <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver" />
      <property name="url" value="jdbc:oracle:thin:@*********:1552/******" />     
      <property name="username" value="*******" />
      <property name="password" value="*******" />
   </bean>

   <bean id="transactionManager"
        class="org.springframework.batch.support.transaction.ResourcelessTransactionManager" />

    <!-- create job-meta tables automatically -->
    <jdbc:initialize-database data-source="dataSource">
        <jdbc:script location="org/springframework/batch/core/schema-drop-oracle10g.sql" />
        <jdbc:script location="org/springframework/batch/core/schema-oracle10g.sql" />
    </jdbc:initialize-database>


</beans>

jobPerson.xml：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:batch="http://www.springframework.org/schema/batch" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:context="http://www.springframework.org/schema/context" 
    xmlns:jdbc="http://www.springframework.org/schema/jdbc">

<!--    <import resource="../config/spring-batch-contextOriginal.xml"/> 
 -->    
     <bean id="itemReader" class="org.springframework.batch.item.database.JdbcCursorItemReader"  scope="step">
        <property name="dataSource" ref="dataSource"/> 

         <property name="sql" value="SELECT internal_Id,individual_Id FROM Person" />

        <property name="rowMapper">
            <bean class="sb.dbToXml.PersonRowMapper"></bean>
        </property>

    </bean>


    <bean id="itemWriter" class="org.springframework.batch.item.xml.StaxEventItemWriter">
       <property name="resource" value="file:xml/persons.xml"/>
       <property name="marshaller"  ref="personMarshaller"/>
       <property name="rootTagName" value="persons"/>
    </bean>

    <bean id="personMarshaller" class="org.springframework.oxm.jaxb.Jaxb2Marshaller">
       <property name="classesToBeBound">
          <value>sb.dbToxml.Person </value>
       </property>
    </bean>



     <batch:job id="personJob">
        <batch:step id="step1" >
            <batch:tasklet transaction-manager="transactionManager">
                <batch:chunk reader="itemReader" writer="itemWriter"   commit-interval="10" />
            </batch:tasklet>
        </batch:step>

        <batch:listeners>
            <batch:listener ref="jobListener" />
        </batch:listeners> 
    </batch:job>


 </beans>

主类：

package sb.dbToxml;

import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobExecutionException;
import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class MainDbToXml
{

  public static void main(String[] args)
  {
    ApplicationContext context=new ClassPathXmlApplicationContext("Spring/batch/config/spring-batch-context.xml");

    JobLauncher jobLauncher= (JobLauncher) context.getBean("jobLauncher");

    Job job=(Job) context.getBean("personJob");

    try
    {
      JobExecution execution=jobLauncher.run(job, new JobParameters());
      System.out.println("Main/try :Job Person  Exit Status "+execution.getStatus());
    }
    catch (JobExecutionException e)
    {
      System.out.println("Main /catch :Job Person  failed");
      e.printStackTrace();
    }
  }

}

人物类：

package sb.dbToxml;

import javax.xml.bind.annotation.XmlAccessOrder;
import javax.xml.bind.annotation.XmlAccessorOrder;
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;

@XmlRootElement(name="Person")
//@XmlAccessorOrder(XmlAccessOrder.UNDEFINED)
public class Person
{
  Long internal_id;
  Long Individual_id;

  @XmlElement(name="int_id")
  public Long getInternal_id()
  {
    return internal_id;
  }
  public void setInternal_id(Long internal_id)
  {
    this.internal_id = internal_id;
  }
  @XmlElement(name="indv_id")
  public Long getIndividual_id()
  {
    return Individual_id;
  }
  public void setIndividual_id(Long individual_id)
  {
    Individual_id = individual_id;
  }


}

PersonRawMapper：

package sb.dbToxml;

import java.sql.ResultSet;
import java.sql.SQLException;

import org.springframework.jdbc.core.RowMapper;

public class PersonRowMapper implements RowMapper <Person>
{

  @Override
  public Person mapRow(ResultSet rs, int rowNum) throws SQLException
  {
    Person person=new Person();
    person.setIndividual_id(rs.getLong("individual_id"));
    person.setInternal_id(rs.getLong("internal_id"));
    return person;
  }

}

【问题讨论】：

MapJobRepositoryFactoryBean 是内存仓库。使用另一个
你知道我可以用什么代替那个吗？
查看how to create a minimal, complete, verifiable example 以获取有关缩短帖子的帮助。因为现在，似乎代码有点太多了。但也许我错了，所有的代码都是必要的。
异常表明MapJobRepositoryFactoryBean 没有dataSource 属性，查看它的documentation 确实没有这样的属性。您的意思是改为设置属性transactionManager 吗？
我想使用数据库从表中读取一些数据，所以我该怎么做，我在示例中看到我应该有一个数据源。我的意思是我可以使用而不是 MapJobRepositoryFactoryBean

标签： java spring spring-batch

【解决方案1】：

MapJobRepositoryFactoryBean 没有属性dataSource、transactionManager 和databaseType。您应该使用JobRepositoryFactoryBean 而不是MapJobRepositoryFactoryBean：

所以替换这个：

<!-- JobRepository and JobLauncher are configuration/setup classes -->
<bean id="jobRepository" class="org.springframework.batch.core.repository.support.MapJobRepositoryFactoryBean" >
   <property name="dataSource" ref="dataSource" /> 
   <property name="transactionManager" ref="transactionManager" />
   <property name="databaseType" value="oracle" /> 
</bean>

用这个：

<!-- JobRepository and JobLauncher are configuration/setup classes -->
<bean id="jobRepository" class="org.springframework.batch.core.repository.support.JobRepositoryFactoryBean" >
   <property name="dataSource" ref="dataSource" /> 
   <property name="transactionManager" ref="transactionManager" />
   <property name="databaseType" value="oracle" /> 
</bean>

它应该可以工作。

【讨论】：