diff --git a/infra/executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/execute/result/query/impl/driver/jdbc/type/stream/JDBCStreamQueryResultTest.java b/infra/executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/execute/result/query/impl/driver/jdbc/type/stream/JDBCStreamQueryResultTest.java index d3bc835aea5ae..89d4ecd50f289 100644 --- a/infra/executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/execute/result/query/impl/driver/jdbc/type/stream/JDBCStreamQueryResultTest.java +++ b/infra/executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/execute/result/query/impl/driver/jdbc/type/stream/JDBCStreamQueryResultTest.java @@ -266,6 +266,14 @@ void assertGetResultSet() throws SQLException { assertTrue(actual.wasNull()); } + @Test + void assertClose() throws SQLException { + ResultSet resultSet = getResultSet(); + JDBCStreamQueryResult queryResult = new JDBCStreamQueryResult(resultSet); + queryResult.close(); + verify(resultSet).close(); + } + private ResultSet getResultSet() throws SQLException { ResultSet result = mock(ResultSet.class); when(result.next()).thenReturn(true).thenReturn(false);