dblink代码逻辑调整

2023-05-15 17:23:57 +08:00
parent 723d2f5d3d
commit 7cdc608d97
1 changed files with 5 additions and 4 deletions
--- a/contrib/dblink/dblink.cpp
+++ b/contrib/dblink/dblink.cpp
@ -1486,12 +1486,13 @@ static void storeRow(storeInfo* sinfo, PGresult* res, bool first)
     */
    oldcontext = MemoryContextSwitchTo(sinfo->tmpcontext);

-     /* Should have a single-row result if we get here */
-    Assert(PQntuples(res) == 1);
-
    /* Done if empty resultset */
    if (PQntuples(res) == 0)
-            return;
+        return;
+
+     /* Should have a single-row result if we get here */
+    Assert(PQntuples(res) == 1);
+    
    /*
     * Fill cstrs with null-terminated strings of column values.
     */