code: @SuppressWarnings("unchecked")
      private void performCommit(Subscriber<? super T> subscriber, State state) {
          getConnection(state);
          query.context().endTransactionObserve();
          if (subscriber.isUnsubscribed())
              return;
  
          debug("committing");
          Conditions.checkTrue(!Util.isAutoCommit(state.con));
          Util.commit(state.con);
          // must close before onNext so that connection is released and is
          // available to a query that might process the onNext
          close(state);
  
          if (subscriber.isUnsubscribed())
              return;
  
          subscriber.onNext((T) Integer.valueOf(1));
          debug("committed");
          complete(subscriber);
      }
docs: Commits the current transaction. Throws {@link RuntimeException} if
  connection is in autoCommit mode.
  
  @param subscriber
  @param state