From 225460f5221524ecebd27b28c70a5bce98827b6c Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Mon, 4 Dec 2023 09:14:24 +0800
Subject: [PATCH] =?UTF-8?q?DataJdbcSource=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/org/redkale/source/DataJdbcSource.java | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/src/main/java/org/redkale/source/DataJdbcSource.java b/src/main/java/org/redkale/source/DataJdbcSource.java
index fb8abfe4d..6f92ea224 100644
--- a/src/main/java/org/redkale/source/DataJdbcSource.java
+++ b/src/main/java/org/redkale/source/DataJdbcSource.java
@@ -2882,6 +2882,9 @@ public class DataJdbcSource extends AbstractDataSqlSource {
             if (password != null) {
                 this.connectAttrs.put("password", password);
             }
+            if (!url.contains("prepareThreshold=")) {
+                this.connectAttrs.put("prepareThreshold", "-1");
+            }
             try {
                 this.driver = DriverManager.getDriver(this.url);
             } catch (SQLException e) {
@@ -2914,6 +2917,11 @@ public class DataJdbcSource extends AbstractDataSqlSource {
                 || !Objects.equals(newPassword, this.connectAttrs.get("password")) || !Objects.equals(newUrl, url)) {
                 this.urlVersion.incrementAndGet();
             }
+            if (!newUrl.contains("prepareThreshold=")) {
+                this.connectAttrs.put("prepareThreshold", "-1");
+            } else {
+                this.connectAttrs.remove("prepareThreshold");
+            }
             this.url = newUrl;
             this.connectTimeoutSeconds = newConnectTimeoutSeconds;
             this.connectAttrs.put("user", newUser);