Commitabc2e7a

committed

fix index command for unexisintg relation; replicate create schema

1 parent8b0be38 commitabc2e7aCopy full SHA for abc2e7a

File tree

-3

lines changed

-3

lines changed

Lines changed: 8 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -2462,9 +2462,13 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`2462`	`2462`	`"CREATE INDEX CONCURRENTLY");`
`2463`	`2463`
`2464`	`2464`	`relid=RelnameGetRelid(stmt->relation->relname);`
`2465`		`-rel=heap_open(relid,ShareLock);`
`2466`		`-skipCommand=rel->rd_rel->relpersistence==RELPERSISTENCE_TEMP;`
`2467`		`-heap_close(rel,NoLock);`
	`2465`	`+`
	`2466`	`+if (OidIsValid(relid))`
	`2467`	`+{`
	`2468`	`+rel=heap_open(relid,ShareLock);`
	`2469`	`+skipCommand=rel->rd_rel->relpersistence==RELPERSISTENCE_TEMP;`
	`2470`	`+heap_close(rel,NoLock);`
	`2471`	`+}`
`2468`	`2472`	`}`
`2469`	`2473`	`break;`
`2470`	`2474`	`caseT_DropStmt:`
`@@ -2486,6 +2490,7 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`2486`	`2490`	`}`
`2487`	`2491`	`}`
`2488`	`2492`	`break;`
	`2493`	`+caseT_CreateSchemaStmt:`
`2489`	`2494`	`default:`
`2490`	`2495`	`skipCommand= false;`
`2491`	`2496`	`break;`

Comments

(0)