Commit7e54475

authored and

committed

Support local COPY ultility

1 parentfeaff21 commit7e54475Copy full SHA for 7e54475

File tree

+12

-0

lines changed

+12

-0

lines changed

Lines changed: 12 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -5110,6 +5110,7 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`5110`	`5110`	`CopyStmtcopyStatement= (CopyStmt)parsetree;`
`5111`	`5111`	`skipCommand= true;`
`5112`	`5112`	`if (copyStatement->is_from) {`
	`5113`	`+ListCell*opt;`
`5113`	`5114`	`RangeVar*relation=copyStatement->relation;`
`5114`	`5115`
`5115`	`5116`	`if (relation!=NULL)`
`@@ -5124,6 +5125,17 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`5124`	`5125`	`heap_close(rel,ShareLock);`
`5125`	`5126`	`}`
`5126`	`5127`	`}`
	`5128`	`+`
	`5129`	`+foreach(opt,copyStatement->options)`
	`5130`	`+{`
	`5131`	`+DefElem*elem=lfirst(opt);`
	`5132`	`+if (strcmp("local",elem->defname)==0) {`
	`5133`	`+MtmTx.isDistributed= false;/* Skip */`
	`5134`	`+MtmTx.snapshot=INVALID_CSN;`
	`5135`	`+MtmTx.containsDML= false;`
	`5136`	`+break;`
	`5137`	`+}`
	`5138`	`+}`
`5127`	`5139`	`}`
`5128`	`5140`	`caseT_CreateFunctionStmt:`
`5129`	`5141`	`{`

Comments

(0)