Commiteac1af3

committed

fix drop temp table

1 parent4e64341 commiteac1af3Copy full SHA for eac1af3

File tree

+15

-8

lines changed

+15

-8

lines changed

Lines changed: 14 additions & 7 deletions

Original file line number	Diff line number	Diff line change
`@@ -2365,7 +2365,7 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`2365`	`2365`	`ProcessUtilityContextcontext,ParamListInfoparams,`
`2366`	`2366`	`DestReceiverdest,charcompletionTag)`
`2367`	`2367`	`{`
`2368`		`-boolskipCommand;`
	`2368`	`+boolskipCommand= false;`
`2369`	`2369`	`MTM_TRACE("%d: Process utility statement %s\n",MyProcPid,queryString);`
`2370`	`2370`	`switch (nodeTag(parsetree))`
`2371`	`2371`	`{`
`@@ -2458,14 +2458,21 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`2458`	`2458`	`break;`
`2459`	`2459`	`caseT_DropStmt:`
`2460`	`2460`	`{`
`2461`		`-Oidrelid;`
`2462`		`-Relationrel;`
`2463`	`2461`	`DropStmtstmt= (DropStmt)parsetree;`
`2464`	`2462`
`2465`		`-//relid = RelnameGetRelid(stmt->relation->relname);`
`2466`		`-//rel = heap_open(relid, ShareLock);`
`2467`		`-//skipCommand = rel->rd_rel->relpersistence == RELPERSISTENCE_TEMP;`
`2468`		`-//heap_close(rel, NoLock);`
	`2463`	`+if (stmt->removeType==OBJECT_TABLE)`
	`2464`	`+{`
	`2465`	`+RangeVar*rv=makeRangeVarFromNameList(`
	`2466`	`+(List*)lfirst(list_head(stmt->objects)));`
	`2467`	`+Oidrelid=RelnameGetRelid(rv->relname);`
	`2468`	`+`
	`2469`	`+if (OidIsValid(relid))`
	`2470`	`+{`
	`2471`	`+Relationrel=heap_open(relid,ShareLock);`
	`2472`	`+skipCommand=rel->rd_rel->relpersistence==RELPERSISTENCE_TEMP;`
	`2473`	`+heap_close(rel,ShareLock);`
	`2474`	`+}`
	`2475`	`+}`
`2469`	`2476`	`}`
`2470`	`2477`	`break;`
`2471`	`2478`	`default:`

Lines changed: 1 addition & 1 deletion

Comments

(0)