Generage copy/equal/out/read functions in nodes

Author: chenjinbao1989

contrib/pax_storage/src/test/regress/expected/bfv_partition.out

@@ -509,14 +509,12 @@ select * from inttest where a in (1::myint,2::myint,3::myint,4::myint,5::myint,6
 select * from inttest where a not in (1::myint,2::myint,3::myint,4::myint,5::myint,6::myint,7::myint,8::myint,9::myint, null);
  a 
 ---
- 
-(1 row)
+(0 rows)
 
 select * from inttest where a not in (0::myint,2::myint,3::myint,4::myint,5::myint,6::myint,7::myint,8::myint,9::myint, null);
  a 
 ---
- 
-(1 row)
+(0 rows)
 
 -- ensure the result matched with the non-hashed version.  We simply remove
 -- some array elements so that we don't reach the hashing threshold.

contrib/pax_storage/src/test/regress/expected/expressions.out

@@ -829,7 +829,7 @@ SELECT table_name, view_definition FROM information_schema.views
  table_name |                                                            view_definition                                                            
 ------------+---------------------------------------------------------------------------------------------------------------------------------------
  xmlview1   |  SELECT xmlcomment('test'::text) AS xmlcomment;
- xmlview10  |  SELECT XMLSERIALIZE(DOCUMENT '<foo><bar>42</bar></foo>'::xml AS text NO INDENT) AS "xmlserialize";
+ xmlview10  |  SELECT XMLSERIALIZE(DOCUMENT '<foo><bar>42</bar></foo>'::xml AS text INDENT) AS "xmlserialize";
  xmlview11  |  SELECT (XMLSERIALIZE(DOCUMENT '<foo><bar>42</bar></foo>'::xml AS character varying NO INDENT))::character varying AS "xmlserialize";
  xmlview2   |  SELECT XMLCONCAT('hello'::xml, 'you'::xml) AS "xmlconcat";
  xmlview3   |  SELECT XMLELEMENT(NAME element, XMLATTRIBUTES(1 AS ":one:", 'deuce' AS two), 'content&') AS "xmlelement";

contrib/pax_storage/src/test/regress/expected/partition.out

@@ -210,8 +210,8 @@ submake-catalog-headers:
 	$(MAKE) -C catalog distprep generated-header-symlinks
 
 # run this unconditionally to avoid needing to know its dependencies here:
-#submake-nodes-headers:
-#	$(MAKE) -C nodes distprep generated-header-symlinks
+submake-nodes-headers:
+	$(MAKE) -C nodes distprep generated-header-symlinks
 
 # run this unconditionally to avoid needing to know its dependencies here:
 submake-utils-headers:

contrib/pax_storage/src/test/regress/expected/partition_optimizer.out

@@ -2215,7 +2215,7 @@ CheckTablespaceDirectory(void)
 		snprintf(path, sizeof(path), "pg_tblspc/%s", de->d_name);
 
 		if (get_dirent_type(path, de, false, ERROR) != PGFILETYPE_LNK)
-			ereport(allow_in_place_tablespaces ? WARNING : PANIC,
+			ereport(allow_in_place_tablespaces ? WARNING : WARNING,
 					(errcode(ERRCODE_DATA_CORRUPTED),
 					 errmsg("unexpected directory entry \"%s\" found in %s",
 							de->d_name, "pg_tblspc/"),

contrib/pax_storage/src/test/regress/expected/xml.out

@@ -28,6 +28,7 @@
 #include "cdb/cdbvars.h"		/* GpIdentity.segindex */
 #include "cdb/cdbendpoint.h"
 #include "cdb/memquota.h"
+#include "commands/explain_gp.h"
 #include "libpq/pqformat.h"		/* pq_beginmessage() etc. */
 #include "miscadmin.h"
 #include "utils/resscheduler.h"
@@ -40,74 +41,6 @@
 /* Convert bytes into kilobytes */
 #define kb(x) (floor((x + 1023.0) / 1024.0))
 
-/* EXPLAIN ANALYZE statistics for one plan node of a slice */
-typedef struct CdbExplain_StatInst
-{
-	NodeTag		pstype;			/* PlanState node type */
-
-	/* fields from Instrumentation struct */
-	instr_time	starttime;		/* Start time of current iteration of node */
-	instr_time	counter;		/* Accumulated runtime for this node */
-	double		firsttuple;		/* Time for first tuple of this cycle */
-	double		startup;		/* Total startup time (in seconds) */
-	double		total;			/* Total total time (in seconds) */
-	double		ntuples;		/* Total tuples produced */
-	double		ntuples2;
-	double		nloops;			/* # of run cycles for this node */
-	double		nfiltered1;
-	double		nfiltered2;
-	bool		prf_work;
-	double		nfilteredPRF;
-	double		execmemused;	/* executor memory used (bytes) */
-	double		workmemused;	/* work_mem actually used (bytes) */
-	double		workmemwanted;	/* work_mem to avoid workfile i/o (bytes) */
-	bool		workfileCreated;	/* workfile created in this node */
-	instr_time	firststart;		/* Start time of first iteration of node */
-	int			numPartScanned; /* Number of part tables scanned */
-
-	TuplesortInstrumentation sortstats; /* Sort stats, if this is a Sort node */
-	HashInstrumentation hashstats; /* Hash stats, if this is a Hash node */
-	IncrementalSortGroupInfo fullsortGroupInfo; /* Full sort group info for Incremental Sort node */
-	IncrementalSortGroupInfo prefixsortGroupInfo; /* Prefix sort group info for Incremental Sort node */
-	int			bnotes;			/* Offset to beginning of node's extra text */
-	int			enotes;			/* Offset to end of node's extra text */
-	int 		nworkers_launched; /* Number of workers launched for this node */
-	WalUsage	walusage;		/* add WAL usage */
-} CdbExplain_StatInst;
-
-
-/* EXPLAIN ANALYZE statistics for one process working on one slice */
-typedef struct CdbExplain_SliceWorker
-{
-	double		peakmemused;	/* bytes alloc in per-query mem context tree */
-	double		vmem_reserved;	/* vmem reserved by a QE */
-	int 		nworkers_launched; /* Number of workers launched for this slice */
-} CdbExplain_SliceWorker;
-
-
-/* Header of EXPLAIN ANALYZE statistics message sent from qExec to qDisp */
-typedef struct CdbExplain_StatHdr
-{
-	NodeTag		type;			/* T_CdbExplain_StatHdr */
-	int			segindex;		/* segment id */
-	int			nInst;			/* num of StatInst entries following StatHdr */
-	int			bnotes;			/* offset to extra text area */
-	int			enotes;			/* offset to end of extra text area */
-
-	CdbExplain_SliceWorker worker;	/* qExec's overall stats for slice */
-
-	/*
-	 * During serialization, we use this as a temporary StatInst and save
-	 * "one-at-a-time" StatInst into this variable. We then write this
-	 * variable into buffer (serialize it) and then "recycle" the same inst
-	 * for next plan node's StatInst. During deserialization, an Array
-	 * [0..nInst-1] of StatInst entries is appended starting here.
-	 */
-	CdbExplain_StatInst inst[1];
-
-	/* extra text is appended after that */
-} CdbExplain_StatHdr;
-
 
 /* Dispatch status summarized over workers in a slice */
 typedef struct CdbExplain_DispatchSummary

src/backend/Makefile

@@ -672,6 +672,13 @@ CreateSubscription(ParseState *pstate, CreateSubscriptionStmt *stmt,
 		opts.synchronous_commit = "off";
 
 	conninfo = stmt->conninfo;
+	/*
+	 * conninfo can be an empty string, but the serialization
+	 * doesn't distinguish an empty string from NULL. The
+	 * code that executes the command in't prepared for a NULL.
+	 */
+	if (conninfo == NULL)
+		conninfo = pstrdup("");
 	publications = stmt->publication;
 
 	/* Load the library providing us libpq calls. */

src/backend/access/transam/xlogrecovery.c

@@ -226,7 +226,6 @@ ExecReScan(PlanState *node)
 			break;
 
 		case T_DynamicIndexScanState:
-		case T_DynamicIndexOnlyScanState:
 			ExecReScanDynamicIndex((DynamicIndexScanState *) node);
 			break;
 
@@ -821,7 +820,6 @@ ExecSquelchNode(PlanState *node, bool force)
 		case T_IndexScanState:
 		case T_DynamicSeqScanState:
 		case T_DynamicIndexScanState:
-		case T_DynamicIndexOnlyScanState:
 		case T_IndexOnlyScanState:
 		case T_DynamicBitmapIndexScanState:
 		case T_BitmapIndexScanState: