From a94d1d1b0c4e927958965797c18549b8f87d00b2 Mon Sep 17 00:00:00 2001
From: robot-clickhouse <robot-clickhouse@users.noreply.github.com>
Date: Mon, 1 Jul 2024 14:08:35 +0000
Subject: [PATCH] Backport #65771 to 24.5: PostgreSQL source support cancel
 query

---
 src/Processors/Sources/PostgreSQLSource.cpp | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/src/Processors/Sources/PostgreSQLSource.cpp b/src/Processors/Sources/PostgreSQLSource.cpp
index 4b828d6699c..66b6398f873 100644
--- a/src/Processors/Sources/PostgreSQLSource.cpp
+++ b/src/Processors/Sources/PostgreSQLSource.cpp
@@ -191,6 +191,12 @@ PostgreSQLSource<T>::~PostgreSQLSource()
     {
         try
         {
+            if (stream)
+            {
+                tx->conn().cancel_query();
+                stream->close();
+            }
+
             stream.reset();
             tx.reset();
         }