Method doWork

src/main/java/com/oltpbenchmark/api/Worker.java:401–644

Called in a loop in the thread to exercise the system under test. Each implementing worker should return the TransactionType handle that was executed. @param databaseType TODO @param transactionType TODO

(DatabaseType databaseType, TransactionType transactionType)

   * @param transactionType TODO
   */
  protected final void doWork(DatabaseType databaseType, TransactionType transactionType) {

    try {
      int retryCount = 0;
      int maxRetryCount = configuration.getMaxRetries();

      while (retryCount < maxRetryCount && this.workloadState.getGlobalState() != State.DONE) {

        TransactionStatus status = TransactionStatus.UNKNOWN;

        if (this.conn == null) {
          try {
            if (!this.configuration.getNewConnectionPerTxn()) {
              if (retryCount > 0) {
                Duration delay = Duration.ofSeconds(Math.min(retryCount, 5));
                LOG.info("Backing off {} seconds before reconnecting.", delay.toSeconds());
                try {
                  Thread.sleep(delay);
                } catch (InterruptedException ex) {
                  // pass
                }
              } else {
                LOG.info("(Re)connecting to database.");
              }
            }
            this.conn = this.benchmark.makeConnection();
            this.conn.setAutoCommit(false);
            this.conn.setTransactionIsolation(this.configuration.getIsolationMode());
          } catch (SQLException ex) {
            if (LOG.isDebugEnabled()) {
              LOG.debug(String.format("%s failed to open a connection...", this));
            }
            retryCount++;
            continue;
          }
        }

        try {

          if (LOG.isDebugEnabled()) {
            LOG.debug(String.format("%s %s attempting...", this, transactionType));
          }

          status = this.executeWork(conn, transactionType);

          if (LOG.isDebugEnabled()) {
            LOG.debug(
                String.format(
                    "%s %s completed with status [%s]...", this, transactionType, status.name()));
          }

          if (LOG.isDebugEnabled()) {
            LOG.debug(String.format("%s %s committing...", this, transactionType));
          }

          conn.commit();

          break;