SpringCloud/spring-cloud-dataflow-samples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added generation of random execution context values.

Browse Source
This commit is contained in:
Corneil du Plessis
2023-12-14 15:23:30 +02:00
parent 0fda00af72
commit 76fce1d51e
4 changed files with 28 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
timestamp-batch-2.0.x/pom.xml
View File

@@ -5,7 +5,7 @@
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.7.16</version>
<version>2.7.18</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>io.spring</groupId>
@@ -38,6 +38,7 @@
<groupId>org.mariadb.jdbc</groupId>
<artifactId>mariadb-java-client</artifactId>
<version>[3.1.2,)</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>com.h2database</groupId>

32
timestamp-batch-2.0.x/src/main/java/io/spring/configuration/TimestampBatchTaskConfiguration.java
View File

@@ -16,15 +16,8 @@
package io.spring.configuration;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import javax.sql.DataSource;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.configuration.annotation.BatchConfigurer;
import org.springframework.batch.core.configuration.annotation.DefaultBatchConfigurer;
@@ -39,15 +32,18 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import javax.sql.DataSource;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
@Configuration
@EnableConfigurationProperties({ TimestampBatchTaskProperties.class })
public class TimestampBatchTaskConfiguration {
private static final Log logger = LogFactory.getLog(TimestampBatchTaskProperties.class);
private static final Logger logger = LoggerFactory.getLogger(TimestampBatchTaskProperties.class);
@Autowired
public JobBuilderFactory jobBuilderFactory;
@@ -96,7 +92,11 @@ public class TimestampBatchTaskConfiguration {
.start(stepBuilderFactory.get("job1step1")
.tasklet((contribution, chunkContext) -> {
DateFormat dateFormat = new SimpleDateFormat(config.getFormat());
logger.info(String.format("Job1 was run with date %s", dateFormat.format(new Date())));
contribution.getStepExecution().getExecutionContext().put("ctx1", "exec1");
contribution.getStepExecution().getJobExecution().getExecutionContext().put("job-ctx1", "exec-job1");
logger.info("jobstep1:{}", contribution.getStepExecution().getExecutionContext());
logger.info("job1:{}", contribution.getStepExecution().getJobExecution().getExecutionContext());
logger.info("Job1 was run with date {}", dateFormat.format(new Date()));
return RepeatStatus.FINISHED;
})
.build())
@@ -108,8 +108,12 @@ public class TimestampBatchTaskConfiguration {
return jobBuilderFactory.get("job2")
.start(stepBuilderFactory.get("job2step1")
.tasklet((contribution, chunkContext) -> {
contribution.getStepExecution().getExecutionContext().put("ctx2", "exec2");
contribution.getStepExecution().getJobExecution().getExecutionContext().put("job-ctx2", "exec-job2");
logger.info("jobstep1:{}", contribution.getStepExecution().getExecutionContext());
logger.info("job2:{}", contribution.getStepExecution().getJobExecution().getExecutionContext());
DateFormat dateFormat = new SimpleDateFormat(config.getFormat());
logger.info(String.format("Job2 was run with date %s", dateFormat.format(new Date())));
logger.info("Job2 was run with date {}", dateFormat.format(new Date()));
return RepeatStatus.FINISHED;
})
.build())