Skip to content

Commit 090150a

Browse files
committed
test(bigquery): use UNNEST and maxResults to make testFastSQLQueryMultiPage hermetic and fast
1 parent fb49fb8 commit 090150a

1 file changed

Lines changed: 18 additions & 11 deletions

File tree

  • java-bigquery/google-cloud-bigquery/src/test/java/com/google/cloud/bigquery/it

java-bigquery/google-cloud-bigquery/src/test/java/com/google/cloud/bigquery/it/ITBigQueryTest.java

Lines changed: 18 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -4826,32 +4826,39 @@ void testLocationFastSQLQueryWithJobId() throws InterruptedException {
48264826
/* TODO(prasmish): replicate the entire test case for executeSelect */
48274827
@Test
48284828
void testFastSQLQueryMultiPage() throws InterruptedException {
4829-
String query =
4830-
"SELECT date, county, state_name, county_fips_code, confirmed_cases, deaths FROM "
4831-
+ TABLE_ID_LARGE.getTable();
4829+
String query = "SELECT * FROM UNNEST(GENERATE_ARRAY(1, 1005)) as num";
48324830
QueryJobConfiguration config =
4833-
QueryJobConfiguration.newBuilder(query).setDefaultDataset(DatasetId.of(DATASET)).build();
4831+
QueryJobConfiguration.newBuilder(query)
4832+
.setDefaultDataset(DatasetId.of(DATASET))
4833+
.setMaxResults(1000L)
4834+
.build();
48344835
TableResult result = bigquery.query(config);
48354836
assertNotNull(result.getJobId());
4836-
assertEquals(LARGE_TABLE_SCHEMA, result.getSchema());
4837-
assertEquals(313348, result.getTotalRows());
4837+
assertEquals(1, result.getSchema().getFields().size());
4838+
assertEquals("num", result.getSchema().getFields().get(0).getName());
4839+
assertEquals(LegacySQLTypeName.INTEGER, result.getSchema().getFields().get(0).getType());
4840+
assertEquals(1005, result.getTotalRows());
48384841
assertNotNull(result.getNextPage());
48394842
assertNotNull(result.getNextPageToken());
48404843
assertTrue(result.hasNextPage());
48414844

48424845
TableResult result1 = bigquery.query(config);
48434846
assertNotNull(result1.getJobId());
4844-
assertEquals(LARGE_TABLE_SCHEMA, result.getSchema());
4845-
assertEquals(313348, result.getTotalRows());
4847+
assertEquals(1, result1.getSchema().getFields().size());
4848+
assertEquals("num", result1.getSchema().getFields().get(0).getName());
4849+
assertEquals(LegacySQLTypeName.INTEGER, result1.getSchema().getFields().get(0).getType());
4850+
assertEquals(1005, result1.getTotalRows());
48464851
assertNotNull(result1.getNextPage());
48474852
assertNotNull(result1.getNextPageToken());
48484853
assertTrue(result1.hasNextPage());
48494854

4850-
config.toBuilder().setQuery(query).build();
4855+
config = config.toBuilder().setQuery(query).build();
48514856
TableResult result2 = bigquery.query(config);
48524857
assertNotNull(result2.getJobId());
4853-
assertEquals(LARGE_TABLE_SCHEMA, result2.getSchema());
4854-
assertEquals(313348, result2.getTotalRows());
4858+
assertEquals(1, result2.getSchema().getFields().size());
4859+
assertEquals("num", result2.getSchema().getFields().get(0).getName());
4860+
assertEquals(LegacySQLTypeName.INTEGER, result2.getSchema().getFields().get(0).getType());
4861+
assertEquals(1005, result2.getTotalRows());
48554862
assertNotNull(result2.getNextPage());
48564863
assertNotNull(result2.getNextPageToken());
48574864
assertTrue(result2.hasNextPage());

0 commit comments

Comments
 (0)