*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/nodes/copyfuncs.c,v 1.27 1998/01/04 04:31:02 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/nodes/copyfuncs.c,v 1.28 1998/01/09 05:48:10 momjian Exp $
*
*-------------------------------------------------------------------------
*/
int i;
newnode->commandType = from->commandType;
+ if (from->utilityStmt && nodeTag(from->utilityStmt) == T_NotifyStmt)
+ {
+ NotifyStmt *from_notify = (NotifyStmt *) from->utilityStmt;
+ NotifyStmt *n = makeNode(NotifyStmt);
+ int length = strlen(from_notify->relname);
+
+ n->relname = palloc(length + 1);
+ strcpy(n->relname, from_notify->relname);
+ newnode->utilityStmt = (Node *) n;
+ }
newnode->resultRelation = from->resultRelation;
/* probably should dup this string instead of just pointing */
/* to the old one --djm */
newnode->into = (char *) 0;
}
newnode->isPortal = from->isPortal;
- Node_Copy(from, newnode, rtable);
- if (from->utilityStmt && nodeTag(from->utilityStmt) == T_NotifyStmt)
- {
- NotifyStmt *from_notify = (NotifyStmt *) from->utilityStmt;
- NotifyStmt *n = makeNode(NotifyStmt);
- int length = strlen(from_notify->relname);
-
- n->relname = palloc(length + 1);
- strcpy(n->relname, from_notify->relname);
- newnode->utilityStmt = (Node *) n;
- }
+ newnode->isBinary = from->isBinary;
+ newnode->unionall = from->unionall;
if (from->uniqueFlag)
{
newnode->uniqueFlag = (char *) palloc(strlen(from->uniqueFlag) + 1);
else
newnode->uniqueFlag = NULL;
Node_Copy(from, newnode, sortClause);
+ Node_Copy(from, newnode, rtable);
Node_Copy(from, newnode, targetList);
Node_Copy(from, newnode, qual);
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/rewrite/rewriteHandler.c,v 1.9 1998/01/07 21:04:37 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/rewrite/rewriteHandler.c,v 1.10 1998/01/09 05:48:17 momjian Exp $
*
*-------------------------------------------------------------------------
*/
*/
Query *other;
- other = copyObject(parsetree); /* ApplyRetrieveRule changes the
- * range table */
+ /*
+ * ApplyRetrieveRule changes the range table
+ * XXX Unions are copied again.
+ */
+ other = copyObject(parsetree);
+
return
ProcessRetrieveQuery(other, parsetree->rtable,
instead_flag, FALSE);
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/tcop/postgres.c,v 1.59 1998/01/07 21:06:00 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/backend/tcop/postgres.c,v 1.60 1998/01/09 05:48:22 momjian Exp $
*
* NOTES
* this is the "main" module of the postgres backend and
* rewrites */
for (i = 0; i < querytree_list->len; i++)
{
+ List *union_result, *union_list, *rewritten_list;
+
querytree = querytree_list->qtrees[i];
/* rewrite queries (retrieve, append, delete, replace) */
rewritten = QueryRewrite(querytree);
+
+ /*
+ * Rewrite the UNIONS.
+ */
+ foreach(rewritten_list, rewritten)
+ {
+ Query *qry = (Query *)lfirst(rewritten_list);
+ union_result = NIL;
+ foreach(union_list, qry->unionClause)
+ union_result = nconc(union_result, QueryRewrite((Query *)lfirst(union_list)));
+ qry->unionClause = union_result;
+ }
+
if (rewritten != NULL)
{
int len,
if (IsUnderPostmaster == false)
{
puts("\nPOSTGRES backend interactive interface");
- puts("$Revision: 1.59 $ $Date: 1998/01/07 21:06:00 $");
+ puts("$Revision: 1.60 $ $Date: 1998/01/09 05:48:22 $");
}
/* ----------------