!3067 dblink 未释放未命名连接问题修改

Merge pull request !3067 from 陈志凯/master
2023-03-09 11:32:46 +00:00
parent c48f7075fa 7c5ebe3992
commit f28ba6b995
1 changed files with 6 additions and 0 deletions
--- a/contrib/dblink/dblink.cpp
+++ b/contrib/dblink/dblink.cpp
@ -827,6 +827,9 @@ Datum dblink_connect(PG_FUNCTION_ARGS)
            rconn->linker = olinker;
            createNewConnection(conname, rconn);
        } else {
+            if (PCONN->linker) {
+                PCONN->linker->finish();
+            }
            PCONN->linker = olinker;  
        }
    } else {
@ -844,6 +847,9 @@ Datum dblink_connect(PG_FUNCTION_ARGS)
            rconn->linker = plinker;
            createNewConnection(conname, rconn);
        } else {
+            if (PCONN->linker) {
+                PCONN->linker->finish();
+            }
            PCONN->linker = plinker;       
        }
    }