Examples of org.springframework.batch.core.step.AbstractStep.execute()

Package org.springframework.batch.core.step

Class org.springframework.batch.core.step.AbstractStep

Examples of org.springframework.batch.core.step.AbstractStep.execute()

org.springframework.batch.core.step.AbstractStep.execute()
Template method for step execution logic - calls abstract methods for resource initialization ( {@link #open(ExecutionContext)}), execution logic ( {@link #doExecute(StepExecution)}) and resource closing ( {@link #close(ExecutionContext)}).

    AbstractStep step = (AbstractStep) factory.getObject();
    step.setName("mytest");
    StepExecution stepExecution = new StepExecution(step.getName(),
        jobExecution);
    repository.add(stepExecution);
    step.execute(stepExecution);


    assertEquals(2, recovered.size());
    assertEquals(2, stepExecution.getSkipCount());
    assertEquals(2, stepExecution.getWriteSkipCount());

View Full Code Here

    AbstractStep step = (AbstractStep) factory.getObject();
    step.setName("mytest");
    StepExecution stepExecution = new StepExecution(step.getName(),
        jobExecution);
    repository.add(stepExecution);
    step.execute(stepExecution);


    assertEquals(2, recovered.size());
    assertEquals(2, stepExecution.getSkipCount());
    assertEquals(2, stepExecution.getWriteSkipCount());

View Full Code Here

    AbstractStep step = (AbstractStep) factory.getObject();


    StepExecution stepExecution = new StepExecution(step.getName(),
        jobExecution);
    repository.add(stepExecution);
    step.execute(stepExecution);
    assertEquals(BatchStatus.FAILED, stepExecution.getStatus());


    List<String> expectedOutput = Arrays.asList(StringUtils
        .commaDelimitedListToStringArray(""));
    assertEquals(expectedOutput, written);

View Full Code Here

    AbstractStep step = (AbstractStep) factory.getObject();


    StepExecution stepExecution = new StepExecution(step.getName(),
        jobExecution);
    repository.add(stepExecution);
    step.execute(stepExecution);
    assertEquals(BatchStatus.FAILED, stepExecution.getStatus());


    // We added a bogus cache so no items are actually skipped
    // because they aren't recognised as eligible
    assertEquals(0, stepExecution.getSkipCount());

View Full Code Here

    step.setName("step1");


    JobExecution jobExecution = repository.createJobExecution(job.getName(), new JobParameters());
    StepExecution stepExecution = jobExecution.createStepExecution(step.getName());
    repository.add(stepExecution);
    step.execute(stepExecution);
    assertEquals(BatchStatus.COMPLETED, stepExecution.getStatus());
    assertEquals(2, written.size());
    assertTrue(written.contains("foo"));
  }

View Full Code Here

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.