From 426e8e463a01523389f784f09c7dbaaecbb697ae Mon Sep 17 00:00:00 2001 From: redkale Date: Sat, 7 Sep 2024 12:48:11 +0800 Subject: [PATCH] =?UTF-8?q?=E6=A0=BC=E5=BC=8F=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/org/redkale/source/AbstractDataSqlSource.java | 3 ++- src/main/java/org/redkale/source/DataSources.java | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/redkale/source/AbstractDataSqlSource.java b/src/main/java/org/redkale/source/AbstractDataSqlSource.java index f57b35ad1..84d540eaf 100644 --- a/src/main/java/org/redkale/source/AbstractDataSqlSource.java +++ b/src/main/java/org/redkale/source/AbstractDataSqlSource.java @@ -483,8 +483,9 @@ public abstract class AbstractDataSqlSource extends AbstractDataSource if (pos > 0) { url = url.substring(0, pos) + "..."; } + String nb = clientNonBlocking ? (", " + DATA_SOURCE_NON_BLOCKING + "=true") : ""; return getClass().getSimpleName() + "{url=" + url + ", maxconns=" + readMaxConns() + ", dbtype=" + dbtype() - + ", " + DATA_SOURCE_TABLE_AUTODDL + "=" + autoDDL + executorToString() + "}"; + + nb + ", " + DATA_SOURCE_TABLE_AUTODDL + "=" + autoDDL + executorToString() + "}"; } else { String readUrl = readConfProps.getProperty(DATA_SOURCE_URL); int pos = readUrl.indexOf('?'); diff --git a/src/main/java/org/redkale/source/DataSources.java b/src/main/java/org/redkale/source/DataSources.java index f19b3a560..ea3f121a2 100644 --- a/src/main/java/org/redkale/source/DataSources.java +++ b/src/main/java/org/redkale/source/DataSources.java @@ -62,10 +62,10 @@ public final class DataSources { // @since 2.8.0 //超过多少毫秒视为较慢, 会打印警告级别的日志, 默认值: 3000 public static final String DATA_SOURCE_SLOWMS_ERROR = "error-slowms"; - + // @since 2.8.0 //是否非阻塞式 public static final String DATA_SOURCE_NON_BLOCKING = "non-blocking"; - + // @since 2.8.0 //sourceExecutor线程数, 默认值: 内核数 public static final String DATA_SOURCE_THREADS = "threads";