使用自己的数据库配置Spring Cloud数据流任务

Question

我有一个任务应用程序，它有自己的数据库，我想在Spring Cloud Data Flow中运行。

我的问题是SCDF使用SCDF的数据源配置覆盖任务中的数据源配置。 （两个数据库都是Oracle DB。）

我的任务应该写入另一个数据库（但我也想知道它在SCDF数据库中的状态）。

如何将我的任务配置为连接到自己的数据库以及SCDF的数据库？

Answer 1

我找到了解决方案。

我在配置类中定义了两个数据源（一个用于JPA，一个用于SCDF），以此为例：https://www.baeldung.com/spring-data-jpa-multiple-databases

但这还不够，因为默认情况下，数据流服务器只接受一个数据源。要解决这个问题，需要扩展DefaultTaskConfigurer并在构造函数中设置Data Flow Server的数据源。

@Component
public class GeneratorTaskConfigurer extends DefaultTaskConfigurer {

    public GeneratorTaskConfigurer(@Qualifier("dataflowDataSource") DataSource dataSource) {
        super(dataSource);
    }
}

Answer 2

你可以有一个带有SCDF数据源代码的配置类

@Configuration
@Profile("cloud")
public class MySqlConfiguration {

@Bean
public Cloud cloud() {
    return new CloudFactory().getCloud();
}

@Bean
@Primary
public DataSource dataSource() {
    return cloud().getSingletonServiceConnector(DataSource.class, null);
}

@Bean
@Primary
public PlatformTransactionManager getTransactionManager() {
    return new DataSourceTransactionManager(dataSource());
}

@Bean
public JobRepository jobRepositoryFactoryBean() throws Exception{
    JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
    factory.setDataSource(dataSource());
    factory.setTransactionManager(getTransactionManager());
    factory.afterPropertiesSet();
    return factory.getObject();
}

@Bean
@Primary
public DefaultTaskConfigurer defaultTaskConfigurer() {
    return new DefaultTaskConfigurer(dataSource());
}
}

然后将您的其他数据源配置放在要写入的数据库的单独类中。确保将SCDF标记为@Primary，否则会出现多个数据源错误。

希望这可以帮助。