From f21cc6a66eae66a738720693f86f9d0377bc8969 Mon Sep 17 00:00:00 2001
From: takapi327 <i-happy-go-lucky-life0001@ezweb.ne.jp>
Date: Sun, 21 Dec 2025 22:53:54 +0900
Subject: [PATCH] Added force connection close in pool

---
 .../src/main/scala/ldbc/connector/pool/PooledDataSource.scala  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/module/ldbc-connector/shared/src/main/scala/ldbc/connector/pool/PooledDataSource.scala b/module/ldbc-connector/shared/src/main/scala/ldbc/connector/pool/PooledDataSource.scala
index ae33e225a..c98c8ef99 100644
--- a/module/ldbc-connector/shared/src/main/scala/ldbc/connector/pool/PooledDataSource.scala
+++ b/module/ldbc-connector/shared/src/main/scala/ldbc/connector/pool/PooledDataSource.scala
@@ -238,7 +238,8 @@ object PooledDataSource:
           val closeAll = state.connections.traverse_ { pooled =>
             pooled.finalizer.attempt.flatMap {
               case Left(error) =>
-                poolLogger.debug(s"Error closing connection ${ pooled.id }: ${ error.getMessage }")
+                poolLogger.debug(s"Error closing connection ${ pooled.id }: ${ error.getMessage }") >>
+                  pooled.connection.close().attempt.void
               case Right(_) =>
                 Temporal[F].unit
             }