]> granicus.if.org Git - postgresql/commitdiff
Fix portal management code to support non-default command completion tags for
authorTom Lane <tgl@sss.pgh.pa.us>
Sun, 18 Feb 2007 19:49:30 +0000 (19:49 +0000)
committerTom Lane <tgl@sss.pgh.pa.us>
Sun, 18 Feb 2007 19:49:30 +0000 (19:49 +0000)
portals using PORTAL_UTIL_SELECT strategy.  This is currently significant only
for FETCH queries, which are supposed to include a count in the tag.  Seems
it's been broken since 7.4, but nobody noticed before Knut Lehre.

src/backend/tcop/pquery.c

index 62310f7c0cd8a2292a407afe6b8f6345459b36ed..269988121dab6e8338d79662ea8f175732a6e735 100644 (file)
@@ -8,7 +8,7 @@
  *
  *
  * IDENTIFICATION
- *       $PostgreSQL: pgsql/src/backend/tcop/pquery.c,v 1.111 2006/10/04 00:29:58 momjian Exp $
+ *       $PostgreSQL: pgsql/src/backend/tcop/pquery.c,v 1.111.2.1 2007/02/18 19:49:30 tgl Exp $
  *
  *-------------------------------------------------------------------------
  */
@@ -919,6 +919,8 @@ FillPortalStore(Portal portal)
        PortalCreateHoldStore(portal);
        treceiver = CreateDestReceiver(DestTuplestore, portal);
 
+       completionTag[0] = '\0';
+
        switch (portal->strategy)
        {
                case PORTAL_ONE_RETURNING:
@@ -929,13 +931,11 @@ FillPortalStore(Portal portal)
                         * tuplestore. Auxiliary query outputs are discarded.
                         */
                        PortalRunMulti(portal, treceiver, None_Receiver, completionTag);
-                       /* Override default completion tag with actual command result */
-                       portal->commandTag = pstrdup(completionTag);
                        break;
 
                case PORTAL_UTIL_SELECT:
                        PortalRunUtility(portal, linitial(portal->parseTrees),
-                                                        treceiver, NULL);
+                                                        treceiver, completionTag);
                        break;
 
                default:
@@ -944,6 +944,10 @@ FillPortalStore(Portal portal)
                        break;
        }
 
+       /* Override default completion tag with actual command result */
+       if (completionTag[0] != '\0')
+               portal->commandTag = pstrdup(completionTag);
+
        (*treceiver->rDestroy) (treceiver);
 }