@@ -37,19 +37,20 @@ public void testChunkDownloaderRetry() throws SQLException, InterruptedException
37
37
38
38
SnowflakeChunkDownloader snowflakeChunkDownloaderSpy = null ;
39
39
40
- try (Connection connection = getConnection (properties )) {
41
- Statement statement = connection .createStatement ();
40
+ try (Connection connection = getConnection (properties );
41
+ Statement statement = connection .createStatement ()) {
42
42
// execute a query that will require chunk downloading
43
- ResultSet resultSet =
43
+ try ( ResultSet resultSet =
44
44
statement .executeQuery (
45
- "select seq8(), randstr(1000, random()) from table(generator(rowcount => 10000))" );
46
- List <SnowflakeResultSetSerializable > resultSetSerializables =
47
- ((SnowflakeResultSet ) resultSet ).getResultSetSerializables (100 * 1024 * 1024 );
48
- SnowflakeResultSetSerializable resultSetSerializable = resultSetSerializables .get (0 );
49
- SnowflakeChunkDownloader downloader =
50
- new SnowflakeChunkDownloader ((SnowflakeResultSetSerializableV1 ) resultSetSerializable );
51
- snowflakeChunkDownloaderSpy = Mockito .spy (downloader );
52
- snowflakeChunkDownloaderSpy .getNextChunkToConsume ();
45
+ "select seq8(), randstr(1000, random()) from table(generator(rowcount => 10000))" )) {
46
+ List <SnowflakeResultSetSerializable > resultSetSerializables =
47
+ ((SnowflakeResultSet ) resultSet ).getResultSetSerializables (100 * 1024 * 1024 );
48
+ SnowflakeResultSetSerializable resultSetSerializable = resultSetSerializables .get (0 );
49
+ SnowflakeChunkDownloader downloader =
50
+ new SnowflakeChunkDownloader ((SnowflakeResultSetSerializableV1 ) resultSetSerializable );
51
+ snowflakeChunkDownloaderSpy = Mockito .spy (downloader );
52
+ snowflakeChunkDownloaderSpy .getNextChunkToConsume ();
53
+ }
53
54
} catch (SnowflakeSQLException exception ) {
54
55
// verify that request was retried twice before reaching max retries
55
56
Mockito .verify (snowflakeChunkDownloaderSpy , Mockito .times (2 )).getResultStreamProvider ();
0 commit comments