Append pg_catalog to some more places, fix again _partition_data_concurrent.

Author: arssher

init.sql

@@ -188,8 +188,8 @@ BEGIN
 	IF callback != 0 THEN
 		SELECT pg_catalog.quote_ident(nspname) || '.' ||
 			   pg_catalog.quote_ident(proname) || '(' ||
-					(SELECT string_agg(x.argtype::REGTYPE::TEXT, ',')
-					 FROM unnest(proargtypes) AS x(argtype)) ||
+					(SELECT pg_catalog.string_agg(x.argtype::REGTYPE::TEXT, ',')
+					 FROM pg_catalog.unnest(proargtypes) AS x(argtype)) ||
 			   ')'
 		FROM pg_catalog.pg_proc p JOIN pg_catalog.pg_namespace n
 		ON n.oid = p.pronamespace
@@ -455,7 +455,7 @@ BEGIN
 		RAISE EXCEPTION 'table "%" has already been partitioned', parent_relid;
 	END IF;
 
-	IF EXISTS (SELECT 1 FROM pg_inherits WHERE inhparent = parent_relid) THEN
+	IF EXISTS (SELECT 1 FROM pg_catalog.pg_inherits WHERE inhparent = parent_relid) THEN
 		RAISE EXCEPTION 'can''t partition table "%" with existing children', parent_relid;
 	END IF;
 
@@ -506,7 +506,7 @@ BEGIN
 
 	/* Find relids to remove from config */
 	SELECT pg_catalog.array_agg(cfg.partrel) INTO relids
-	FROM pg_event_trigger_dropped_objects() AS events
+	FROM pg_catalog.pg_event_trigger_dropped_objects() AS events
 	JOIN @[email protected]_config AS cfg ON cfg.partrel::oid = events.objid
 	WHERE events.classid = pg_class_oid AND events.objsubid = 0;
 
@@ -707,7 +707,7 @@ CREATE FUNCTION @[email protected]_number_of_partitions(
 	parent_relid	REGCLASS)
 RETURNS INT4 AS
 $$
-	SELECT count(*)::INT4
+	SELECT pg_catalog.count(*)::INT4
 	FROM pg_catalog.pg_inherits
 	WHERE inhparent = parent_relid;
 $$

src/pathman_workers.c

@@ -523,7 +523,7 @@ bgw_main_concurrent_part(Datum main_arg)
 			 * context will be destroyed after transaction finishes
 			 */
 			current_mcxt = MemoryContextSwitchTo(TopPathmanContext);
-			sql = psprintf("SELECT %s._partition_data_concurrent($1::oid, NULL::text, NULL::text, p_limit:=$2)",
+			sql = psprintf("SELECT %s._partition_data_concurrent($1::regclass, NULL::text, NULL::text, p_limit:=$2)",
 						   get_namespace_name(get_pathman_schema()));
 			MemoryContextSwitchTo(current_mcxt);
 		}