Method Worker

src/main/java/com/oltpbenchmark/api/Worker.java:75–100

(T benchmark, int id)

  private boolean seenDone = false;

  public Worker(T benchmark, int id) {
    this.id = id;
    this.benchmark = benchmark;
    this.configuration = this.benchmark.getWorkloadConfiguration();
    this.workloadState = this.configuration.getWorkloadState();
    this.currStatement = null;
    this.transactionTypes = this.configuration.getTransTypes();

    if (!this.configuration.getNewConnectionPerTxn()) {
      try {
        this.conn = this.benchmark.makeConnection();
        this.conn.setAutoCommit(false);
        this.conn.setTransactionIsolation(this.configuration.getIsolationMode());
      } catch (SQLException ex) {
        throw new RuntimeException("Failed to connect to database", ex);
      }
    }

    // Generate all the Procedures that we're going to need
    this.procedures.putAll(this.benchmark.getProcedures());
    for (Entry<TransactionType, Procedure> e : this.procedures.entrySet()) {
      Procedure proc = e.getValue();
      this.name_procedures.put(e.getKey().getName(), proc);
      this.class_procedures.put(proc.getClass(), proc);
    }
  }

  /** Get the BenchmarkModule managing this Worker */
  public final T getBenchmark() {