From 30bab10438b7988adb28f4800f28470dc6da50db Mon Sep 17 00:00:00 2001
From: CookiePieWw <profsyb@gmail.com>
Date: Fri, 20 Dec 2024 18:34:59 +0800
Subject: [PATCH] fix: spawn a background connection thread

---
 src/meta-srv/src/bootstrap.rs         | 9 ++++++++-
 src/meta-srv/src/election/postgres.rs | 2 +-
 2 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/src/meta-srv/src/bootstrap.rs b/src/meta-srv/src/bootstrap.rs
index 78c28b6fbf96..5a4cd1284227 100644
--- a/src/meta-srv/src/bootstrap.rs
+++ b/src/meta-srv/src/bootstrap.rs
@@ -288,8 +288,15 @@ async fn create_postgres_client(opts: &MetasrvOptions) -> Result<tokio_postgres:
     let postgres_url = opts.store_addrs.first().context(InvalidArgumentsSnafu {
         err_msg: "empty store addrs",
     })?;
-    let (client, _) = tokio_postgres::connect(postgres_url, NoTls)
+    let (client, connection) = tokio_postgres::connect(postgres_url, NoTls)
         .await
         .context(error::ConnectPostgresSnafu)?;
+
+    tokio::spawn(async move {
+        connection
+            .await
+            .context(error::PostgresExecutionSnafu)
+            .unwrap()
+    });
     Ok(client)
 }
diff --git a/src/meta-srv/src/election/postgres.rs b/src/meta-srv/src/election/postgres.rs
index ff368aeb09d6..9da2b1dd00dd 100644
--- a/src/meta-srv/src/election/postgres.rs
+++ b/src/meta-srv/src/election/postgres.rs
@@ -304,7 +304,7 @@ mod tests {
             }
             .fail();
         }
-        let (client, connection) = tokio_postgres::connect(&addr, NoTls)
+        let (client, connection) = tokio_postgres::connect(addr, NoTls)
             .await
             .context(PostgresExecutionSnafu)?;
         tokio::spawn(async move {