Class Procedure

src/main/java/com/oltpbenchmark/api/Procedure.java:35–234

import org.slf4j.LoggerFactory;

public abstract class Procedure {
  private static final Logger LOG = LoggerFactory.getLogger(Procedure.class);

  private final String procName;
  private DatabaseType dbType;

  public DatabaseType getDbType() {
    return dbType;
  }

  private Map<String, SQLStmt> name_stmt_xref;

  /** Constructor */
  protected Procedure() {
    this.procName = this.getClass().getSimpleName();
  }

  /**
   * Initialize all of the SQLStmt handles. This must be called separately from the constructor,
   * otherwise we can't get access to all of our SQLStmts.
   *
   * @param <T>
   * @return
   */
  @SuppressWarnings("unchecked")
  protected final <T extends Procedure> T initialize(DatabaseType dbType) {
    this.dbType = dbType;
    this.name_stmt_xref = Procedure.getStatements(this);

    if (LOG.isDebugEnabled()) {
      LOG.debug(
          String.format(
              "Initialized %s with %d SQLStmts: %s",
              this, this.name_stmt_xref.size(), this.name_stmt_xref.keySet()));
    }
    return ((T) this);
  }

  /** Return the name of this Procedure */
  protected final String getProcedureName() {
    return (this.procName);
  }

  /**
   * Return a PreparedStatement for the given SQLStmt handle The underlying Procedure API will make
   * sure that the proper SQL for the target DBMS is used for this SQLStmt. This will automatically
   * call setObject for all the parameters you pass in
   *
   * @param conn
   * @param stmt
   * @param params
   * @return
   * @throws SQLException
   */
  public final PreparedStatement getPreparedStatement(
      Connection conn, SQLStmt stmt, Object... params) throws SQLException {
    PreparedStatement pStmt = this.getPreparedStatementReturnKeys(conn, stmt, null);
    for (int i = 0; i < params.length; i++) {