From bfa8c8ea03011a370cbc9dfb69dda38ca625eb91 Mon Sep 17 00:00:00 2001
From: zhouhao <zh.sqy@qq.com>
Date: Sat, 5 Jul 2025 21:03:32 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E6=97=A0=E6=B3=95?=
 =?UTF-8?q?=E5=8D=95=E7=8B=AC=E4=BD=BF=E7=94=A8timescaledb=E9=97=AE?=
 =?UTF-8?q?=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../jetlinks/community/datasource/rdb/DefaultRDBDataSource.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/jetlinks-components/datasource-component/src/main/java/org/jetlinks/community/datasource/rdb/DefaultRDBDataSource.java b/jetlinks-components/datasource-component/src/main/java/org/jetlinks/community/datasource/rdb/DefaultRDBDataSource.java
index 95925be9..4956ef07 100644
--- a/jetlinks-components/datasource-component/src/main/java/org/jetlinks/community/datasource/rdb/DefaultRDBDataSource.java
+++ b/jetlinks-components/datasource-component/src/main/java/org/jetlinks/community/datasource/rdb/DefaultRDBDataSource.java
@@ -62,6 +62,7 @@ import java.sql.SQLException;
 import java.time.Duration;
 import java.util.List;
 import java.util.concurrent.CopyOnWriteArrayList;
+import java.util.function.Function;
 
 public class DefaultRDBDataSource extends AbstractDataSource<RDBDataSourceProperties> implements RDBDataSource {
 
@@ -247,6 +248,7 @@ public class DefaultRDBDataSource extends AbstractDataSource<RDBDataSourceProper
                     .as(transactionalOperator::transactional);
             }
         };
+        executor.setDefaultFactory(connectionPool);
         executor.setBindSymbol(dialect.getBindSymbol());
         executor.setBindCustomSymbol(!executor.getBindSymbol().equals("?"));
         RDBDatabaseMetadata database = new RDBDatabaseMetadata(dialect.getDialect());