Vertx JDBC的工作原理

Question

private void selectEndedMatches(){
        this.jdbcClient.getConnection(conn->{
            if(conn.failed()){
                log.error("Can't get Vertx connection",conn.cause());
            } else{
                final SQLConnection connection = conn.result();
                connection.queryWithParams("select matchid from get5_stats_matches where matchid > ? and end_time is not null",new JsonArray().add(this.lastMatchId),this::endedMatches);
                connection.close();
            }
        });
    }


private void endedMatches(final AsyncResult<ResultSet> rs) {
        if(rs.failed()){
            log.error("Can't make select statement from JdbcVerticle",rs.cause());
        } else{
            final List<JsonArray> results = rs.result().getResults();
            final List<Integer> endedMatches = new ArrayList<>(results.size());
            for (final JsonArray result : results) {
                endedMatches.add(result.getInteger(0));
            }

        }
    }

Vertx使用一个辅助线程来执行select语句，以避免阻塞事件循环线程，但是在这种情况下，每个sql查询都需要一个单独的线程来执行。但是如果Vertx不使用任何单独线程来执行查询呢？在这种情况下，事件循环如何知道结果何时来自DB呢？使用线程就很简单了，事件循环可以检查jdbc查询使用的线程的当前状态，如果状态准备就绪，就意味着事件循环应该执行回调

我说得对吗？

Answer 1

总的来说，你是正确的。
你自己可以看到引擎盖下面：

方法querywithparams()调用execute():

public SQLConnection queryWithParams(String sql, JsonArray params, Handler<AsyncResult<ResultSet>> resultHandler) {
    new JDBCQuery(vertx, helper, options, ctx, sql, params).execute(conn, statementsQueue, resultHandler);
    return this;
  }

execute()如下所示：

public void execute(Connection conn, TaskQueue statementsQueue, Handler<AsyncResult<T>> resultHandler) {
    ctx.executeBlocking(future -> handle(conn, future), statementsQueue, resultHandler);
}

您可能想知道ctx来自哪里。它位于jdbcclientimpl中：

public SQLClient getConnection(Handler<AsyncResult<SQLConnection>> handler) {
    Context ctx = vertx.getOrCreateContext();
    getConnection(ctx, ar -> ctx.runOnContext(v -> handler.handle(ar)));
    return this;
  }