2020import java .util .ArrayList ;
2121import java .util .List ;
2222import java .util .Properties ;
23+ import java .util .concurrent .TimeUnit ;
24+ import java .util .logging .Logger ;
2325import javax .annotation .Nullable ;
2426import net .snowflake .client .annotations .DontRunOnGithubActions ;
2527import net .snowflake .client .category .TestTags ;
2628import net .snowflake .client .providers .SimpleResultFormatProvider ;
29+ import org .apache .commons .lang3 .time .StopWatch ;
2730import org .junit .jupiter .api .Disabled ;
2831import org .junit .jupiter .api .Tag ;
2932import org .junit .jupiter .api .Test ;
3437/** SnowflakeResultSetSerializable tests */
3538@ Tag (TestTags .RESULT_SET )
3639public class SnowflakeResultSetSerializableIT extends BaseJDBCTest {
40+ private static Logger logger = Logger .getLogger (HeartbeatAsyncLatestIT .class .getName ());
41+
3742 @ TempDir private File tmpFolder ;
3843
39- private static boolean developPrint = false ;
44+ private static boolean developPrint = true ;
4045
4146 // sfFullURL is used to support private link URL.
4247 // This test case is not for private link env, so just use a valid URL for testing purpose.
@@ -240,8 +245,11 @@ private void testBasicTableHarness(
240245 throws Throwable {
241246 List <String > fileNameList = null ;
242247 String originalResultCSVString = null ;
248+ StopWatch stopwatch = new StopWatch ();
249+ stopwatch .start ();
243250 try (Connection connection = init (queryResultFormat )) {
244251 Statement statement = connection .createStatement ();
252+ logger .severe (stopwatch .getTime (TimeUnit .SECONDS ) + " ms: testBasicTableHarness start" );
245253
246254 if (developPrint ) {
247255 System .out .println (
@@ -261,6 +269,9 @@ private void testBasicTableHarness(
261269 statement .execute (
262270 "create or replace table table_basic " + " (int_c int, string_c string(128))" );
263271
272+ logger .severe (
273+ stopwatch .getTime (TimeUnit .SECONDS )
274+ + " ms: testBasicTableHarness before insert into table_basic" );
264275 if (rowCount > 0 ) {
265276 statement .execute (
266277 "insert into table_basic select "
@@ -269,6 +280,9 @@ private void testBasicTableHarness(
269280 + rowCount
270281 + "))" );
271282 }
283+ logger .severe (
284+ stopwatch .getTime (TimeUnit .SECONDS )
285+ + " ms: testBasicTableHarness after insert into table_basic" );
272286 }
273287
274288 String sqlSelect = "select * from table_basic " + whereClause ;
@@ -277,14 +291,28 @@ private void testBasicTableHarness(
277291 ? statement .unwrap (SnowflakeStatement .class ).executeAsyncQuery (sqlSelect )
278292 : statement .executeQuery (sqlSelect )) {
279293
294+ logger .severe (
295+ stopwatch .getTime (TimeUnit .SECONDS ) + " ms: testBasicTableHarness after select query" );
280296 fileNameList = serializeResultSet ((SnowflakeResultSet ) rs , maxSizeInBytes , "txt" );
297+ logger .severe (
298+ stopwatch .getTime (TimeUnit .SECONDS )
299+ + " ms: testBasicTableHarness after serializeResultSet" );
281300
282301 originalResultCSVString = generateCSVResult (rs );
302+ logger .severe (
303+ stopwatch .getTime (TimeUnit .SECONDS )
304+ + " ms: testBasicTableHarness after generateCSVResult" );
283305 }
284306 }
285307
286308 String chunkResultString = deserializeResultSet (fileNameList );
309+ logger .severe (
310+ stopwatch .getTime (TimeUnit .SECONDS )
311+ + " ms: testBasicTableHarness after deserializeResultSet" );
287312 assertEquals (chunkResultString , originalResultCSVString );
313+ logger .severe (
314+ stopwatch .getTime (TimeUnit .SECONDS )
315+ + " ms: testBasicTableHarness after deserializeResultSet" );
288316 }
289317
290318 @ ParameterizedTest
0 commit comments