From 58ac7acaff589a075baf206aca0779d0cc554569 Mon Sep 17 00:00:00 2001 From: Russell Spitzer Date: Tue, 30 Jul 2024 16:27:58 -0500 Subject: [PATCH] Adds failing Create View Spark Integration Test --- .../catalog/PolarisSparkIntegrationTest.java | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/polaris-service/src/test/java/io/polaris/service/catalog/PolarisSparkIntegrationTest.java b/polaris-service/src/test/java/io/polaris/service/catalog/PolarisSparkIntegrationTest.java index 4dc4162a9f..11401c7e36 100644 --- a/polaris-service/src/test/java/io/polaris/service/catalog/PolarisSparkIntegrationTest.java +++ b/polaris-service/src/test/java/io/polaris/service/catalog/PolarisSparkIntegrationTest.java @@ -251,6 +251,22 @@ public void testCreateTable() { assertThat(recordCount).isEqualTo(3); } + @Test + public void testCreateViewTable() { + long namespaceCount = spark.sql("SHOW NAMESPACES").count(); + assertThat(namespaceCount).isEqualTo(0L); + + spark.sql("CREATE NAMESPACE ns1"); + spark.sql("USE ns1"); + spark.sql("CREATE TABLE tb1 (col1 integer, col2 string)"); + spark.sql("INSERT INTO tb1 VALUES (1, 'a'), (2, 'b'), (3, 'c')"); + long recordCount = spark.sql("SELECT * FROM tb1").count(); + assertThat(recordCount).isEqualTo(3); + + spark.sql("CREATE VIEW v1 AS SELECT MAX(col1) FROM tb1"); + spark.sql("SELECT * FROM v1"); + } + @Test public void testCreateAndUpdateExternalTable() { long namespaceCount = spark.sql("SHOW NAMESPACES").count();