[FLINK-39302][table] Support SHOW CREATE OR ALTER MATERIALIZED TABLE

snuyanzin · web-flow · commit 8b716346099d · 2026-03-31T18:37:38.000+02:00
diff --git a/docs/content.zh/docs/sql/reference/utility/show.md b/docs/content.zh/docs/sql/reference/utility/show.md
@@ -41,7 +41,7 @@ SHOW CREATE 语句用于打印给定对象的创建 DDL 语句。当前的 SHOW
 - SHOW TABLES
 - SHOW CREATE TABLE
 - SHOW MATERIALIZED TABLES
-- SHOW CREATE MATERIALIZED TABLE
+- SHOW CREATE [OR ALTER ]MATERIALIZED TABLE
 - SHOW COLUMNS
 - SHOW PARTITIONS
 - SHOW PROCEDURES
@@ -993,14 +993,20 @@ The syntax of sql pattern in `LIKE` clause is the same as that of `MySQL` dialec
 * `%` matches any number of characters, including zero characters, `\%` matches one `%` character.
 * `_` matches exactly one character, `\_` matches one `_` character.
 
-## SHOW CREATE MATERIALIZED TABLE
+## SHOW CREATE [OR ALTER ]MATERIALIZED TABLE
 
 ```sql
 SHOW CREATE MATERIALIZED TABLE [catalog_name.][db_name.]materialized_table_name
 ```
 
 Show create materialized table statement for specified materialized table.
 
+```sql
+SHOW CREATE OR ALTER MATERIALIZED TABLE [catalog_name.][db_name.]materialized_table_name
+```
+
+Show create or alter materialized table statement for specified materialized table.
+
 展示创建指定视图的 create 语句。
 
 ## SHOW FUNCTIONS
diff --git a/docs/content/docs/sql/reference/utility/show.md b/docs/content/docs/sql/reference/utility/show.md
@@ -45,7 +45,7 @@ Flink SQL supports the following SHOW statements for now:
 - SHOW VIEWS
 - SHOW CREATE VIEW
 - SHOW MATERIALIZED TABLES
-- SHOW CREATE MATERIALIZED TABLE
+- SHOW CREATE [OR ALTER ]MATERIALIZED TABLE
 - SHOW FUNCTIONS
 - SHOW MODULES
 - SHOW JARS
@@ -1004,14 +1004,20 @@ The syntax of sql pattern in `LIKE` clause is the same as that of `MySQL` dialec
 * `%` matches any number of characters, including zero characters, `\%` matches one `%` character.
 * `_` matches exactly one character, `\_` matches one `_` character.
 
-## SHOW CREATE MATERIALIZED TABLE
+## SHOW CREATE [OR ALTER ]MATERIALIZED TABLE
 
 ```sql
 SHOW CREATE MATERIALIZED TABLE [catalog_name.][db_name.]materialized_table_name
 ```
 
 Show create materialized table statement for specified materialized table.
 
+```sql
+SHOW CREATE OR ALTER MATERIALIZED TABLE [catalog_name.][db_name.]materialized_table_name
+```
+
+Show create or alter materialized table statement for specified materialized table.
+
 ## SHOW FUNCTIONS
 
 ```sql
diff --git a/flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl b/flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl
@@ -792,11 +792,13 @@ SqlShowCreate SqlShowCreate() :
             return new SqlShowCreateConnection(pos, sqlIdentifier);
         }
     |
+        {boolean createOrAlter = false;}
+        [ <OR> <ALTER> {createOrAlter = true;} ]
         <MATERIALIZED> <TABLE>
         { pos = getPos(); }
         sqlIdentifier = CompoundIdentifier()
         {
-            return new SqlShowCreateMaterializedTable(pos, sqlIdentifier);
+            return new SqlShowCreateMaterializedTable(pos, sqlIdentifier, createOrAlter);
         }
     )
 }
diff --git a/flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowCreateMaterializedTable.java b/flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowCreateMaterializedTable.java
@@ -29,13 +29,20 @@
 import java.util.Collections;
 import java.util.List;
 
-/** SHOW CREATE MATERIALIZED TABLE sql call. */
+/** SHOW CREATE [OR ALTER ]MATERIALIZED TABLE sql call. */
 public class SqlShowCreateMaterializedTable extends SqlShowCreate {
-    public static final SqlSpecialOperator OPERATOR =
+    private static final SqlSpecialOperator SHOW_CREATE_OPERATOR =
             new SqlSpecialOperator("SHOW CREATE MATERIALIZED TABLE", SqlKind.OTHER_DDL);
 
-    public SqlShowCreateMaterializedTable(SqlParserPos pos, SqlIdentifier sqlIdentifier) {
+    private static final SqlSpecialOperator SHOW_CREATE_OR_ALTER_OPERATOR =
+            new SqlSpecialOperator("SHOW CREATE OR ALTER MATERIALIZED TABLE", SqlKind.OTHER_DDL);
+
+    private final boolean createOrAlter;
+
+    public SqlShowCreateMaterializedTable(
+            SqlParserPos pos, SqlIdentifier sqlIdentifier, boolean createOrAlter) {
         super(pos, sqlIdentifier);
+        this.createOrAlter = createOrAlter;
     }
 
     public SqlIdentifier getMaterializedTableName() {
@@ -48,17 +55,21 @@ public String[] getFullMaterializedTableName() {
 
     @Override
     public SqlOperator getOperator() {
-        return OPERATOR;
+        return createOrAlter ? SHOW_CREATE_OR_ALTER_OPERATOR : SHOW_CREATE_OPERATOR;
     }
 
     @Override
     public List<SqlNode> getOperandList() {
         return Collections.singletonList(sqlIdentifier);
     }
 
+    public boolean isCreateOrAlter() {
+        return createOrAlter;
+    }
+
     @Override
     public void unparse(SqlWriter writer, int leftPrec, int rightPrec) {
-        writer.keyword(OPERATOR.getName());
+        writer.keyword(getOperator().getName());
         sqlIdentifier.unparse(writer, leftPrec, rightPrec);
     }
 }
diff --git a/flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/MaterializedTableStatementParserTest.java b/flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/MaterializedTableStatementParserTest.java
@@ -741,6 +741,22 @@ void testStartMode() {
                                 + "    ");
     }
 
+    @Test
+    void testShowCreateOrAlterMaterializedTable() {
+        sql("show create materialized table mt1").ok("SHOW CREATE MATERIALIZED TABLE `MT1`");
+        sql("show create materialized table db1.mt1")
+                .ok("SHOW CREATE MATERIALIZED TABLE `DB1`.`MT1`");
+        sql("show create materialized table catalog1.db1.mt1")
+                .ok("SHOW CREATE MATERIALIZED TABLE `CATALOG1`.`DB1`.`MT1`");
+
+        sql("show create or alter materialized table mt1")
+                .ok("SHOW CREATE OR ALTER MATERIALIZED TABLE `MT1`");
+        sql("show create or alter materialized table db1.mt1")
+                .ok("SHOW CREATE OR ALTER MATERIALIZED TABLE `DB1`.`MT1`");
+        sql("show create or alter materialized table catalog1.db1.mt1")
+                .ok("SHOW CREATE OR ALTER MATERIALIZED TABLE `CATALOG1`.`DB1`.`MT1`");
+    }
+
     public SqlParserFixture fixture() {
         return SqlParserFixture.DEFAULT.withConfig(
                 c -> c.withParserFactory(FlinkSqlParserImpl.FACTORY));
diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/ShowCreateUtil.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/ShowCreateUtil.java
@@ -61,7 +61,7 @@ public static String buildShowCreateModelRow(
                 new StringBuilder()
                         .append(
                                 buildCreateFormattedPrefix(
-                                        "MODEL", isTemporary, modelIdentifier, false));
+                                        "MODEL", isTemporary, modelIdentifier, false, false));
         extractFormattedColumns(model.getResolvedInputSchema())
                 .ifPresent(
                         c -> sb.append(String.format("INPUT (%s)%s", c, System.lineSeparator())));
@@ -93,7 +93,7 @@ public static String buildShowCreateTableRow(
                 new StringBuilder()
                         .append(
                                 buildCreateFormattedPrefix(
-                                        "TABLE", isTemporary, tableIdentifier, true));
+                                        "TABLE", isTemporary, tableIdentifier, false, true));
         sb.append(extractFormattedColumns(table, PRINT_INDENT));
         extractFormattedWatermarkSpecs(table, PRINT_INDENT, sqlFactory)
                 .ifPresent(watermarkSpecs -> sb.append(",\n").append(watermarkSpecs));
@@ -117,13 +117,18 @@ public static String buildShowCreateMaterializedTableRow(
             ResolvedCatalogMaterializedTable table,
             ObjectIdentifier tableIdentifier,
             boolean isTemporary,
+            boolean createOrAlter,
             SqlFactory sqlFactory) {
         validateTableKind(table, tableIdentifier, TableKind.MATERIALIZED_TABLE);
         StringBuilder sb =
                 new StringBuilder()
                         .append(
                                 buildCreateFormattedPrefix(
-                                        "MATERIALIZED TABLE", isTemporary, tableIdentifier, true));
+                                        "MATERIALIZED TABLE",
+                                        isTemporary,
+                                        tableIdentifier,
+                                        createOrAlter,
+                                        true));
         sb.append(extractFormattedColumns(table, PRINT_INDENT));
         extractFormattedWatermarkSpecs(table, PRINT_INDENT, sqlFactory)
                 .ifPresent(watermarkSpecs -> sb.append(",\n").append(watermarkSpecs));
@@ -162,7 +167,7 @@ public static String buildShowCreateViewRow(
                 new StringBuilder()
                         .append(
                                 buildCreateFormattedPrefix(
-                                        "VIEW", isTemporary, viewIdentifier, true));
+                                        "VIEW", isTemporary, viewIdentifier, false, true));
         sb.append(extractFormattedColumnNames(view, PRINT_INDENT)).append("\n)\n");
         extractComment(view).ifPresent(c -> sb.append(formatComment(c)).append("\n"));
         sb.append("AS ").append(((CatalogView) origin).getExpandedQuery()).append("\n");
@@ -186,9 +191,11 @@ static String buildCreateFormattedPrefix(
             String type,
             boolean isTemporary,
             ObjectIdentifier identifier,
+            boolean createOrAlter,
             boolean openParenthesis) {
         return String.format(
-                "CREATE %s%s %s%s%s",
+                "CREATE %s%s%s %s%s%s",
+                createOrAlter ? "OR ALTER " : "",
                 isTemporary ? "TEMPORARY " : "",
                 type,
                 identifier.asSerializableString(),
diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowCreateMaterializedTableOperation.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowCreateMaterializedTableOperation.java
@@ -27,19 +27,23 @@
 
 import static org.apache.flink.table.api.internal.TableResultUtils.buildStringArrayResult;
 
-/** Operation to describe a SHOW CREATE MATERIALIZED TABLE statement. */
+/** Operation to describe a SHOW CREATE [OR ALTER ]MATERIALIZED TABLE statement. */
 @Internal
 public class ShowCreateMaterializedTableOperation implements ShowOperation {
     private final ObjectIdentifier tableIdentifier;
+    private final boolean createOrAlter;
 
-    public ShowCreateMaterializedTableOperation(ObjectIdentifier sqlIdentifier) {
+    public ShowCreateMaterializedTableOperation(
+            ObjectIdentifier sqlIdentifier, boolean createOrAlter) {
         this.tableIdentifier = sqlIdentifier;
+        this.createOrAlter = createOrAlter;
     }
 
     @Override
     public String asSummaryString() {
         return String.format(
-                "SHOW CREATE MATERIALIZED TABLE %s", tableIdentifier.asSummaryString());
+                "SHOW CREATE %sMATERIALIZED TABLE %s",
+                createOrAlter ? "OR ALTER " : "", tableIdentifier.asSummaryString());
     }
 
     @Override
@@ -51,13 +55,15 @@ public TableResultInternal execute(Context ctx) {
                                 () ->
                                         new ValidationException(
                                                 String.format(
-                                                        "Could not execute SHOW CREATE MATERIALIZED TABLE. Materialized table with identifier %s does not exist.",
+                                                        "Could not execute %s. Materialized table with identifier %s does not exist.",
+                                                        asSummaryString(),
                                                         tableIdentifier.asSerializableString())));
         String resultRow =
                 ShowCreateUtil.buildShowCreateMaterializedTableRow(
                         table.getResolvedTable(),
                         tableIdentifier,
                         table.isTemporary(),
+                        createOrAlter,
                         ctx.getCatalogManager().getSqlFactory());
 
         return buildStringArrayResult("result", new String[] {resultRow});
diff --git a/flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/internal/ShowCreateUtilTest.java b/flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/internal/ShowCreateUtilTest.java
diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/SqlNodeToOperationConversion.java b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/SqlNodeToOperationConversion.java

Original file line number	Diff line number	Diff line change
`@@ -792,11 +792,13 @@ SqlShowCreate SqlShowCreate() :`
`792`	`792`	`return new SqlShowCreateConnection(pos, sqlIdentifier);`
`793`	`793`	`}`
`794`	`794`	`\|`
	`795`	`+ {boolean createOrAlter = false;}`
	`796`	`+ [ <OR> <ALTER> {createOrAlter = true;} ]`
`795`	`797`	`<MATERIALIZED> <TABLE>`
`796`	`798`	`{ pos = getPos(); }`
`797`	`799`	`sqlIdentifier = CompoundIdentifier()`
`798`	`800`	`{`
`799`		`- return new SqlShowCreateMaterializedTable(pos, sqlIdentifier);`
	`801`	`+ return new SqlShowCreateMaterializedTable(pos, sqlIdentifier, createOrAlter);`
`800`	`802`	`}`
`801`	`803`	`)`
`802`	`804`	`}`