initial ctid for testing

airbyte-db/db-lib/src/main/java/io/airbyte/db/factory/DataSourceFactory.java

@@ -306,6 +306,7 @@ public DataSource build() {
       config.setPassword(password);
       config.setUsername(username);
 
+      config.setIdleTimeout(1_000); // TODO: check here
       /*
        * Disable to prevent failing on startup. Applications may start prior to the database container
        * being available. To avoid failing to create the connection pool, disable the fail check. This

airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/ctid/CtidStateIterator.java

@@ -40,7 +40,7 @@ protected AirbyteMessage computeNext() {
     }
 
     if (messageIterator.hasNext()) {
-      if (count % 10_000 == 0 && StringUtils.isNotBlank(lastCtid)) {
+      if (count % 1_000_000 == 0 && StringUtils.isNotBlank(lastCtid)) {
         LOGGER.info("saving ctid state with {}", this.lastCtid);
         return CtidStateManager.createStateMessage(pair, new CtidStatus().withCtid(lastCtid));
       }

airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/ctid/PostgresCtidHandler.java

@@ -131,6 +131,7 @@ private PreparedStatement createCtidQueryStatement(
         preparedStatement.setObject(1, "(0,0)");
       }
       LOGGER.info("Executing query for table {}: {}", tableName, preparedStatement);
+      preparedStatement.setQueryTimeout(120);
       return preparedStatement;
     } catch (final SQLException e) {
       throw new RuntimeException(e);
@@ -161,7 +162,7 @@ private AutoCloseableIterator<AirbyteMessage> augmentWithLogs(final AutoCloseabl
         AirbyteStreamUtils.convertFromNameAndNamespace(pair.getName(), pair.getNamespace()),
         r -> {
           final long count = recordCount.incrementAndGet();
-          if (count % 10000 == 0) {
+          if (count % 1_000_000 == 0) {
             LOGGER.info("Reading stream {}. Records read: {}", streamName, count);
           }
           return r;

airbyte-integrations/connectors/source-relational-db/src/main/java/io/airbyte/integrations/source/relationaldb/AbstractDbSource.java

@@ -418,7 +418,7 @@ private AutoCloseableIterator<AirbyteMessage> createReadIterator(final Database
         AirbyteStreamUtils.convertFromNameAndNamespace(pair.getName(), pair.getNamespace()),
         r -> {
           final long count = recordCount.incrementAndGet();
-          if (count % 10000 == 0) {
+          if (count % 1_000_000 == 0) {
             LOGGER.info("Reading stream {}. Records read: {}", streamName, count);
           }
           return r;