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.setSkippableExceptionClasses(getExceptionMap(Exception.class));


    Step step = factory.getObject();


    step.execute(stepExecution);
    assertEquals(BatchStatus.FAILED, stepExecution.getStatus());
    assertEquals("oops", stepExecution.getFailureExceptions().get(0).getCause().getMessage());


    // listeners are called only once chunk is about to commit, so
    // listener failure does not affect other statistics

View Full Code Here

    } });
    factory.setSkippableExceptionClasses(getExceptionMap(Exception.class));


    Step step = factory.getObject();


    step.execute(stepExecution);
    assertEquals(BatchStatus.FAILED, stepExecution.getStatus());
    assertEquals("oops", stepExecution.getFailureExceptions().get(0).getCause().getMessage());
    assertEquals(1, stepExecution.getSkipCount());
    assertEquals(0, stepExecution.getReadSkipCount());
    assertEquals(1, stepExecution.getWriteSkipCount());

View Full Code Here


    factory.setSkipLimit(4);


    Step step = factory.getObject();


    step.execute(stepExecution);
    assertEquals(4, stepExecution.getSkipCount());
    assertEquals(3, stepExecution.getReadSkipCount());
    assertEquals(1, stepExecution.getWriteSkipCount());


    // skipped 2,3,4,5

View Full Code Here

    factory.setSkipLimit(4);
    factory.setCommitInterval(3); // includes all expected skips


    Step step = factory.getObject();


    step.execute(stepExecution);
    assertEquals(4, stepExecution.getSkipCount());
    assertEquals(2, stepExecution.getReadSkipCount());
    assertEquals(2, stepExecution.getWriteSkipCount());


    // skipped 2,3,4,5

View Full Code Here

    factory.setSkippableExceptionClasses(getExceptionMap(Exception.class));
    factory.setSkipLimit(1);


    Step step = factory.getObject();


    step.execute(stepExecution);


    assertEquals(1, stepExecution.getSkipCount());
    assertEquals("[a, c]", reader.getRead().toString());
    assertStepExecutionsAreEqual(stepExecution, repository.getLastStepExecution(jobExecution.getJobInstance(), step
        .getName()));

View Full Code Here

    factory.setSkipLimit(3);
    factory.setSkippableExceptionClasses(getExceptionMap(Exception.class));


    Step step = factory.getObject();


    step.execute(stepExecution);
    assertEquals(BatchStatus.FAILED, stepExecution.getStatus());
    assertEquals("bad skip count", 3, stepExecution.getSkipCount());
    assertEquals("bad read skip count", 2, stepExecution.getReadSkipCount());
    assertEquals("bad write skip count", 1, stepExecution.getWriteSkipCount());

View Full Code Here

    reader.setItems("1", "2", "3", "4");


    writer.setFailures("4");


    Step step = factory.getObject();
    step.execute(stepExecution);


    assertEquals(1, stepExecution.getSkipCount());
    assertEquals(2, stepExecution.getRollbackCount());


    // 1,2,3,4,3,4 - one scan until the item is

View Full Code Here

    }


    factory.setItemWriter(new TestItemListenerWriter());


    Step step = factory.getObject();
    step.execute(stepExecution);


    assertEquals(BatchStatus.COMPLETED, stepExecution.getStatus());
    for (int i = 1; i <= 6; i++) {
      assertTrue("didn't call listener " + i, listenerCalls.contains(i));
    }

View Full Code Here

    factory.setItemReader(reader);
    factory.setTaskExecutor(new ConcurrentTaskExecutor());


    Step step = factory.getObject();


    step.execute(stepExecution);


    assertTrue(opened);
    assertTrue(closed);
    assertEquals(BatchStatus.COMPLETED, stepExecution.getStatus());
  }

View Full Code Here

    factory.setItemReader(reader);
    factory.setStreams(new ItemStream[] { stream, reader });


    Step step = factory.getObject();


    step.execute(stepExecution);


    assertTrue(opened);
    assertTrue(closed);
    assertEquals(BatchStatus.COMPLETED, stepExecution.getStatus());
  }

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.