diff options
Diffstat (limited to 'src/backend/commands')
| -rw-r--r-- | src/backend/commands/createas.c | 2 | ||||
| -rw-r--r-- | src/backend/commands/portalcmds.c | 14 |
2 files changed, 5 insertions, 11 deletions
diff --git a/src/backend/commands/createas.c b/src/backend/commands/createas.c index fcb03313092..cb7a145ee5d 100644 --- a/src/backend/commands/createas.c +++ b/src/backend/commands/createas.c @@ -197,7 +197,7 @@ ExecCreateTableAs(CreateTableAsStmt *stmt, const char *queryString, /* save the rowcount if we're given a completionTag to fill */ if (completionTag) snprintf(completionTag, COMPLETION_TAG_BUFSIZE, - "SELECT %u", queryDesc->estate->es_processed); + "SELECT " UINT64_FORMAT, queryDesc->estate->es_processed); /* and clean up */ ExecutorFinish(queryDesc); diff --git a/src/backend/commands/portalcmds.c b/src/backend/commands/portalcmds.c index 8c045c090b4..50a54e74633 100644 --- a/src/backend/commands/portalcmds.c +++ b/src/backend/commands/portalcmds.c @@ -148,7 +148,7 @@ PerformPortalFetch(FetchStmt *stmt, char *completionTag) { Portal portal; - long nprocessed; + uint64 nprocessed; /* * Disallow empty-string cursor name (conflicts with protocol-level @@ -181,7 +181,7 @@ PerformPortalFetch(FetchStmt *stmt, /* Return command status if wanted */ if (completionTag) - snprintf(completionTag, COMPLETION_TAG_BUFSIZE, "%s %ld", + snprintf(completionTag, COMPLETION_TAG_BUFSIZE, "%s " UINT64_FORMAT, stmt->ismove ? "MOVE" : "FETCH", nprocessed); } @@ -392,20 +392,14 @@ PersistHoldablePortal(Portal portal) if (portal->atEnd) { /* - * We can handle this case even if posOverflow: just force the - * tuplestore forward to its end. The size of the skip request - * here is arbitrary. + * Just force the tuplestore forward to its end. The size of the + * skip request here is arbitrary. */ while (tuplestore_skiptuples(portal->holdStore, 1000000, true)) /* continue */ ; } else { - if (portal->posOverflow) /* oops, cannot trust portalPos */ - ereport(ERROR, - (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE), - errmsg("could not reposition held cursor"))); - tuplestore_rescan(portal->holdStore); if (!tuplestore_skiptuples(portal->holdStore, |