executeDirect.java

  private <T> void executeDirect(ContextInternal ctx, AbstractJDBCAction<T> action, Handler<AsyncResult<T>> handler) {
    getConnection(ctx, ar1 -> {
      Future<T> fut = Future.future();
      fut.setHandler(ar2 -> ctx.runOnContext(v -> handler.handle(ar2)));
      if (ar1.succeeded()) {
        JDBCConnectionImpl conn = (JDBCConnectionImpl) ar1.result();
        Tracer tracer = ctx.owner().tracer();
        Object trace;
        if (tracer != null) {
          trace = tracer.sendRequest(ctx.localContextData(), action);
        } else {
          trace = null;
        }
        Throwable failure = null;
        T result = null;
        try {
          result = action.execute(conn.conn);
          fut.complete(result);
        } catch (Exception e) {
          failure = e;
          fut.fail(e);
        } finally {
          if (tracer != null) {
            tracer.receiveResponse(ctx.localContextData(), result, trace, failure);
          }
          if (metrics != null) {
            metrics.end(conn.metric, true);
          }
          try {
            conn.conn.close();
          } catch (Exception e) {
            JDBCConnectionImpl.log.error("Failure in closing connection", ar1.cause());
          }
        }
      } else {
        fut.fail(ar1.cause());
      }
    });
  }