diff options
Diffstat (limited to 'src/backend/rewrite/rewriteHandler.c')
| -rw-r--r-- | src/backend/rewrite/rewriteHandler.c | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/backend/rewrite/rewriteHandler.c b/src/backend/rewrite/rewriteHandler.c index 04f9622f788..8f75948d0dd 100644 --- a/src/backend/rewrite/rewriteHandler.c +++ b/src/backend/rewrite/rewriteHandler.c @@ -2157,6 +2157,7 @@ RewriteQuery(Query *parsetree, List *rewrite_events) List * QueryRewrite(Query *parsetree) { + uint32 input_query_id = parsetree->queryId; List *querylist; List *results; ListCell *l; @@ -2181,6 +2182,8 @@ QueryRewrite(Query *parsetree) * Step 2 * * Apply all the RIR rules on each query + * + * This is also a handy place to mark each query with the original queryId */ results = NIL; foreach(l, querylist) @@ -2188,6 +2191,9 @@ QueryRewrite(Query *parsetree) Query *query = (Query *) lfirst(l); query = fireRIRrules(query, NIL, false); + + query->queryId = input_query_id; + results = lappend(results, query); } |