static Instant queryReplication()

in dbeam-core/src/main/java/com/spotify/dbeam/jobs/PsqlReplicationCheck.java [106:123]

• 18 lines of code
• 1 McCabe index (conditional complexity)

  static Instant queryReplication(final Connection connection, final String query)
      throws SQLException {
    final ResultSet resultSet = connection.createStatement().executeQuery(query);
    Preconditions.checkState(
        resultSet.next(),
        "Replication query returned empty results, consider using jdbc-avro-job instead");
    Instant lastReplication =
        Preconditions.checkNotNull(
                resultSet.getTimestamp("last_replication"),
                "Empty last_replication, consider using jdbc-avro-job instead")
            .toInstant();
    Duration replicationDelay = Duration.ofSeconds(resultSet.getLong("replication_delay"));
    LOGGER.info(
        "Psql replication check lastReplication={} replicationDelay={}",
        lastReplication,
        replicationDelay);
    return lastReplication;
  }