java CDK: add debug logging of executed SQL in TestDatabase (#33513)

airbytehq · Dec 15, 2023 · 96ac32e · 96ac32e
1 parent 7ddcc02
commit 96ac32e
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/...a/airbyte-cdk/db-sources/src/testFixtures/java/io/airbyte/cdk/testutils/TestDatabase.java b/...a/airbyte-cdk/db-sources/src/testFixtures/java/io/airbyte/cdk/testutils/TestDatabase.java
@@ -167,10 +167,13 @@ public Database getDatabase() {
     return new Database(getDslContext());
   }
 
-  protected void execSQL(Stream<String> sql) {
+  protected void execSQL(final Stream<String> sql) {
     try {
       getDatabase().query(ctx -> {
-        sql.forEach(ctx::execute);
+        sql.forEach(statement -> {
+          LOGGER.debug("{}", statement);
+          ctx.execute(statement);
+        });
         return null;
       });
     } catch (SQLException e) {