From d9b86885dbe47e69de7be8c1700daf56f48af58e Mon Sep 17 00:00:00 2001
From: ljc <1194570458@qq.com>
Date: Thu, 2 Nov 2023 17:40:12 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E9=87=8D=E5=A4=8D?=
 =?UTF-8?q?=E9=80=89=E4=B8=AD=E6=95=B0=E6=8D=AE=E5=BA=93=E7=9A=84=E9=97=AE?=
 =?UTF-8?q?=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ai/chat2db/plugin/clickhouse/ClickHouseDBManage.java    | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/chat2db-server/chat2db-plugins/chat2db-clickhouse/src/main/java/ai/chat2db/plugin/clickhouse/ClickHouseDBManage.java b/chat2db-server/chat2db-plugins/chat2db-clickhouse/src/main/java/ai/chat2db/plugin/clickhouse/ClickHouseDBManage.java
index 94209052..4bf54439 100644
--- a/chat2db-server/chat2db-plugins/chat2db-clickhouse/src/main/java/ai/chat2db/plugin/clickhouse/ClickHouseDBManage.java
+++ b/chat2db-server/chat2db-plugins/chat2db-clickhouse/src/main/java/ai/chat2db/plugin/clickhouse/ClickHouseDBManage.java
@@ -29,10 +29,14 @@ public class ClickHouseDBManage extends DefaultDBManage implements DBManage {
 
         String connectAddress = connectInfo.getHost() + ":" + connectInfo.getPort();
         String[] addressSplit = url.split(connectAddress);
-        String connectParams = addressSplit[1];
+        String connectParams = addressSplit.length == 2 ? addressSplit[1] : "";
         if (connectParams.startsWith("/")) {
             // 删除连接参数中的 /
             connectParams = connectParams.substring(1);
+            if(connectParams.startsWith(databaseName)){
+                // 删除连接参数中的数据库名
+                connectParams = connectParams.substring(databaseName.length());
+            }
         }
         // 添加数据库名
         return addressSplit[0] + connectAddress + "/" + databaseName + connectParams;