|
62 | 62 | #include"pglogical_output/hooks.h" |
63 | 63 | #include"parser/analyze.h" |
64 | 64 | #include"parser/parse_relation.h" |
| 65 | +#include"tcop/pquery.h" |
65 | 66 |
|
66 | 67 | #include"multimaster.h" |
67 | 68 | #include"ddd.h" |
@@ -3939,13 +3940,15 @@ static void MtmProcessUtility(Node *parsetree, const char *queryString, |
3939 | 3940 | if (!skipCommand&& (context==PROCESS_UTILITY_TOPLEVEL||MtmUtilityProcessedInXid!=GetCurrentTransactionId())) |
3940 | 3941 | MtmUtilityProcessedInXid=InvalidTransactionId; |
3941 | 3942 |
|
3942 | | -if (context==PROCESS_UTILITY_TOPLEVEL||context==PROCESS_UTILITY_QUERY) |
3943 | | -{ |
3944 | | -if (!skipCommand&& !MtmTx.isReplicated&& (MtmUtilityProcessedInXid==InvalidTransactionId)) { |
3945 | | -MtmUtilityProcessedInXid=GetCurrentTransactionId(); |
| 3943 | +if (!skipCommand&& !MtmTx.isReplicated&& (MtmUtilityProcessedInXid==InvalidTransactionId)) { |
| 3944 | +MtmUtilityProcessedInXid=GetCurrentTransactionId(); |
| 3945 | + |
| 3946 | +if (context==PROCESS_UTILITY_TOPLEVEL) |
3946 | 3947 | MtmProcessDDLCommand(queryString, true); |
3947 | | -executed= true; |
3948 | | -} |
| 3948 | +else |
| 3949 | +MtmProcessDDLCommand(ActivePortal->sourceText, true); |
| 3950 | + |
| 3951 | +executed= true; |
3949 | 3952 | } |
3950 | 3953 |
|
3951 | 3954 | if (PreviousProcessUtilityHook!=NULL) |
|