disable shared lock for pg_dump

qjpcpu · qjpcpu · commit 0996129651e9 · 2021-10-12T18:30:46.000+08:00
Change-Id: I63de1bbd19cd1638903acbe5fb592dd3f754e6da
diff --git a/src/bin/pg_dump/parallel.c b/src/bin/pg_dump/parallel.c
@@ -1305,6 +1305,7 @@ IsEveryWorkerIdle(ParallelState *pstate)
 static void
 lockTableForWorker(ArchiveHandle *AH, TocEntry *te)
 {
+	return;
 	const char *qualId;
 	PQExpBuffer query;
 	PGresult   *res;
diff --git a/src/bin/pg_dump/pg_dump.c b/src/bin/pg_dump/pg_dump.c
@@ -7019,11 +7019,13 @@ getTables(Archive *fout, int *numTables)
 			 tblinfo->relkind == RELKIND_PARTITIONED_TABLE) &&
 			(tblinfo[i].dobj.dump & DUMP_COMPONENTS_REQUIRING_LOCK))
 		{
+			/*
 			resetPQExpBuffer(query);
 			appendPQExpBuffer(query,
 							  "LOCK TABLE %s IN ACCESS SHARE MODE",
 							  fmtQualifiedDumpable(&tblinfo[i]));
 			ExecuteSqlStatement(fout, query->data);
+			*/
 		}
 
 		/* Emit notice if join for owner failed */

Original file line number	Diff line number	Diff line change
`@@ -1305,6 +1305,7 @@ IsEveryWorkerIdle(ParallelState *pstate)`
`1305`	`1305`	`static void`
`1306`	`1306`	`lockTableForWorker(ArchiveHandle AH, TocEntry te)`
`1307`	`1307`	`{`
	`1308`	`+ return;`
`1308`	`1309`	`const char *qualId;`
`1309`	`1310`	`PQExpBuffer query;`
`1310`	`1311`	`PGresult *res;`
Original file line number	Diff line number	Diff line change
`@@ -7019,11 +7019,13 @@ getTables(Archive fout, int numTables)`
`7019`	`7019`	`tblinfo->relkind == RELKIND_PARTITIONED_TABLE) &&`
`7020`	`7020`	`(tblinfo[i].dobj.dump & DUMP_COMPONENTS_REQUIRING_LOCK))`
`7021`	`7021`	`{`
	`7022`	`+ /*`
`7022`	`7023`	`resetPQExpBuffer(query);`
`7023`	`7024`	`appendPQExpBuffer(query,`
`7024`	`7025`	`"LOCK TABLE %s IN ACCESS SHARE MODE",`
`7025`	`7026`	`fmtQualifiedDumpable(&tblinfo[i]));`
`7026`	`7027`	`ExecuteSqlStatement(fout, query->data);`
	`7028`	`+ */`
`7027`	`7029`	`}`
`7028`	`7030`
`7029`	`7031`	`/* Emit notice if join for owner failed */`