春季批处理作者不会出现任何错误

奥马尔·B ::

我尝试了一个springbatch示例,我使用了读取器来读取数据库,并使用写入器来写入数据库。当我运行主类时,它从数据库中打印了元素(这意味着可以从数据库中正确读取),但是停止了那里的数据库写操作,并且没有显示任何错误。我很困惑,将不胜感激。我把控制台日志放到那里可以帮到您。谢谢 。

春天的背景:

<?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="datasource.xml"/>
 <import resource="/job1.xml"/>


 <bean id="jobRepository" class="org.springframework.batch.core.repository.support.JobRepositoryFactoryBean">
   <property name="dataSource" ref="dataSource1"></property>
   <property name="transactionManager" ref="transactionManager"></property>
   <property name="databaseType" value="oracle"></property>
 </bean >



    <bean  id="jobLauncher" class="org.springframework.batch.core.launch.support.SimpleJobLauncher">
       <property name="jobRepository" ref="jobRepository"> </property>
     </bean>
     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager" >
   <property name="dataSource" ref="dataSource1"></property>
 </bean>
     </beans>

job1.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">


<bean id="personReader" class="org.springframework.batch.item.database.JdbcCursorItemReader" scope="step">
    <property name="dataSource" ref="dataSource1"/>
    <property name="sql" value="SELECT internal_id,individual_id from Person where internal_id &lt; 350"/>
    <property name="rowMapper">
       <bean  class="main.PersonMapper" />
    </property>
</bean>

<bean id="marshallerPerson" class="org.springframework.oxm.jaxb.Jaxb2Marshaller">
 <property name="classesToBeBound">
   <value>main.Person1</value>
 </property>
</bean>

 <bean id="personWriter" class="org.springframework.batch.item.database.JdbcBatchItemWriter" >
   <property name="dataSource" ref="dataSource1"/>
   <property name="sql">
     <value>
        <![CDATA[
            insert into  BDE1 (ID,Numero) values (:internal_id,:individual_id)
       ]]>
     </value>
   </property>
   <!-- ce qui suist map the  : internal_id et  individual_id with the object in the 
   reader which is Person  here. so Person should have  this values in SQL property -->
   <property name="itemSqlParameterSourceProvider" >
       <bean class="org.springframework.batch.item.database.BeanPropertyItemSqlParameterSourceProvider" />


   </property>


 </bean>

<batch:job id="personJob">
      <batch:step id="stepAAA">
          <batch:tasklet>
        <batch:chunk reader="personReader" writer="personWriter" commit-interval="100">

             </batch:chunk>
          </batch:tasklet>
      </batch:step>
</batch:job>
</beans>

datasource.xml:

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">
        <bean id="dataSource1"  class="org.springframework.jdbc.datasource.DriverManagerDataSource">
           <property name="driverClassName" value="oracle.jdbc.OracleDriver"></property>
           <property name="url" value="jdbc:oracle:thin:*********"></property>
           <property name="password" value="I6"></property>
           <property name="username" value="I6"></property>
         </bean>  
   </beans>

personMapper.java:

package main;

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

import org.springframework.jdbc.core.RowMapper;



public class PersonMapper implements RowMapper<Person1>
{

  public Person1 mapRow(ResultSet rs, int arg1) throws SQLException
  {
    Person1 person=new Person1();
    person.setInternal_id(rs.getLong("internal_id"));
    person.setIndividual_id(rs.getLong("individual_id"));
    System.out.println("int_id :"+person.getInternal_id()+"   indiv_id :"+person.getIndividual_id());


    return person;
  }

}

person1.java:

package main;

public class Person1
{
  Long internal_id;
  Long individual_id;

  public Long getInternal_id()
  {
    return internal_id;
  }
  public void setInternal_id(Long internal_id)
  {
    this.internal_id = internal_id;
  }

  public Long getIndividual_id()
  {
    return individual_id;
  }
  public void setIndividual_id(Long individual_id)
  {
    this.individual_id = individual_id;
  }

}

主类:

package main;

import java.util.Date;

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.JobParametersBuilder;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Main
{
  public static void main (String [] args ) 
  {
  ApplicationContext context=new ClassPathXmlApplicationContext("config/spring-context.xml");
  JobLauncher jobLauncher=(JobLauncher) context.getBean("jobLauncher");
  Job job=(Job) context.getBean("personJob");
  try
  {
   JobParameters param=new JobParametersBuilder().addLong("max", (long) 269).toJobParameters();
    //JobParameters param=new JobParametersBuilder().addLong("now", System.currentTimeMillis()).toJobParameters();

   JobExecution jobExecution=jobLauncher.run(job, param);
   System.out.println("job done..."+jobExecution.getStatus());
  }
  catch (JobExecutionException e) {

  }
 }
}

控制台日志:

Oct 19, 2018 2:05:23 PM org.springframework.context.support.ClassPathXmlApplicationContext prepareRefresh
INFO: Refreshing org.springframework.context.support.ClassPathXmlApplicationContext@4ccabbaa: startup date [Fri Oct 19 14:05:23 EDT 2018]; root of context hierarchy
Oct 19, 2018 2:05:23 PM org.springframework.beans.factory.xml.XmlBeanDefinitionReader loadBeanDefinitions
INFO: Loading XML bean definitions from class path resource [config/spring-context.xml]
Oct 19, 2018 2:05:23 PM org.springframework.beans.factory.xml.XmlBeanDefinitionReader loadBeanDefinitions
INFO: Loading XML bean definitions from class path resource [config/datasource.xml]
Oct 19, 2018 2:05:23 PM org.springframework.beans.factory.xml.XmlBeanDefinitionReader loadBeanDefinitions
INFO: Loading XML bean definitions from class path resource [config/job1.xml]
Oct 19, 2018 2:05:23 PM org.springframework.beans.factory.support.DefaultListableBeanFactory registerBeanDefinition
INFO: Overriding bean definition for bean 'personReader' with a different definition: replacing [Generic bean: class [org.springframework.batch.item.database.JdbcCursorItemReader]; scope=step; abstract=false; lazyInit=false; autowireMode=0; dependencyCheck=0; autowireCandidate=false; primary=false; factoryBeanName=null; factoryMethodName=null; initMethodName=null; destroyMethodName=null; defined in class path resource [config/job1.xml]] with [Root bean: class [org.springframework.aop.scope.ScopedProxyFactoryBean]; scope=; abstract=false; lazyInit=false; autowireMode=0; dependencyCheck=0; autowireCandidate=true; primary=false; factoryBeanName=null; factoryMethodName=null; initMethodName=null; destroyMethodName=null; defined in BeanDefinition defined in class path resource [config/job1.xml]]
Oct 19, 2018 2:05:23 PM org.springframework.jdbc.datasource.DriverManagerDataSource setDriverClassName
INFO: Loaded JDBC driver: oracle.jdbc.OracleDriver
Oct 19, 2018 2:05:23 PM org.springframework.jdbc.datasource.DriverManagerDataSource setDriverClassName
INFO: Loaded JDBC driver: oracle.jdbc.OracleDriver
Oct 19, 2018 2:05:23 PM org.springframework.oxm.jaxb.Jaxb2Marshaller createJaxbContextFromClasses
INFO: Creating JAXBContext with classes to be bound [class main.Person1]
Oct 19, 2018 2:05:24 PM org.springframework.batch.core.launch.support.SimpleJobLauncher afterPropertiesSet
INFO: No TaskExecutor has been set, defaulting to synchronous executor.
Oct 19, 2018 2:05:25 PM org.springframework.batch.core.launch.support.SimpleJobLauncher run
INFO: Job: [FlowJob: [name=personJob]] launched with the following parameters: [{max=269}]
Oct 19, 2018 2:05:27 PM org.springframework.batch.core.job.SimpleStepHandler handleStep
INFO: Executing step: [stepAAA]
int_id :1   indiv_id :778141667541
.
.
.
int_id :122   indiv_id :547249915381
Mahmoud Ben Hassine:

ResoucelessTransactionManager在配置中使用了

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

该事务管理器不与任何资源交互(因此没有名称),可将其视为“ NoOp”事务管理器(更多详细信息,请参见此处的文档)。

因此,该事务管理器不提交任何事务,因此,由于没有错误,因此将(无提示)将项目写入您的数据库。您可以使用a org.springframework.jdbc.datasource.DataSourceTransactionManager作为步骤,并且在没有错误发生时,您的项目将被写入数据库。

希望这可以帮助。

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

数组越界而不会出现任何错误

Stackmob不会执行获取请求,不会出现任何错误

vuejs vue-cli如何使用console.log而不会出现任何错误

为什么Android会强制停止我的应用程序而不会出现任何错误?

如何运行此代码段而不会出现任何错误?

当 Mediawiki 页面包含预先格式化的文本时,Mpdf 不会打印,不会出现任何错误

带有+分隔参数的System.out.println无法打印完整的输出,也不会出现任何错误

如何在 PowerShell 中以干净的方式将 Markdown 文件转换为 HTML 而不会出现任何错误?

如何让 R 循环中的失败步骤输出 n/a 或 null 空白,以便 data.frame() 函数不会出现任何行号问题

春季批处理计划期间累积的错误

如果标签错误,ChartJS不会呈现任何图例

如果任何块失败,如何中止春季批处理作业

春季批处理框架

春季批处理StoredProcedureItemReader

春季批处理:如果未写入任何项目,则停止批处理作业

运行时出现批处理错误

使用gedit使用'sudo -H gedit'编辑系统文件时,是否会出现任何问题?

角度6中出现任何错误时如何显示错误分量?

如何处理网络错误,使它们不会出现在chrome开发者控制台中?

如何使用 JavaScript 处理复杂的 100 位 (+/-) 乘 100 位 (+/-) 乘法而不会出现溢出错误?

使用消息后如果出现任何错误,如何在JMS消息队列中保存消息?

数据库插入无法正常工作且未出现任何错误

如果出现任何错误,如何自动重新打开/重新启动WPF应用程序?

MySQL Java驱动程序:未插入行,但未出现任何错误

如何使bash函数在出现任何错误时返回1

解析JSON时,避免Go程序在出现任何错误时停止运行

Python 程序没有给出错误或警告,但也没有出现任何窗口

如果出现任何错误,是否可以在循环中运行try语句?

如果出现任何错误后可见 false,Excel.exe 进程会继续运行