Commit5d3274d

committed

Fix PGPPRO-717 correctly restore name/schema of local tables

1 parent6c4ad7f commit5d3274dCopy full SHA for 5d3274d

File tree

-8

lines changed

-8

lines changed

Lines changed: 6 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -2522,7 +2522,7 @@ MtmCreateLocalTableMap(void)`
`2522`	`2522`	`returnhtab;`
`2523`	`2523`	`}`
`2524`	`2524`
`2525`		`-voidMtmMakeRelationLocal(Oidrelid)`
	`2525`	`+staticvoidMtmMakeRelationLocal(Oidrelid)`
`2526`	`2526`	`{`
`2527`	`2527`	`if (OidIsValid(relid)) {`
`2528`	`2528`	`MtmLock(LW_EXCLUSIVE);`
`@@ -2532,17 +2532,17 @@ void MtmMakeRelationLocal(Oid relid)`
`2532`	`2532`	`}`
`2533`	`2533`
`2534`	`2534`
`2535`		`-staticvoidMtmMakeTableLocal(charschema,charname)`
	`2535`	`+voidMtmMakeTableLocal(charconstschema,charconstname)`
`2536`	`2536`	`{`
`2537`		`-RangeVar*rv=makeRangeVar(schema,name,-1);`
	`2537`	`+RangeVarrv=makeRangeVar((char)schema,(char*)name,-1);`
`2538`	`2538`	`Oidrelid=RangeVarGetRelid(rv,NoLock, true);`
`2539`	`2539`	`MtmMakeRelationLocal(relid);`
`2540`	`2540`	`}`
`2541`	`2541`
`2542`	`2542`
`2543`	`2543`	`typedefstruct {`
`2544`		`-NameDataschema;`
`2545`		`-NameDataname;`
	`2544`	`+textschema;`
	`2545`	`+textname;`
`2546`	`2546`	`}MtmLocalTablesTuple;`
`2547`	`2547`
`2548`	`2548`	`staticvoidMtmLoadLocalTables(void)`
`@@ -2562,7 +2562,7 @@ static void MtmLoadLocalTables(void)`
`2562`	`2562`	`while (HeapTupleIsValid(tuple=systable_getnext(scan)))`
`2563`	`2563`	`{`
`2564`	`2564`	`MtmLocalTablesTuplet= (MtmLocalTablesTuple)GETSTRUCT(tuple);`
`2565`		`-MtmMakeTableLocal(NameStr(t->schema),NameStr(t->name));`
	`2565`	`+MtmMakeTableLocal(text_to_cstring(&t->schema),text_to_cstring(&t->name));`
`2566`	`2566`	`}`
`2567`	`2567`
`2568`	`2568`	`systable_endscan(scan);`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -403,7 +403,7 @@ extern void MtmCheckQuorum(void);`
`403`	`403`	`externboolMtmRecoveryCaughtUp(intnodeId,lsn_twalEndPtr);`
`404`	`404`	`externvoidMtmCheckRecoveryCaughtUp(intnodeId,lsn_tslotLSN);`
`405`	`405`	`externvoidMtmRecoveryCompleted(void);`
`406`		`-externvoidMtmMakeRelationLocal(Oidrelid);`
	`406`	`+externvoidMtmMakeTableLocal(charconstschema,charconstname);`
`407`	`407`	`externvoidMtmHandleApplyError(void);`
`408`	`408`	`externvoidMtmUpdateLsnMapping(intnodeId,lsn_tendLsn);`
`409`	`409`	`externlsn_tMtmGetFlushPosition(intnodeId);`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -860,7 +860,7 @@ process_remote_insert(StringInfo s, Relation rel)`
`860`	`860`	`if (strcmp(RelationGetRelationName(rel),MULTIMASTER_LOCAL_TABLES_TABLE)==0&&`
`861`	`861`	`strcmp(get_namespace_name(RelationGetNamespace(rel)),MULTIMASTER_SCHEMA_NAME)==0)`
`862`	`862`	`{`
`863`		`-MtmMakeRelationLocal(RelationGetRelid(rel));`
	`863`	`+MtmMakeTableLocal(TextDatumGetCString(new_tuple.values[0]),TextDatumGetCString(new_tuple.values[1]));`
`864`	`864`	`}`
`865`	`865`
`866`	`866`	`ExecResetTupleTable(estate->es_tupleTable, true);`

Comments

(0)