Maintain materialized view data status.

gpMgmt/bin/gpcheckcat

@@ -1283,6 +1283,10 @@ def checkTableMissingEntry(cat):
     if catname == "gp_segment_configuration":
         return
 
+    # Skip gp_matview_aux or gp_matview_tables
+    if catname == "gp_matview_aux" or catname == "gp_matview_tables":
+        return
+
     # skip shared/non-shared tables
     if GV.opt['-S']:
         if re.match("none", GV.opt['-S'], re.I) and isShared:
@@ -1533,6 +1537,10 @@ def checkTableInconsistentEntry(cat):
     if catname == "gp_segment_configuration" or catname == "pg_appendonly":
         return
 
+    # Skip gp_matview_aux or gp_matview_tables
+    if catname == "gp_matview_aux" or catname == "gp_matview_tables":
+        return
+
     # skip shared/non-shared tables
     if GV.opt['-S']:
         if re.match("none", GV.opt['-S'], re.I) and isShared:

gpMgmt/bin/gppylib/gpcatalog.py

@@ -33,7 +33,9 @@ class GPCatalogException(Exception):
     'pg_statistic_ext',
     'pg_statistic_ext_data',
     'gp_partition_template', # GPDB_12_MERGE_FIXME: is gp_partition_template intentionally missing from segments?
-    'pg_event_trigger'
+    'pg_event_trigger',
+    'gp_matview_aux',
+    'gp_matview_tables',
     ]
 
 # Hard coded tables that have different values on every segment

src/backend/catalog/Makefile

@@ -53,6 +53,7 @@ OBJS += pg_extprotocol.o \
        oid_dispatch.o aocatalog.o storage_tablespace.o storage_database.o \
        storage_tablespace_twophase.o storage_tablespace_xact.o \
        gp_partition_template.o pg_task.o pg_task_run_history.o \
+	   gp_matview_aux.o \
        pg_directory_table.o storage_directory_table.o
 
 CATALOG_JSON:= $(addprefix $(top_srcdir)/gpMgmt/bin/gppylib/data/, $(addsuffix .json,$(GP_MAJORVERSION)))
@@ -94,6 +95,8 @@ CATALOG_HEADERS := \
 	pg_sequence.h pg_publication.h pg_publication_rel.h pg_subscription.h \
 	pg_subscription_rel.h gp_partition_template.h pg_task.h pg_task_run_history.h \
 	pg_profile.h pg_password_history.h pg_directory_table.h gp_storage_server.h \
+	gp_matview_aux.h \
+	gp_matview_tables.h \
 	gp_storage_user_mapping.h
 
 USE_INTERNAL_FTS_FOUND := $(if $(findstring USE_INTERNAL_FTS,$(CFLAGS)),true,false)

src/backend/catalog/catalog.c

@@ -76,6 +76,8 @@
 #include "catalog/pg_stat_last_shoperation.h"
 #include "catalog/pg_statistic.h"
 #include "catalog/pg_trigger.h"
+#include "catalog/gp_matview_aux.h"
+#include "catalog/gp_matview_tables.h"
 #include "cdb/cdbvars.h"
 
 #include "catalog/gp_indexing.h"
@@ -551,6 +553,16 @@ IsSharedRelation(Oid relationId)
 		return true;
 	}
 
+	/* materialized view aux and its indexes */
+	if (relationId == GpMatviewAuxId ||
+		relationId == GpMatviewAuxMvoidIndexId ||
+		relationId == GpMatviewAuxMvnameIndexId ||
+		relationId == GpMatviewAuxDatastatusIndexId ||
+		relationId == GpMatviewTablesId ||
+		relationId == GpMatviewTablesMvRelIndexId ||
+		relationId == GpMatviewTablesRelIndexId)
+		return true;
+
 	/* warehouse table and its indexes */
 	if (relationId == GpWarehouseRelationId ||
 		relationId == GpWarehouseOidIndexId ||

src/backend/catalog/dependency.c

@@ -100,6 +100,7 @@
 #include "catalog/pg_profile.h"
 #include "catalog/pg_password_history.h"
 #include "commands/tablecmds.h"
+#include "catalog/gp_matview_aux.h"
 
 
 /*
@@ -209,7 +210,8 @@ static const Oid object_classes[] = {
 	StorageServerRelationId,	/* OCLASS_STORAGE_SERVER */
 	StorageUserMappingRelationId,	/* OCLASS_STORAGE_USER_MAPPING */
 	ExtprotocolRelationId,		/* OCLASS_EXTPROTOCOL */
-	TaskRelationId				/* OCLASS_TASK */
+	GpMatviewAuxId,				/* OCLASS_MATVIEW_AUX */
+	TaskRelationId,				/* OCLASS_TASK */
 };
 
 
@@ -1554,6 +1556,10 @@ doDeletion(const ObjectAddress *object, int flags)
 			RemoveTaskById(object->objectId);
 			break;
 
+		case OCLASS_MATVIEW_AUX:
+			RemoveMatviewAuxEntry(object->objectId);
+			break;
+
 		case OCLASS_CAST:
 		case OCLASS_COLLATION:
 		case OCLASS_CONVERSION:
@@ -2978,6 +2984,9 @@ getObjectClass(const ObjectAddress *object)
 		case TaskRelationId:
 			return OCLASS_TASK;
 
+		case GpMatviewAuxId:
+			return OCLASS_MATVIEW_AUX;
+
 		case DirectoryTableRelationId:
 			return OCLASS_DIRTABLE;