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

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


    Step step = factory.getObject();


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

View Full Code Here

    writer.setFailures("2", "3");
    writer.setExceptionType(AssertionError.class);


    Step step = factory.getObject();


    step.execute(stepExecution);
    assertEquals(BatchStatus.FAILED, stepExecution.getStatus());
    assertEquals(0, stepExecution.getSkipCount());
    assertEquals(1, stepExecution.getRollbackCount());
  }

View Full Code Here

    writer.setFailures("2", "3");
    writer.setExceptionType(SkippableRuntimeException.class);


    Step step = factory.getObject();


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


  }

View Full Code Here


    factory.setNoRollbackExceptionClasses(getExceptionList(SkippableRuntimeException.class));


    Step step = factory.getObject();


    step.execute(stepExecution);
    assertEquals(BatchStatus.COMPLETED, stepExecution.getStatus());
    assertEquals(2, stepExecution.getSkipCount());
    // Two multi-item chunks rolled back. When the item was encountered on
    // its own it can proceed
    assertEquals(2, stepExecution.getRollbackCount());

View Full Code Here


    factory.setNoRollbackExceptionClasses(getExceptionList(SkippableException.class));


    Step step = factory.getObject();


    step.execute(stepExecution);
    assertEquals(BatchStatus.COMPLETED, stepExecution.getStatus());
    assertEquals(2, stepExecution.getSkipCount());
    // Two multi-item chunks rolled back. When the item was encountered on
    // its own it can proceed
    assertEquals(2, stepExecution.getRollbackCount());

View Full Code Here

    processor.setFailures("4");
    factory.setCommitInterval(30);


    Step step = factory.getObject();


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


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

View Full Code Here

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


    Step step = factory.getObject();


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


    assertEquals("[1, 3, 5]", processor.getCommitted().toString());
    assertEquals("[1, 3, 5]", writer.getWritten().toString());
    assertEquals("[1, 3, 5]", writer.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.getWritten().toString());
    assertEquals("[1, 3, 5]", writer.getCommitted().toString());
    // If non-transactional, we should only process each item once

View Full Code Here

    processor.setFilter(true);
    factory.setCommitInterval(30);


    Step step = factory.getObject();


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


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

View Full Code Here

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


    Step step = factory.getObject();


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


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

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.