如何测试从FTP读取数据并写入数据库的Spring Batch作业？

完全可以测试这类Spring Batch作业，你推测的思路是对的，核心是隔离外部依赖（FTP服务器），聚焦作业的核心逻辑（解析、写入），下面分两种测试场景给出具体实现：

一、单元测试：聚焦文件解析逻辑 #

针对文件到领域模型的解析环节，无需启动整个Spring上下文，直接测试解析组件即可：

• 将测试文件放到src/test/resources目录下（类路径）
• 直接实例化文件读取/解析组件，验证输出的领域模型是否符合预期

示例代码：

@Test
void testFileParsing() throws Exception {
    // 初始化FlatFileItemReader（适配固定格式文件场景）
    FlatFileItemReader<DomainModel> reader = new FlatFileItemReader<>();
    reader.setResource(new ClassPathResource("test-data.csv"));
    reader.setLineMapper(new DefaultLineMapper<DomainModel>() {{
        setLineTokenizer(new DelimitedLineTokenizer() {{
            setNames("id", "name", "value");
        }});
        setFieldSetMapper(new BeanWrapperFieldSetMapper<DomainModel>() {{
            setTargetType(DomainModel.class);
        }});
    }});
    reader.open(new ExecutionContext());

    // 读取并验证第一条数据
    DomainModel item = reader.read();
    assertNotNull(item);
    assertEquals(1L, item.getId());
    assertEquals("test-name", item.getName());
    
    reader.close();
}

二、集成测试：验证完整作业流程 #

要验证「读取-解析-写入」的完整链路，需模拟FTP环境并使用内存数据库：

1. 替换FTP依赖：在测试环境下，将FTP读取器替换为类路径文件读取器（避免依赖真实FTP服务器）
   可以通过@Profile("test")配置测试专用的ItemReader：

   @Configuration
   @Profile("test")
   public class TestBatchConfig {
       @Bean
       public ItemReader<DomainModel> testFileReader() {
           FlatFileItemReader<DomainModel> reader = new FlatFileItemReader<>();
           reader.setResource(new ClassPathResource("test-data.csv"));
           // 复用单元测试中的解析配置
           return reader;
       }
   }
   

2. 配置内存数据库：在src/test/resources/application-test.yml中配置H2内存数据库，避免污染生产数据：

   spring:
     datasource:
       url: jdbc:h2:mem:testdb;DB_CLOSE_DELAY=-1
       driver-class-name: org.h2.Driver
       username: sa
       password:
     jpa:
       hibernate:
         ddl-auto: create-drop
   

3. 编写集成测试用例：使用Spring Batch的测试工具启动作业，然后验证数据库数据：

   @SpringBootTest
   @ActiveProfiles("test")
   @SpringBatchTest
   class FtpToDbJobTest {
       @Autowired
       private JobLauncherTestUtils jobLauncherTestUtils;
       @Autowired
       private JdbcTemplate jdbcTemplate;
   
       @Test
       void testJobCompleteAndDataPersisted() throws Exception {
           // 启动作业
           JobExecution jobExecution = jobLauncherTestUtils.launchJob();
           // 验证作业执行成功
           assertEquals(BatchStatus.COMPLETED, jobExecution.getStatus());
   
           // 验证数据库中数据是否正确
           Integer count = jdbcTemplate.queryForObject("SELECT COUNT(*) FROM domain_model", Integer.class);
           assertEquals(3, count); // 假设测试文件包含3条数据
   
           String name = jdbcTemplate.queryForObject("SELECT name FROM domain_model WHERE id = ?", 
               new Object[]{1L}, String.class);
           assertEquals("test-name", name);
       }
   }
   

额外技巧：模拟FTP服务器（可选） #

如果一定要验证FTP读取逻辑（而非仅解析），可以用内存FTP服务器组件（如org.mockftpserver:MockFtpServer）在测试中临时启动FTP服务，上传测试文件后再执行作业，完全避免依赖外部FTP环境。

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