org.springframework.batch.core.JobExecution.setExecutionContext()方法的使用及代码示例

本文整理了Java中org.springframework.batch.core.JobExecution.setExecutionContext()方法的一些代码示例，展示了JobExecution.setExecutionContext()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。JobExecution.setExecutionContext()方法的具体详情如下：
包路径：org.springframework.batch.core.JobExecution
类名称：JobExecution
方法名：setExecutionContext

JobExecution.setExecutionContext介绍

[英]Sets the ExecutionContext for this execution
[中]设置此执行的ExecutionContext

代码示例

代码示例来源：origin: spring-projects/spring-batch

@Override
public JobExecution createJobExecution(JobInstance jobInstance,
JobParameters jobParameters, String jobConfigurationLocation) {
Assert.notNull(jobInstance, "A JobInstance is required to associate the JobExecution with");
Assert.notNull(jobParameters, "A JobParameters object is required to create a JobExecution");
JobExecution jobExecution = new JobExecution(jobInstance, jobParameters, jobConfigurationLocation);
ExecutionContext executiOnContext= new ExecutionContext();
jobExecution.setExecutionContext(executionContext);
jobExecution.setLastUpdated(new Date(System.currentTimeMillis()));
// Save the JobExecution so that it picks up an ID (useful for clients
// monitoring asynchronous executions):
jobExecutionDao.saveJobExecution(jobExecution);
ecDao.saveExecutionContext(jobExecution);
return jobExecution;
}
}

代码示例来源：origin: spring-projects/spring-batch

@Override
@Nullable
public JobExecution getLastJobExecution(String jobName, JobParameters jobParameters) {
JobInstance jobInstance = jobInstanceDao.getJobInstance(jobName, jobParameters);
if (jobInstance == null) {
return null;
}
JobExecution jobExecution = jobExecutionDao.getLastJobExecution(jobInstance);
if (jobExecution != null) {
jobExecution.setExecutionContext(ecDao.getExecutionContext(jobExecution));
stepExecutionDao.addStepExecutions(jobExecution);
}
return jobExecution;
}

代码示例来源：origin: spring-projects/spring-batch

private void getJobExecutionDependencies(JobExecution jobExecution) {
JobInstance jobInstance = jobInstanceDao.getJobInstance(jobExecution);
stepExecutionDao.addStepExecutions(jobExecution);
jobExecution.setJobInstance(jobInstance);
jobExecution.setExecutionContext(ecDao.getExecutionContext(jobExecution));
}

代码示例来源：origin: spring-projects/spring-batch

latest.setExecutionContext(stepExecutionContext);
ExecutionContext jobExecutiOnContext= ecDao.getExecutionContext(latest.getJobExecution());
latest.getJobExecution().setExecutionContext(jobExecutionContext);

代码示例来源：origin: spring-projects/spring-batch

@Transactional
@Test
public void testSaveAndFindJobContext() {
ExecutionContext ctx = new ExecutionContext(Collections. singletonMap("key", "value"));
jobExecution.setExecutionContext(ctx);
contextDao.saveExecutionContext(jobExecution);
ExecutionContext retrieved = contextDao.getExecutionContext(jobExecution);
assertEquals(ctx, retrieved);
}

代码示例来源：origin: spring-projects/spring-batch

@Transactional
@Test
public void testSaveAndFindEmptyJobContext() {
ExecutionContext ctx = new ExecutionContext();
jobExecution.setExecutionContext(ctx);
contextDao.saveExecutionContext(jobExecution);
ExecutionContext retrieved = contextDao.getExecutionContext(jobExecution);
assertEquals(ctx, retrieved);
}

代码示例来源：origin: spring-projects/spring-batch

jobExecution.setExecutionContext(executionContext);
jobExecution.setLastUpdated(new Date(System.currentTimeMillis()));

代码示例来源：origin: spring-projects/spring-batch

@Transactional
@Test
public void testUpdateContext() {
ExecutionContext ctx = new ExecutionContext(Collections
. singletonMap("key", "value"));
jobExecution.setExecutionContext(ctx);
contextDao.saveExecutionContext(jobExecution);
ctx.putLong("longKey", 7);
contextDao.updateExecutionContext(jobExecution);
ExecutionContext retrieved = contextDao.getExecutionContext(jobExecution);
assertEquals(ctx, retrieved);
assertEquals(7, retrieved.getLong("longKey"));
}

代码示例来源：origin: spring-projects/spring-batch

private void start(String foo) {
JobSynchronizationManager.close();
jobExecution = new JobExecution(123L);
ExecutionContext executiOnContext= new ExecutionContext();
executionContext.put("foo", foo);
executionContext.put("parent", bar);
jobExecution.setExecutionContext(executionContext);
JobSynchronizationManager.register(jobExecution);
beanCount = beanFactory.getBeanDefinitionCount();
}

代码示例来源：origin: spring-projects/spring-batch

@Before
public void start() {
JobSynchronizationManager.close();
jobExecution = new JobExecution(123L);
ExecutionContext executiOnContext= new ExecutionContext();
executionContext.put("foo", "bar");
jobExecution.setExecutionContext(executionContext);
JobSynchronizationManager.register(jobExecution);
beanCount = beanFactory.getBeanDefinitionCount();
}

代码示例来源：origin: spring-projects/spring-batch

@Test
public void testCompoundPropertyTwice() throws Exception {
assertEquals("bar-bar", compound.getName());
JobSynchronizationManager.close();
jobExecution = new JobExecution(123L);
ExecutionContext executiOnContext= new ExecutionContext();
executionContext.put("foo", "spam");
jobExecution.setExecutionContext(executionContext);
JobSynchronizationManager.register(jobExecution);
assertEquals("spam-bar", compound.getName());
}

代码示例来源：origin: spring-projects/spring-batch

@Transactional
@Test
public void testSaveExecutionContext() throws Exception {
@SuppressWarnings("serial")
ExecutionContext ctx = new ExecutionContext() {
{
putLong("crashedPosition", 7);
}
};
JobExecution jobExec = jobRepository.createJobExecution(job.getName(), jobParameters);
jobExec.setStartTime(new Date(0));
jobExec.setExecutionContext(ctx);
Step step = new StepSupport("step1");
StepExecution stepExec = new StepExecution(step.getName(), jobExec);
stepExec.setExecutionContext(ctx);
jobRepository.add(stepExec);
StepExecution retrievedStepExec = jobRepository.getLastStepExecution(jobExec.getJobInstance(), step.getName());
assertEquals(stepExec, retrievedStepExec);
assertEquals(ctx, retrievedStepExec.getExecutionContext());
// JobExecution retrievedJobExec =
// jobRepository.getLastJobExecution(jobExec.getJobInstance());
// assertEquals(jobExec, retrievedJobExec);
// assertEquals(ctx, retrievedJobExec.getExecutionContext());
}

代码示例来源：origin: spring-projects/spring-batch

@Test
public void testExecutionContext() throws Exception {
JobExecution stepExecution = new JobExecution(11L);
ExecutionContext executiOnContext= new ExecutionContext();
executionContext.put("name", "spam");
stepExecution.setExecutionContext(executionContext);
proxied.execute(stepExecution);
assertTrue(TestJob.getContext().attributeNames().length > 0);
String collaborator = (String) TestJob.getContext().getAttribute("collaborator");
assertNotNull(collaborator);
assertEquals("bar", collaborator);
}

代码示例来源：origin: org.springframework.batch/org.springframework.batch.core

public JobExecution getLastJobExecution(String jobName, JobParameters jobParameters) {
JobInstance jobInstance = jobInstanceDao.getJobInstance(jobName, jobParameters);
if (jobInstance == null) {
return null;
}
JobExecution jobExecution = jobExecutionDao.getLastJobExecution(jobInstance);
if (jobExecution != null) {
jobExecution.setExecutionContext(ecDao.getExecutionContext(jobExecution));
}
return jobExecution;
}

代码示例来源：origin: org.springframework.batch.core/org.motechproject.org.springframework.batch.core

@Override
public JobExecution getLastJobExecution(String jobName, JobParameters jobParameters) {
JobInstance jobInstance = jobInstanceDao.getJobInstance(jobName, jobParameters);
if (jobInstance == null) {
return null;
}
JobExecution jobExecution = jobExecutionDao.getLastJobExecution(jobInstance);
if (jobExecution != null) {
jobExecution.setExecutionContext(ecDao.getExecutionContext(jobExecution));
}
return jobExecution;
}

代码示例来源：origin: org.springframework.batch/spring-batch-core

private void getJobExecutionDependencies(JobExecution jobExecution) {
JobInstance jobInstance = jobInstanceDao.getJobInstance(jobExecution);
stepExecutionDao.addStepExecutions(jobExecution);
jobExecution.setJobInstance(jobInstance);
jobExecution.setExecutionContext(ecDao.getExecutionContext(jobExecution));
}

代码示例来源：origin: org.springframework.batch.core/org.motechproject.org.springframework.batch.core

private void getJobExecutionDependencies(JobExecution jobExecution) {
JobInstance jobInstance = jobInstanceDao.getJobInstance(jobExecution);
stepExecutionDao.addStepExecutions(jobExecution);
jobExecution.setJobInstance(jobInstance);
jobExecution.setExecutionContext(ecDao.getExecutionContext(jobExecution));
}

代码示例来源：origin: org.springframework.batch/org.springframework.batch.core

private void getJobExecutionDependencies(JobExecution jobExecution) {
JobInstance jobInstance = jobInstanceDao.getJobInstance(jobExecution);
stepExecutionDao.addStepExecutions(jobExecution);
jobExecution.setJobInstance(jobInstance);
jobExecution.setExecutionContext(ecDao
.getExecutionContext(jobExecution));
}

代码示例来源：origin: apache/servicemix-bundles

private void getJobExecutionDependencies(JobExecution jobExecution) {
JobInstance jobInstance = jobInstanceDao.getJobInstance(jobExecution);
stepExecutionDao.addStepExecutions(jobExecution);
jobExecution.setJobInstance(jobInstance);
jobExecution.setExecutionContext(ecDao.getExecutionContext(jobExecution));
}

代码示例来源：origin: com.marklogic/marklogic-spring-batch

@Override
public JobExecution unmarshal(AdaptedJobExecution v) throws Exception {
JobExecution jobExec = new JobExecution(v.getId(), v.getJobParameters());
jobExec.setJobInstance(v.getJobInstance());
jobExec.setCreateTime(v.getCreateDateTime());
jobExec.setEndTime(v.getEndDateTime());
jobExec.setLastUpdated(v.getLastUpdatedDateTime());
jobExec.setStartTime(v.getStartDateTime());
jobExec.setStatus(BatchStatus.valueOf(v.getStatus()));
jobExec.setExitStatus(new ExitStatus(v.getExitCode(), ""));
jobExec.addStepExecutions(v.getStepExecutions());
jobExec.setVersion(v.getVersion());
jobExec.setExecutionContext(v.getExecutionContext());
return jobExec;
}