Support local COPY ultility

knizhnik · kelvich · commit 7e5447507f76 · 2017-11-13T02:21:37.000+03:00
diff --git a/multimaster.c b/multimaster.c
@@ -5110,6 +5110,7 @@ static void MtmProcessUtility(Node *parsetree, const char *queryString,
 			CopyStmt *copyStatement = (CopyStmt *) parsetree;
 			skipCommand = true;
 			if (copyStatement->is_from) {
+				ListCell *opt;
 				RangeVar *relation = copyStatement->relation;
 
 				if (relation != NULL)
@@ -5124,6 +5125,17 @@ static void MtmProcessUtility(Node *parsetree, const char *queryString,
 						heap_close(rel, ShareLock);
 					}
 				}
+
+				foreach(opt, copyStatement->options)
+				{
+					DefElem	*elem = lfirst(opt);
+					if (strcmp("local", elem->defname) == 0) {
+						MtmTx.isDistributed = false; /* Skip */
+						MtmTx.snapshot = INVALID_CSN;
+						MtmTx.containsDML = false;
+						break;
+					}
+				}
 			}
 		    case T_CreateFunctionStmt:
 		    {

Original file line number	Diff line number	Diff line change
`@@ -5110,6 +5110,7 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`5110`	`5110`	`CopyStmt copyStatement = (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`	`case T_CreateFunctionStmt:`
`5129`	`5141`	`{`