@@ -4827,34 +4827,32 @@ void testLocationFastSQLQueryWithJobId() throws InterruptedException {
48274827 @ Test
48284828 void testFastSQLQueryMultiPage () throws InterruptedException {
48294829 String query =
4830- "SELECT date, county, state_name, county_fips_code, confirmed_cases, deaths FROM "
4831- + TABLE_ID_LARGE .getTable ();
4830+ "SELECT TimestampField, StringField, BooleanField FROM " + TABLE_ID_FAST_QUERY .getTable ();
48324831 QueryJobConfiguration config =
4833- QueryJobConfiguration .newBuilder (query ).setDefaultDataset (DatasetId .of (DATASET )).build ();
4832+ QueryJobConfiguration .newBuilder (query )
4833+ .setDefaultDataset (DatasetId .of (DATASET ))
4834+ .setMaxResults (1L )
4835+ .build ();
4836+
4837+ java .util .function .Consumer <TableResult > assertResult =
4838+ r -> {
4839+ assertNotNull (r .getJobId ());
4840+ assertEquals (QUERY_RESULT_SCHEMA , r .getSchema ());
4841+ assertEquals (2 , r .getTotalRows ());
4842+ assertNotNull (r .getNextPage ());
4843+ assertNotNull (r .getNextPageToken ());
4844+ assertTrue (r .hasNextPage ());
4845+ };
4846+
48344847 TableResult result = bigquery .query (config );
4835- assertNotNull (result .getJobId ());
4836- assertEquals (LARGE_TABLE_SCHEMA , result .getSchema ());
4837- assertEquals (313348 , result .getTotalRows ());
4838- assertNotNull (result .getNextPage ());
4839- assertNotNull (result .getNextPageToken ());
4840- assertTrue (result .hasNextPage ());
4848+ assertResult .accept (result );
48414849
48424850 TableResult result1 = bigquery .query (config );
4843- assertNotNull (result1 .getJobId ());
4844- assertEquals (LARGE_TABLE_SCHEMA , result .getSchema ());
4845- assertEquals (313348 , result .getTotalRows ());
4846- assertNotNull (result1 .getNextPage ());
4847- assertNotNull (result1 .getNextPageToken ());
4848- assertTrue (result1 .hasNextPage ());
4851+ assertResult .accept (result1 );
48494852
4850- config .toBuilder ().setQuery (query ).build ();
4853+ config = config .toBuilder ().setQuery (query ).build ();
48514854 TableResult result2 = bigquery .query (config );
4852- assertNotNull (result2 .getJobId ());
4853- assertEquals (LARGE_TABLE_SCHEMA , result2 .getSchema ());
4854- assertEquals (313348 , result2 .getTotalRows ());
4855- assertNotNull (result2 .getNextPage ());
4856- assertNotNull (result2 .getNextPageToken ());
4857- assertTrue (result2 .hasNextPage ());
4855+ assertResult .accept (result2 );
48584856 }
48594857
48604858 @ Test
0 commit comments