MGR-96

appNG · Feb 4, 2020 · 54239af · 54239af
1 parent c93255b
commit 54239af
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/src/main/java/org/appng/application/manager/business/SqlExecutor.java b/src/main/java/org/appng/application/manager/business/SqlExecutor.java
@@ -182,11 +182,12 @@ public void setHasError(boolean hasError) {
 	}
 
 	public List<String> getQueries(String sql, DatabaseConnection connection) {
-		Database<?> db = DatabaseFactory
-				.createDatabase(new FluentConfiguration().dataSource(connection.getDataSource()), true);
-		SqlScript sqlScript = new SqlScript(db.createSqlStatementBuilderFactory(), new StringResource(sql), false);
 		List<String> queries = new ArrayList<String>();
-		sqlScript.getSqlStatements().forEach(query -> queries.add(query.getSql()));
+		try (Database<?> db = DatabaseFactory
+				.createDatabase(new FluentConfiguration().dataSource(connection.getDataSource()), true)) {
+			SqlScript sqlScript = new SqlScript(db.createSqlStatementBuilderFactory(), new StringResource(sql), false);
+			sqlScript.getSqlStatements().forEach(query -> queries.add(query.getSql()));
+		}
 		return queries;
 	}