Merge branch 'main' into reshke-patch-1

Author: reshke

src/backend/gporca/libgpopt/include/gpopt/operators/CPhysicalDynamicTableScan.h

@@ -74,6 +74,9 @@ class CPhysicalDynamicTableScan : public CPhysicalDynamicScan
 	CPartitionPropagationSpec *PppsDerive(
 		CMemoryPool *mp, CExpressionHandle &exprhdl) const override;
 
+	// return rewindability property enforcing type for this operator
+	CEnfdProp::EPropEnforcingType EpetRewindability(CExpressionHandle &, const CEnfdRewindability *) const override;
+
 };	// class CPhysicalDynamicTableScan
 
 }  // namespace gpopt

src/backend/gporca/libgpopt/src/operators/CPhysicalDynamicTableScan.cpp

@@ -91,4 +91,19 @@ CPhysicalDynamicTableScan::PppsDerive(CMemoryPool *mp,
 	return pps;
 }
 
+
+CEnfdProp::EPropEnforcingType
+CPhysicalDynamicTableScan::EpetRewindability(CExpressionHandle &exprhdl,
+											 const CEnfdRewindability *per) const
+{
+	CRewindabilitySpec *prs = CDrvdPropPlan::Pdpplan(exprhdl.Pdp())->Prs();
+	if (per->FCompatible(prs))
+	{
+		// required rewindability is already provided
+		return CEnfdProp::EpetUnnecessary;
+	}
+
+	return CEnfdProp::EpetRequired;
+}
+
 // EOF

src/bin/pg_dump/pg_backup_archiver.c

@@ -4935,43 +4935,8 @@ CloneArchive(ArchiveHandle *AH)
 
 	/* re-establish fixed state */
 	if (AH->mode == archModeRead)
-	{
-		Assert(AH->connection == NULL);
-
-		/* this also sets clone->connection */
-		ConnectDatabase((Archive *) clone, &clone->public.ropt->cparams, true, false);
-
-		/* re-establish fixed state */
 		_doSetFixedOutputState(clone);
-	}
-	else
-	{
-		PQExpBufferData connstr;
-		char	   *pghost;
-		char	   *pgport;
-		char	   *username;
-
-		Assert(AH->connection != NULL);
-
-		/*
-		 * Even though we are technically accessing the parent's database
-		 * object here, these functions are fine to be called like that
-		 * because all just return a pointer and do not actually send/receive
-		 * any data to/from the database.
-		 */
-		initPQExpBuffer(&connstr);
-		appendPQExpBufferStr(&connstr, "dbname=");
-		appendConnStrVal(&connstr, PQdb(AH->connection));
-		pghost = PQhost(AH->connection);
-		pgport = PQport(AH->connection);
-		username = PQuser(AH->connection);
-
-		/* this also sets clone->connection */
-		ConnectDatabase((Archive *) clone, &clone->public.ropt->cparams, true, false);
-
-		termPQExpBuffer(&connstr);
-		/* setupDumpWorker will fix up connection state */
-	}
+	/* in write case, setupDumpWorker will fix up connection state */
 
 	/* Let the format-specific code have a chance too */
 	clone->ClonePtr(clone);

src/bin/pg_dump/t/002_pg_dump.pl

@@ -2214,20 +2214,22 @@
 		create_order => 19,
 		create_sql	=> 'CREATE TABLE dump_test.test_table_ao(a integer, b text)
 						WITH (appendonly = true, compresstype = zlib, compresslevel = 1);',
-		regexp => qr/^
-			\QCREATE TABLE dump_test.test_table_ao (\E\n
-			\s+\Qa integer,\E\n
-			\s+\Qb text\E\n
-			\QWITH (appendonly = true, orientation = column, compresstype = zlib, compresslevel = 1);\E\n/xm,
+		regexp => qr{^
+			\QCREATE TABLE dump_test.test_table_ao (\E
+			\n\s+\Qa integer,\E
+			\n\s+\Qb text\E
+			\n\Q)\E
+			\n\QWITH (appendonly = true, compresstype=zlib, compresslevel='1');\E
+			}xm,
 		like => {
 			%full_runs,
 			%dump_test_schema_runs,
-			only_dump_test_table => 1,
 			section_pre_data     => 1,
+			exclude_test_table       => 1,
 		},
 		unlike => {
+			only_dump_test_table => 1,
 			exclude_dump_test_schema => 1,
-			exclude_test_table       => 1,
 		},
 	},