Commit3028dc9

committed

fix index command for unexisintg relation; replicate create schema

1 parenteac1af3 commit3028dc9Copy full SHA for 3028dc9

File tree

-3

lines changed

-3

lines changed

Lines changed: 8 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -2451,9 +2451,13 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`2451`	`2451`	`"CREATE INDEX CONCURRENTLY");`
`2452`	`2452`
`2453`	`2453`	`relid=RelnameGetRelid(stmt->relation->relname);`
`2454`		`-rel=heap_open(relid,ShareLock);`
`2455`		`-skipCommand=rel->rd_rel->relpersistence==RELPERSISTENCE_TEMP;`
`2456`		`-heap_close(rel,NoLock);`
	`2454`	`+`
	`2455`	`+if (OidIsValid(relid))`
	`2456`	`+{`
	`2457`	`+rel=heap_open(relid,ShareLock);`
	`2458`	`+skipCommand=rel->rd_rel->relpersistence==RELPERSISTENCE_TEMP;`
	`2459`	`+heap_close(rel,NoLock);`
	`2460`	`+}`
`2457`	`2461`	`}`
`2458`	`2462`	`break;`
`2459`	`2463`	`caseT_DropStmt:`
`@@ -2475,6 +2479,7 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`2475`	`2479`	`}`
`2476`	`2480`	`}`
`2477`	`2481`	`break;`
	`2482`	`+caseT_CreateSchemaStmt:`
`2478`	`2483`	`default:`
`2479`	`2484`	`skipCommand= false;`
`2480`	`2485`	`break;`

Comments

(0)