code: private void executeQuery(Subscriber<? super T> subscriber, State state) throws SQLException {
          if (!subscriber.isUnsubscribed()) {
              try {
                  log.debug("executing sql={}, parameters {}", query.sql(), parameters);
                  state.rs = query.resultSetTransform()
                          .call(query.context().resultSetTransform().call(state.ps.executeQuery()));
                  log.debug("executed ps={}", state.ps);
              } catch (SQLException e) {
                  throw new SQLException("failed to run sql=" + query.sql(), e);
              }
          }
      }
docs: Executes the prepared statement.
  
  @param subscriber
  @param state
  
  @throws SQLException