Examples of org.springframework.batch.core.Step.execute()

Class org.springframework.batch.core.Step

Examples of org.springframework.batch.core.Step.execute()

org.springframework.batch.core.Step.execute()
Process the step and assign progress and status meta information to the {@link StepExecution} provided. The{@link Step} is responsible for setting the meta information and also saving it if required by theimplementation.
It is not safe to re-use an instance of {@link Step} to process multiple concurrent executions. @param stepExecution an entity representing the step to be executed @throws JobInterruptedException if the step is interrupted externally

    factory.setCommitInterval(30);
    factory.setProcessorTransactional(false);


    Step step = factory.getObject();


    step.execute(stepExecution);
    assertEquals(BatchStatus.COMPLETED, stepExecution.getStatus());


    assertEquals("[1, 2, 3, 5]", writer.getCommitted().toString());
    assertEquals("[1, 2, 3, 4, 1, 2, 3, 4, 5]", writer.getWritten().toString());
    assertEquals("[1, 2, 3, 4, 5]", processor.getProcessed().toString());

View Full Code Here

    factory.setSkipLimit(10);
    factory.setIsReaderTransactionalQueue(true);


    Step step = factory.getObject();


    step.execute(stepExecution);
    assertEquals(BatchStatus.COMPLETED, stepExecution.getStatus());


    assertEquals("[]", writer.getCommitted().toString());
    assertEquals("[1, 2, 3, 4]", writer.getWritten().toString());
    assertEquals("[1, 2, 3, 4, 5, 1, 2, 3, 4, 5]", processor.getProcessed().toString());

View Full Code Here

    factory.setSkipLimit(10);
    factory.setTaskExecutor(new SimpleAsyncTaskExecutor());


    Step step = factory.getObject();


    step.execute(stepExecution);
    assertEquals(BatchStatus.COMPLETED, stepExecution.getStatus());


    assertEquals("[]", writer.getCommitted().toString());
    assertEquals("[]", processor.getCommitted().toString());
    assertEquals(5, stepExecution.getSkipCount());

View Full Code Here

    writer.setFailures("2", "4");
    factory.setCommitInterval(30);


    Step step = factory.getObject();


    step.execute(stepExecution);
    assertEquals(BatchStatus.COMPLETED, stepExecution.getStatus());


    assertEquals("[1, 3, 5]", writer.getCommitted().toString());
    assertEquals("[1, 2, 1, 2, 3, 4, 5]", writer.getWritten().toString());
    assertEquals("[1, 3, 5]", processor.getCommitted().toString());

View Full Code Here

    factory.setCommitInterval(30);
    factory.setProcessorTransactional(false);


    Step step = factory.getObject();


    step.execute(stepExecution);
    assertEquals(BatchStatus.COMPLETED, stepExecution.getStatus());


    assertEquals("[1, 3, 5]", writer.getCommitted().toString());
    assertEquals("[1, 2, 1, 2, 3, 4, 5]", writer.getWritten().toString());
    assertEquals("[1, 2, 3, 4, 5]", processor.getProcessed().toString());

View Full Code Here


  @Test
  public void testBeforeChunkListenerException() throws Exception{
    factory.setListeners(new StepListener []{new ExceptionThrowingChunkListener(1)});
    Step step = factory.getObject();
    step.execute(stepExecution);
    assertEquals(FAILED, stepExecution.getStatus());
    assertEquals(FAILED.toString(), stepExecution.getExitStatus().getExitCode());
    assertTrue(stepExecution.getCommitCount() == 0);//Make sure exception was thrown in after, not before
    Throwable e = stepExecution.getFailureExceptions().get(0);
    assertThat(e, instanceOf(FatalStepExecutionException.class));

View Full Code Here


  @Test
  public void testAfterChunkListenerException() throws Exception{
    factory.setListeners(new StepListener []{new ExceptionThrowingChunkListener(2)});
    Step step = factory.getObject();
    step.execute(stepExecution);
    assertEquals(FAILED, stepExecution.getStatus());
    assertEquals(FAILED.toString(), stepExecution.getExitStatus().getExitCode());
    assertTrue(stepExecution.getCommitCount() > 0);//Make sure exception was thrown in after, not before
    Throwable e = stepExecution.getFailureExceptions().get(0);
    assertThat(e, instanceOf(FatalStepExecutionException.class));

View Full Code Here

    reader.setFailures("2", "3");
    reader.setExceptionType(SkippableException.class);


    Step step = factory.getObject();


    step.execute(stepExecution);
    assertEquals(BatchStatus.COMPLETED, stepExecution.getStatus());
    assertEquals(2, stepExecution.getSkipCount());
    assertEquals(0, stepExecution.getRollbackCount());
  }

View Full Code Here


        Step step = factory.getObject();


        stepExecution = jobExecution.createStepExecution(factory.getName());
        repository.add(stepExecution);
        step.execute(stepExecution);
        assertEquals(BatchStatus.COMPLETED, stepExecution.getStatus());


        assertEquals("[]", writer.getCommitted().toString());
        assertEquals("[]", processor.getCommitted().toString());
        List<String> processed = new ArrayList<String>(processor.getProcessed());

View Full Code Here

0 1 2 3 4 5 6 7

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.