从网络数据库读取SpringBatch

Question

我有一个springbatch应用程序，我将连接到一个网络数据库进行阅读。我发现的大多数示例都嵌入了数据库，用于独立html" target="_blank">测试。我不想那样做。我不确定配置是否类似。以下是我所拥有的最具德国特色的部分（带有一些异议）：

@Configuration
@EnableBatchProcessing
public class BatchConfig {


    @Autowired
    public JobBuilderFactory jobBuilderFactory;

    @Autowired
    public StepBuilderFactory stepBuilderFactory;


    private static final String GET_DATA =
        "SELECT " +
                "stuffA, " +
                "stuffB, " +
                "FROM STUFF_TABLE " +
                "ORDER BY stuffA ASC";

    @Bean
    public ItemReader<StuffDto> itemReader(DataSource dataSource) {
        return new JdbcCursorItemReaderBuilder<StuffDto>()
            .name("cursorItemReader")
            .dataSource(dataSource)
            .sql(GET_DATA)
            .rowMapper(new BeanPropertyRowMapper<>(StuffDto.class))
            .build();
}

....

，然后从应用程序启动：

@SpringBootApplication
@EnableBatchProcessing
public class BatchApplication {

    public static void main(String[] args) {
        SpringApplication.run(BatchApplication.class, args);
    }
}

我没有配置数据源。我不确定，因为我的基本上只是一个到远程网络数据库的客户端连接，它的配置是否会与我找到的各种示例的嵌入式设置不同。所以我自然会出错（如下）。我只是在寻找一个简单的配置来实例化数据源，即到我的远程数据库的连接。

谢谢你的回复

...

启动ApplicationContext时出错。要显示条件报告，请在启用“调试”的情况下重新运行应用程序。2020-08-21 13:18:09.773错误1220---[main]o.s.b.d.记录故障分析报告员：

应用程序无法启动

描述：

java中方法itemReader的参数0。主要的配置配置BatchConfig需要一个“javax”类型的bean。sql。找不到“数据源”。

已找到以下候选项，但无法注入：-未加载“JndiDataSourceAutoConfiguration”中的Bean方法“dataSource”，因为@ConditionalOnProperty（spring.dataSource.jndi name）未找到属性“jndi name”-未加载“XadasourceAutoConfiguration”中的Bean方法“dataSource”，因为@ConditionalOnClass未找到属性“jndi name”必选类“javax”。交易TransactionManager'

行动：

考虑重新访问上面的条目或在配置中定义类型为'javax.sql.DataSource'的bean。

Answer 1

Ajavax。sql。数据源是对远程/本地/嵌入式数据源的抽象。因此，这是一个配置问题，您可以在其中将JDBC连接字符串设置为远程数据库主机。下面是一个远程MySQL数据源的示例：

@Bean
public DataSource dataSource() {
    MysqlDataSource datasource = new MysqlDataSource();
    // config values could be injected from properties/environment variables
    datasource.setURL("jdbc:mysql://REMOTE_HOST:PORT/schema");
    datasource.setUser("username");
    datasource.setPassword("passord");
    return datasource;
}

Spring Batch使用的是数据源对象，不（也不应该）知道它是本地的、远程的还是嵌入式的。