Commit8b0be38

committed

fix drop temp table

1 parent875743b commit8b0be38Copy full SHA for 8b0be38

File tree

+14

-7

lines changed

+14

-7

lines changed

Lines changed: 14 additions & 7 deletions

Original file line number	Diff line number	Diff line change
`@@ -2379,7 +2379,7 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`2379`	`2379`	`ProcessUtilityContextcontext,ParamListInfoparams,`
`2380`	`2380`	`DestReceiverdest,charcompletionTag)`
`2381`	`2381`	`{`
`2382`		`-boolskipCommand;`
	`2382`	`+boolskipCommand= false;`
`2383`	`2383`	`MTM_TRACE("%d: Process utility statement %s\n",MyProcPid,queryString);`
`2384`	`2384`	`switch (nodeTag(parsetree))`
`2385`	`2385`	`{`
`@@ -2469,14 +2469,21 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`2469`	`2469`	`break;`
`2470`	`2470`	`caseT_DropStmt:`
`2471`	`2471`	`{`
`2472`		`-Oidrelid;`
`2473`		`-Relationrel;`
`2474`	`2472`	`DropStmtstmt= (DropStmt)parsetree;`
`2475`	`2473`
`2476`		`-//relid = RelnameGetRelid(stmt->relation->relname);`
`2477`		`-//rel = heap_open(relid, ShareLock);`
`2478`		`-//skipCommand = rel->rd_rel->relpersistence == RELPERSISTENCE_TEMP;`
`2479`		`-//heap_close(rel, NoLock);`
	`2474`	`+if (stmt->removeType==OBJECT_TABLE)`
	`2475`	`+{`
	`2476`	`+RangeVar*rv=makeRangeVarFromNameList(`
	`2477`	`+(List*)lfirst(list_head(stmt->objects)));`
	`2478`	`+Oidrelid=RelnameGetRelid(rv->relname);`
	`2479`	`+`
	`2480`	`+if (OidIsValid(relid))`
	`2481`	`+{`
	`2482`	`+Relationrel=heap_open(relid,ShareLock);`
	`2483`	`+skipCommand=rel->rd_rel->relpersistence==RELPERSISTENCE_TEMP;`
	`2484`	`+heap_close(rel,ShareLock);`
	`2485`	`+}`
	`2486`	`+}`
`2480`	`2487`	`}`
`2481`	`2488`	`break;`
`2482`	`2489`	`default:`

Comments

(0)