官网实例
https://spring.io/guides/gs/batch-processing/
Batch一句话描述概要:
一个Job仓库,一个Job启动器,多个Job任务,每个Job任务由多个Step组成,每个Step需要Reader读取,Processor处理,Writer写入,在处理过程中如果抛出异常那么可用Skip跳过然后继续执行。
整体架构图
Job操作流程
Job中Step活动图
配置文件
#oracle source
spring.primary.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring.primary.datasource.driver-class-name=oracle.jdbc.driver.OracleDriver
spring.primary.datasource.url=jdbc:oracle:thin:@localhost:1521:oracle
spring.primary.datasource.username=
spring.primary.datasource.password=
# batch config
spring.batch.job.enabled=true
spring.batch.initializer.enabled=true
代码配置
@Configuration
public class DataSourcePrimaryConfig {
@Primary
@Bean(name = "primaryDS")
@Qualifier("primaryDS")
@ConfigurationProperties(prefix="spring.primary.datasource")
public DataSource primaryDataSource(){
return DataSourceBuilder.create().build();
}
}
异常问题处理
1、Caused by: org.springframework.dao.CannotSerializeTransactionException
在oracle中输入执行: set transaction isolation level read committed;
2、读取Oracle数据源的异常:Could not open JDBC Connection for transaction,SET TRANSACTION 必须是事务处理的第一个语句
最终查明是数据库权限问题,可能需要修改下面的事务处理权限,因为在dba用户下,抽取操作是有效的。