Commit484e3d8

committed

Support local COPY ultility

1 parent075798f commit484e3d8Copy full SHA for 484e3d8

File tree

+17

-1

lines changed

+17

-1

lines changed

Lines changed: 12 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -5441,6 +5441,7 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`5441`	`5441`	`CopyStmtcopyStatement= (CopyStmt)parsetree;`
`5442`	`5442`	`skipCommand= true;`
`5443`	`5443`	`if (copyStatement->is_from) {`
	`5444`	`+ListCell*opt;`
`5444`	`5445`	`RangeVar*relation=copyStatement->relation;`
`5445`	`5446`
`5446`	`5447`	`if (relation!=NULL)`
`@@ -5455,6 +5456,17 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`5455`	`5456`	`heap_close(rel,ShareLock);`
`5456`	`5457`	`}`
`5457`	`5458`	`}`
	`5459`	`+`
	`5460`	`+foreach(opt,copyStatement->options)`
	`5461`	`+{`
	`5462`	`+DefElem*elem=lfirst(opt);`
	`5463`	`+if (strcmp("local",elem->defname)==0) {`
	`5464`	`+MtmTx.isDistributed= false;/* Skip */`
	`5465`	`+MtmTx.snapshot=INVALID_CSN;`
	`5466`	`+MtmTx.containsDML= false;`
	`5467`	`+break;`
	`5468`	`+}`
	`5469`	`+}`
`5458`	`5470`	`}`
`5459`	`5471`	`caseT_CreateFunctionStmt:`
`5460`	`5472`	`{`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1191,7 +1191,7 @@ ProcessCopyOptions(CopyState cstate,`
`1191`	`1191`	`errmsg("argument to option \"%s\" must be a valid encoding name",`
`1192`	`1192`	`defel->defname)));`
`1193`	`1193`	`}`
`1194`		`-else`
	`1194`	`+elseif (strcmp(defel->defname,"local")!=0)`
`1195`	`1195`	`ereport(ERROR,`
`1196`	`1196`	`(errcode(ERRCODE_SYNTAX_ERROR),`
`1197`	`1197`	`errmsg("option \"%s\" not recognized",`

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -2856,6 +2856,10 @@ copy_opt_item:`
`2856`	`2856`	`{`
`2857`	`2857`	`$$ = makeDefElem("format", (Node *)makeString("csv"));`
`2858`	`2858`	`}`
	`2859`	`+\|LOCAL`
	`2860`	`+{`
	`2861`	`+$$ = makeDefElem("local", (Node *)makeInteger(TRUE));`
	`2862`	`+}`
`2859`	`2863`	`\|HEADER_P`
`2860`	`2864`	`{`
`2861`	`2865`	`$$ = makeDefElem("header", (Node *)makeInteger(TRUE));`

Comments

(0)