SpringBoot中级篇-SpringBatch+Oracle配置

官网实例
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用户下,抽取操作是有效的。

发表评论

电子邮件地址不会被公开。 必填项已用*标注