fix(relations): Ensure materialized view access method is restored

On Cloudberry, Greenplum 7+, materialized views must be created with
a specific access method (e.g., 'heap', 'ao_row') and associated storage
options in the 'WITH' clause (e.g., 'compresstype=zstd').

The prior implementation did not back up the 'USING' clause.
During restore, the database would default to another access method
(e.g., 'heap') which might not support the view's storage options.
This incompatibility caused the 'CREATE MATERIALIZED VIEW' command
to fail validation.

This commit corrects the failure by:
- Updating the view query for Cloudberry, GPDB 7+ to fetch the access method.
- Modifying DDL generation to include the 'USING' clause.
- Updating integration tests to verify the fix.

Author: robertmu

integration/predata_relations_create_test.go

@@ -550,6 +550,9 @@ SET SUBPARTITION TEMPLATE ` + `
 		})
 		It("creates a view with privileges, owner, security label, and comment", func() {
 			view := builtin.View{Oid: 1, Schema: "public", Name: "simplemview", Definition: sql.NullString{String: " SELECT 1 AS a;", Valid: true}, IsMaterialized: true, DistPolicy: "DISTRIBUTED BY (a)"}
+			if (connectionPool.Version.IsGPDB() && connectionPool.Version.AtLeast("7")) || connectionPool.Version.IsCBDBFamily() {
+				view.AccessMethodName = "heap"
+			}
 			viewMetadata := testutils.DefaultMetadata("MATERIALIZED VIEW", true, true, true, includeSecurityLabels)
 
 			builtin.PrintCreateViewStatement(backupfile, tocfile, view, viewMetadata)
@@ -568,7 +571,9 @@ SET SUBPARTITION TEMPLATE ` + `
 		})
 		It("creates a materialized view with options", func() {
 			view := builtin.View{Oid: 1, Schema: "public", Name: "simplemview", Options: " WITH (fillfactor=10)", Definition: sql.NullString{String: " SELECT 1 AS a;", Valid: true}, IsMaterialized: true, DistPolicy: "DISTRIBUTED BY (a)"}
-
+			if (connectionPool.Version.IsGPDB() && connectionPool.Version.AtLeast("7")) || connectionPool.Version.IsCBDBFamily() {
+				view.AccessMethodName = "heap"
+			}
 			builtin.PrintCreateViewStatement(backupfile, tocfile, view, builtin.ObjectMetadata{})
 
 			testhelper.AssertQueryRuns(connectionPool, buffer.String())

integration/predata_relations_queries_test.go

@@ -501,6 +501,9 @@ var _ = Describe("cbcopy integration tests", func() {
 
 			results := builtin.GetAllViews(connectionPool)
 			materialView := builtin.View{Oid: 1, Schema: "public", Name: "simplematerialview", Definition: sql.NullString{String: " SELECT 1 AS a;", Valid: true}, IsMaterialized: true, DistPolicy: "DISTRIBUTED BY (a)"}
+			if (connectionPool.Version.IsGPDB() && connectionPool.Version.AtLeast("7")) || connectionPool.Version.IsCBDBFamily() {
+				materialView.AccessMethodName = "heap"
+			}
 
 			Expect(results).To(HaveLen(1))
 			structmatcher.ExpectStructsToMatchExcluding(&materialView, &results[0], "Oid")
@@ -514,6 +517,9 @@ var _ = Describe("cbcopy integration tests", func() {
 
 			results := builtin.GetAllViews(connectionPool)
 			materialView := builtin.View{Oid: 1, Schema: "public", Name: "simplematerialview", Definition: sql.NullString{String: " SELECT 1 AS a;", Valid: true}, Options: " WITH (fillfactor=50, autovacuum_enabled=false)", IsMaterialized: true, DistPolicy: "DISTRIBUTED BY (a)"}
+			if (connectionPool.Version.IsGPDB() && connectionPool.Version.AtLeast("7")) || connectionPool.Version.IsCBDBFamily() {
+				materialView.AccessMethodName = "heap"
+			}
 
 			Expect(results).To(HaveLen(1))
 			structmatcher.ExpectStructsToMatchExcluding(&materialView, &results[0], "Oid")
@@ -529,6 +535,9 @@ var _ = Describe("cbcopy integration tests", func() {
 
 			results := builtin.GetAllViews(connectionPool)
 			materialView := builtin.View{Oid: 1, Schema: "public", Name: "simplematerialview", Definition: sql.NullString{String: " SELECT 1 AS a;", Valid: true}, Tablespace: "test_tablespace", IsMaterialized: true, DistPolicy: "DISTRIBUTED BY (a)"}
+			if (connectionPool.Version.IsGPDB() && connectionPool.Version.AtLeast("7")) || connectionPool.Version.IsCBDBFamily() {
+				materialView.AccessMethodName = "heap"
+			}
 
 			Expect(results).To(HaveLen(1))
 			structmatcher.ExpectStructsToMatchExcluding(&materialView, &results[0], "Oid")

meta/builtin/predata_relations.go

@@ -682,8 +682,12 @@ func PrintCreateViewStatement(metadataFile *utils.FileWithByteCount, toc *toc.TO
 			viewOptions = transformViewOptions(viewOptions)
 		}
 
-		metadataFile.MustPrintf("\n\nCREATE MATERIALIZED VIEW %s%s%s AS %s\nWITH NO DATA\n%s;\n",
-			view.FQN(), viewOptions, tablespaceClause, view.Definition.String[:len(view.Definition.String)-1], view.DistPolicy)
+		accessMethodClause := ""
+		if view.AccessMethodName != "" {
+			accessMethodClause = fmt.Sprintf(" USING %s", view.AccessMethodName)
+		}
+		metadataFile.MustPrintf("\n\nCREATE MATERIALIZED VIEW %s%s%s%s AS %s\nWITH NO DATA\n%s;\n",
+			view.FQN(), accessMethodClause, viewOptions, tablespaceClause, view.Definition.String[:len(view.Definition.String)-1], view.DistPolicy)
 	}
 	section, entry := view.GetMetadataEntry()
 	toc.AddMetadataEntry(section, entry, start, metadataFile.ByteCount)

meta/builtin/queries_relations.go

@@ -458,7 +458,8 @@ type View struct {
 	Tablespace     string
 	IsMaterialized bool
 	// https://github.com/greenplum-db/gpbackup/commit/ea5977fc892735fbb9f41e1e0a4944e20e260077
-	DistPolicy string
+	DistPolicy       string
+	AccessMethodName string
 }
 
 func (v View) GetMetadataEntry() (string, toc.MetadataEntry) {
@@ -519,7 +520,7 @@ func GetAllViews(connectionPool *dbconn.DBConn) []View {
 
 	// Materialized views were introduced in GPDB 7 and backported to GPDB 6.2.
 	// Reloptions and tablespace added to pg_class in GPDB 6
-	atLeast6Query := fmt.Sprintf(`
+	version6Query := fmt.Sprintf(`
 	SELECT
 		c.oid AS oid,
 		quote_ident(n.nspname) AS schema,
@@ -535,11 +536,31 @@ func GetAllViews(connectionPool *dbconn.DBConn) []View {
 		AND %s
 		AND %s`, relationAndSchemaFilterClause(connectionPool), ExtensionFilterClause("c"))
 
+	atLeast7Query := fmt.Sprintf(`
+	SELECT
+		c.oid AS oid,
+		quote_ident(n.nspname) AS schema,
+		quote_ident(c.relname) AS name,
+		pg_get_viewdef(c.oid) AS definition,
+		coalesce(' WITH (' || array_to_string(c.reloptions, ', ') || ')', '') AS options,
+		coalesce(quote_ident(t.spcname), '') AS tablespace,
+		c.relkind='m' AS ismaterialized,
+		coalesce(quote_ident(am.amname), '') AS accessmethodname
+	FROM pg_class c
+		LEFT JOIN pg_namespace n ON n.oid = c.relnamespace
+		LEFT JOIN pg_tablespace t ON t.oid = c.reltablespace
+		LEFT JOIN pg_am am ON am.oid = c.relam
+	WHERE c.relkind IN ('m', 'v')
+		AND %s
+		AND %s`, relationAndSchemaFilterClause(connectionPool), ExtensionFilterClause("c"))
+
 	query := ""
 	if connectionPool.Version.IsGPDB() && connectionPool.Version.Before("6") {
 		query = before6Query
+	} else if connectionPool.Version.IsGPDB() && connectionPool.Version.Is("6") {
+		query = version6Query
 	} else {
-		query = atLeast6Query
+		query = atLeast7Query
 	}
 
 	gplog.Debug("GetAllViews, query is %v", query)