pvary commented on code in PR #17873:
URL: https://github.com/apache/iceberg/pull/17873#discussion_r4014174620
##########
flink/v2.3/flink/src/test/java/org/apache/iceberg/flink/TestFlinkCatalogView.java:
##########
@@ -333,6 +334,203 @@ public void testViewWithMatchingDefaultsIsReadable() {
assertSameElements(expectedRows(), sql("SELECT * FROM %s", VIEW_NAME));
}
+ @TestTemplate
+ public void testCreateViewViaSql() {
+ sql("CREATE VIEW %s AS SELECT id, data FROM %s", VIEW_NAME, TABLE_NAME);
+
+ assertSameElements(expectedRows(), sql("SELECT * FROM %s", VIEW_NAME));
+
+ View view = viewCatalog().loadView(TableIdentifier.of(icebergNamespace,
VIEW_NAME));
+ // the expanded query is stored: every reference is fully qualified, so
resolution does not
+ // depend on the reader's session
+ assertThat(view.sqlFor("flink").sql())
+ .containsIgnoringCase(
+ String.format("FROM `%s`.`%s`.`%s`", catalogName, DATABASE,
TABLE_NAME));
+
assertThat(view.currentVersion().defaultNamespace()).isEqualTo(icebergNamespace);
+ assertThat(view.currentVersion().defaultCatalog()).isNull();
+ assertThat(view.schema().columns())
+ .extracting(Types.NestedField::name)
+ .containsExactly("id", "data");
+ }
+
+ @TestTemplate
+ public void testCreateViewWithCommentAndColumnList() {
+ sql(
+ "CREATE VIEW %s (view_id, view_data) COMMENT 'a view comment' AS
SELECT id, data FROM %s",
+ VIEW_NAME, TABLE_NAME);
+
+ View view = viewCatalog().loadView(TableIdentifier.of(icebergNamespace,
VIEW_NAME));
+ assertThat(view.properties()).containsEntry(ViewProperties.COMMENT, "a
view comment");
+ assertThat(view.schema().columns())
+ .extracting(Types.NestedField::name)
+ .containsExactly("view_id", "view_data");
+ }
+
+ @TestTemplate
+ public void testCreateViewIfNotExists() {
+ sql("CREATE VIEW %s AS SELECT id, data FROM %s", VIEW_NAME, TABLE_NAME);
+ // IF NOT EXISTS is silent
+ sql("CREATE VIEW IF NOT EXISTS %s AS SELECT id FROM %s", VIEW_NAME,
TABLE_NAME);
+ // the view was not replaced: it still exists with its original query
+ View view = viewCatalog().loadView(TableIdentifier.of(icebergNamespace,
VIEW_NAME));
+ assertThat(view.sqlFor("flink").sql()).containsIgnoringCase("data");
+
+ // without IF NOT EXISTS, creation fails
+ assertThatThrownBy(() -> sql("CREATE VIEW %s AS SELECT id FROM %s",
VIEW_NAME, TABLE_NAME))
+ .hasMessageContaining("Could not execute CreateTable")
+ .cause()
+ .isInstanceOf(TableAlreadyExistException.class)
+ .hasMessageContaining(VIEW_NAME);
+ }
+
+ @TestTemplate
+ public void testCreateViewOverExistingTableFails() {
+ assertThatThrownBy(() -> sql("CREATE VIEW %s AS SELECT id FROM %s",
TABLE_NAME, TABLE_NAME))
+ .hasMessageContaining("Could not execute CreateTable")
+ .cause()
+ .isInstanceOf(TableAlreadyExistException.class)
+ .hasMessageContaining(TABLE_NAME);
+
+ // the table was not touched by the failed attempt
+ assertSameElements(expectedRows(), sql("SELECT * FROM %s", TABLE_NAME));
+ }
+
+ @TestTemplate
+ public void testCreateViewWithUnqualifiedCrossDatabaseReference() {
+ // the stored expanded query fully qualifies the reference at creation
time, so the view
+ // resolves against the table the creator saw, regardless of the reader's
session database
+ sql("CREATE DATABASE %s.db2", catalogName);
+ sql("USE db2");
+ try {
+ sql("CREATE TABLE cross_t (id BIGINT)");
+ sql("INSERT INTO cross_t VALUES (7)");
+ sql("CREATE VIEW %s.%s.cross_view AS SELECT id FROM cross_t",
catalogName, DATABASE);
+
+ assertSameElements(
+ Lists.newArrayList(Row.of(7L)),
+ sql("SELECT * FROM %s.%s.cross_view", catalogName, DATABASE));
+
+ // reading from the view's own database, where an unqualified cross_t
would not resolve
+ sql("USE %s", DATABASE);
+ assertSameElements(Lists.newArrayList(Row.of(7L)), sql("SELECT * FROM
cross_view"));
+ } finally {
+ sql("USE %s", DATABASE);
+ sql("DROP TABLE IF EXISTS %s.db2.cross_t", catalogName);
+ dropDatabase(catalogName + ".db2", true);
+ }
+ }
+
+ @TestTemplate
+ public void testCreateViewWithQualifiedCrossDatabaseReference() {
+ // explicitly qualified references are deterministic and remain allowed
Review Comment:
Is this still true?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
