Close database when checking connection

airbytehq · Jan 7, 2022 · 6b5d420 · 6b5d420
1 parent 7b71fef
commit 6b5d420
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...ion-jdbc/src/main/java/io/airbyte/integrations/destination/jdbc/copy/CopyDestination.java b/...ion-jdbc/src/main/java/io/airbyte/integrations/destination/jdbc/copy/CopyDestination.java
@@ -54,10 +54,9 @@ public AirbyteConnectionStatus check(final JsonNode config) {
           .withMessage("Could not connect to the staging persistence with the provided configuration. \n" + e.getMessage());
     }
 
-    try {
+    try (final JdbcDatabase database = getDatabase(config)) {
       final var nameTransformer = getNameTransformer();
       final var outputSchema = nameTransformer.convertStreamName(config.get(schemaFieldName).asText());
-      final JdbcDatabase database = getDatabase(config);
       AbstractJdbcDestination.attemptSQLCreateAndDropTableOperations(outputSchema, database, nameTransformer, getSqlOperations());
 
       return new AirbyteConnectionStatus().withStatus(AirbyteConnectionStatus.Status.SUCCEEDED);