0

我有一个通过多个数据库运行的应用程序，并且每个数据库对所有表运行选择查询并将其转储到 hadoop。

我的设计是一次创建一个数据源连接，并使用获得的连接池在多个线程中运行选择查询。完成此数据源后，关闭连接并创建新连接。

这是异步代码

@Component
public class MySampleService {

    private final static Logger LOGGER = Logger
            .getLogger(MySampleService.class);

    @Async
    public Future<String> callAsync(JdbcTemplate template, String query) throws InterruptedException {

 try {
        jdbcTemplate.query(query);
        //process the results
        return new AsyncResult<String>("success");
      }
 catch (Exception ex){
         return new AsyncResult<String>("failed");
    }    
}

这是来电者

 public String taskExecutor() throws InterruptedException, ExecutionException {
        Future<String> asyncResult1 = mySampleService.callAsync(jdbcTemplate,query1);
        Future<String> asyncResult2 = mySampleService.callAsync(jdbcTemplate,query2);
        Future<String> asyncResult3 = mySampleService.callAsync(jdbcTemplate,query3);
        Future<String> asyncResult4 = mySampleService.callAsync(jdbcTemplate,query4);

        LOGGER.info(asyncResult1.get());
        LOGGER.info(asyncResult2.get());
        LOGGER.info(asyncResult3.get());
        LOGGER.info( asyncResult4.get());

       //now all threads finished, close the connection
       jdbcTemplate.getConnection().close();
    }

我想知道这是否是正确的方法，或者做任何我缺少的开箱即用的现有/优化解决方案。我不能使用 spring-data-jpa，因为我的查询很复杂。

谢谢

4

1 回答 1

0

Spring Boot 文档：

生产数据库连接也可以使用池数据源自动配置。这是选择特定实现的算法：

  • 我们更喜欢 Tomcat 池化数据源，因为它的性能和并发性，所以如果可用，我们总是选择它。
  • 否则，如果 HikariCP 可用，我们将使用它。
  • 如果 Tomcat 池数据源和 HikariCP 均不可用，并且 Commons DBCP 可用，我们将使用它，但我们不建议在生产中使用它。
  • 最后，如果 Commons DBCP2 可用，我们将使用它。

如果您使用 spring-boot-starter-jdbc 或 spring-boot-starter-data-jpa 'starters'，您将自动获得对 tomcat-jdbc 的依赖。

因此，应该为您提供合理的默认值。

于 2017-01-24T07:44:21.443 回答