diff --git a/src/main/java/com/kingsrook/qqq/backend/module/rdbms/actions/RDBMSCountAction.java b/src/main/java/com/kingsrook/qqq/backend/module/rdbms/actions/RDBMSCountAction.java index 1976b273..d0970a73 100644 --- a/src/main/java/com/kingsrook/qqq/backend/module/rdbms/actions/RDBMSCountAction.java +++ b/src/main/java/com/kingsrook/qqq/backend/module/rdbms/actions/RDBMSCountAction.java @@ -56,12 +56,12 @@ public class RDBMSCountAction extends AbstractRDBMSAction implements CountInterf { try { - QTableMetaData table = countRequest.getTable(); - String tableName = getTableName(table); + QTableMetaData table = countRequest.getTable(); + String tableName = getTableName(table); String sql = "SELECT count(*) as record_count FROM " + tableName; - QQueryFilter filter = countRequest.getFilter(); + QQueryFilter filter = countRequest.getFilter(); List params = new ArrayList<>(); if(filter != null && CollectionUtils.nullSafeHasContents(filter.getCriteria())) { @@ -72,16 +72,18 @@ public class RDBMSCountAction extends AbstractRDBMSAction implements CountInterf CountResult rs = new CountResult(); - Connection connection = getConnection(countRequest); - QueryManager.executeStatement(connection, sql, ((ResultSet resultSet) -> + try(Connection connection = getConnection(countRequest)) { - ResultSetMetaData metaData = resultSet.getMetaData(); - if(resultSet.next()) + QueryManager.executeStatement(connection, sql, ((ResultSet resultSet) -> { - rs.setCount(resultSet.getInt("record_count")); - } + ResultSetMetaData metaData = resultSet.getMetaData(); + if(resultSet.next()) + { + rs.setCount(resultSet.getInt("record_count")); + } - }), params); + }), params); + } return rs; }