INNER CODE UNIT · Java

createVersionTableIfNotExists

gruelbox/transaction-outbox · transactionoutbox-core/src/main/java/com/gruelbox/transactionoutbox/DefaultDialect.java:42

  public void createVersionTableIfNotExists(Connection connection) throws SQLException {
    try (Statement s = connection.createStatement()) {
      s.execute(
          "CREATE TABLE IF NOT EXISTS TXNO_VERSION (id INT DEFAULT 0, version INT, PRIMARY KEY (id))");
    }
  }

  @Override
  public String toString() {
    return name;
  }

  @Override
  public Stream<Migration> getMigrations() {
    return migrations.stream();
  }

  @Setter

View source record →