Spring Batch 5.0如何不持久化元数据至数据库？解决运行异常

问题根源 #

Spring Batch默认依赖数据库存储作业元数据，当未指定自定义元数据存储策略时，框架会自动尝试使用当前配置的数据源访问默认的元数据表（如BATCH_JOB_INSTANCE），若数据库中未预先创建这些表，就会抛出你遇到的SQL语法错误异常。

解决方案 #

方案一：使用内存型元数据存储（推荐）

通过配置让Spring Batch使用内存中的Map结构存储元数据，完全脱离数据库依赖。

配置文件方式（Spring Boot）

在application.yml中添加以下配置：

spring:
  batch:
    jdbc:
      initialize-schema: never  # 禁止自动初始化元数据表
    repository:
      type: map  # 指定使用内存Map作为元数据存储

或application.properties：

spring.batch.jdbc.initialize-schema=never
spring.batch.repository.type=map

Java配置方式（非Boot或需自定义Bean）

创建配置类覆盖默认的JobRepository和JobLauncher：

import org.springframework.batch.core.configuration.annotation.DefaultBatchConfigurer;
import org.springframework.batch.core.repository.JobRepository;
import org.springframework.batch.core.repository.support.MapJobRepositoryFactoryBean;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.batch.core.launch.support.SimpleJobLauncher;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.task.SimpleAsyncTaskExecutor;

@Configuration
public class InMemoryBatchConfig extends DefaultBatchConfigurer {

    @Override
    protected JobRepository createJobRepository() throws Exception {
        MapJobRepositoryFactoryBean factory = new MapJobRepositoryFactoryBean();
        factory.afterPropertiesSet();
        return factory.getObject();
    }

    @Bean
    public JobLauncher jobLauncher(JobRepository jobRepository) throws Exception {
        SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
        jobLauncher.setJobRepository(jobRepository);
        jobLauncher.setTaskExecutor(new SimpleAsyncTaskExecutor());
        jobLauncher.afterPropertiesSet();
        return jobLauncher;
    }
}

方案二：完全禁用元数据存储（仅适用于无状态作业场景）

如果不需要追踪任何作业执行状态，可以使用NoOpJobRepository，但这种方式会丢失所有作业运行信息，仅适合简单测试场景：

import org.springframework.batch.core.repository.JobRepository;
import org.springframework.batch.core.repository.support.NoOpJobRepository;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.batch.core.launch.support.SimpleJobLauncher;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.task.SimpleAsyncTaskExecutor;

@Configuration
public class NoOpBatchConfig {

    @Bean
    public JobRepository jobRepository() {
        return new NoOpJobRepository();
    }

    @Bean
    public JobLauncher jobLauncher(JobRepository jobRepository) throws Exception {
        SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
        jobLauncher.setJobRepository(jobRepository);
        jobLauncher.setTaskExecutor(new SimpleAsyncTaskExecutor());
        jobLauncher.afterPropertiesSet();
        return jobLauncher;
    }
}

注意事项 #

• 内存型存储的元数据会在应用重启后全部丢失，适合临时测试或不需要持久化状态的作业。
• 若项目中存在数据源配置，确保Spring Batch不会自动绑定该数据源，上述配置已通过指定存储类型避免了这种情况。

内容的提问来源于stack exchange，提问作者Ram