Skip to content

Commit 152abe9

Browse files
committed
Add test for aggregating BigQuery view more than once
1 parent 54beed2 commit 152abe9

File tree

1 file changed

+20
-0
lines changed

1 file changed

+20
-0
lines changed

plugin/trino-bigquery/src/test/java/io/trino/plugin/bigquery/TestBigQueryIntegrationSmokeTest.java

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
import static io.trino.spi.type.VarcharType.VARCHAR;
2929
import static io.trino.testing.MaterializedResult.resultBuilder;
3030
import static io.trino.testing.assertions.Assert.assertEquals;
31+
import static io.trino.testing.sql.TestTable.randomTableSuffix;
3132
import static java.lang.String.format;
3233
import static org.assertj.core.api.Assertions.assertThat;
3334

@@ -133,6 +134,25 @@ public void testCountAggregationView()
133134
"VALUES (1)");
134135
}
135136

137+
/**
138+
* regression test for https://github.com/trinodb/trino/issues/6696
139+
*/
140+
@Test
141+
public void testRepeatCountAggregationView()
142+
{
143+
BigQuery client = createBigQueryClient();
144+
145+
String viewName = "test.repeat_count_aggregation_view_" + randomTableSuffix();
146+
147+
executeBigQuerySql(client, "DROP VIEW IF EXISTS " + viewName);
148+
executeBigQuerySql(client, "CREATE VIEW " + viewName + " AS SELECT 1 AS col1");
149+
150+
assertQuery("SELECT count(*) FROM " + viewName, "VALUES (1)");
151+
assertQuery("SELECT count(*) FROM " + viewName, "VALUES (1)");
152+
153+
executeBigQuerySql(client, "DROP VIEW " + viewName);
154+
}
155+
136156
private static void executeBigQuerySql(BigQuery bigquery, String query)
137157
{
138158
QueryJobConfiguration queryConfig = QueryJobConfiguration.newBuilder(query)

0 commit comments

Comments
 (0)