Add record_image_ops opclass for matview concurrent refresh.

[postgresql] / src / backend / commands / matview.c

diff --git a/src/backend/commands/matview.c b/src/backend/commands/matview.c
index 238ccc72f5205ae00a15e6e17f384addfa445552..fcfc678813d5ce2f02aacb31bec3b5635825c4c4 100644 (file)
--- a/src/backend/commands/matview.c
+++ b/src/backend/commands/matview.c
@@ -562,7 +562,7 @@ refresh_by_match_merge(Oid matviewOid, Oid tempOid)
                                         "SELECT newdata FROM %s newdata "
                                         "WHERE newdata IS NOT NULL AND EXISTS "
                                         "(SELECT * FROM %s newdata2 WHERE newdata2 IS NOT NULL "
-                                        "AND newdata2 OPERATOR(pg_catalog.=) newdata "
+                                        "AND newdata2 OPERATOR(pg_catalog.*=) newdata "
                                         "AND newdata2.ctid OPERATOR(pg_catalog.<>) "
                                         "newdata.ctid) LIMIT 1",
                                         tempname, tempname);
@@ -645,9 +645,6 @@ refresh_by_match_merge(Oid matviewOid, Oid tempOid)
                                /*
                                 * Only include the column once regardless of how many times
                                 * it shows up in how many indexes.
-                                *
-                                * This is also useful later to omit columns which can not
-                                * have changed from the SET clause of the UPDATE statement.
                                 */
                                if (usedForQual[attnum - 1])
                                        continue;
@@ -682,8 +679,9 @@ refresh_by_match_merge(Oid matviewOid, Oid tempOid)
                                 errhint("Create a UNIQUE index with no WHERE clause on one or more columns of the materialized view.")));
 
        appendStringInfoString(&querybuf,
-                                                  " AND newdata = mv) WHERE newdata IS NULL OR mv IS NULL"
-                                                  " ORDER BY tid");
+                                                  " AND newdata OPERATOR(pg_catalog.*=) mv) "
+                                                  "WHERE newdata IS NULL OR mv IS NULL "
+                                                  "ORDER BY tid");
 
        /* Create the temporary "diff" table. */
        if (SPI_exec(querybuf.data, 0) != SPI_OK_UTILITY)