diff --git a/src/main/java/com/knecon/fforesight/mongo/database/commons/liquibase/TenantMongoLiquibaseExecutor.java b/src/main/java/com/knecon/fforesight/mongo/database/commons/liquibase/TenantMongoLiquibaseExecutor.java index 907c4aa..6eb2100 100644 --- a/src/main/java/com/knecon/fforesight/mongo/database/commons/liquibase/TenantMongoLiquibaseExecutor.java +++ b/src/main/java/com/knecon/fforesight/mongo/database/commons/liquibase/TenantMongoLiquibaseExecutor.java @@ -58,11 +58,12 @@ public class TenantMongoLiquibaseExecutor implements InitializingBean { try (MongoLiquibaseDatabase database = (MongoLiquibaseDatabase) DatabaseFactory.getInstance() .openDatabase(mongoUrl, mongoDBConnection.getUsername(), encryptionService.decrypt(mongoDBConnection.getPassword()), null, null)) { - Liquibase liquibase = new Liquibase(tenantLiquibaseProperties.getChangeLog(), new ClassLoaderResourceAccessor(), database); - Contexts contexts = new Contexts(tenantLiquibaseProperties.getContexts()); - List changeSetsList = liquibase.listUnrunChangeSets(contexts, null); - if (!changeSetsList.isEmpty()) { - liquibase.update(contexts); + try (Liquibase liquibase = new Liquibase(tenantLiquibaseProperties.getChangeLog(), new ClassLoaderResourceAccessor(), database)) { + Contexts contexts = new Contexts(tenantLiquibaseProperties.getContexts()); + List changeSetsList = liquibase.listUnrunChangeSets(contexts, null); + if (!changeSetsList.isEmpty()) { + liquibase.update(contexts); + } } } catch (Exception e) {