From e9c35fcc3c43f5286c1a25bf0fb964e3fad3c49a Mon Sep 17 00:00:00 2001
From: fengshuonan <sn93@qq.com>
Date: Thu, 15 Sep 2022 13:50:18 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=907.2.5=E3=80=91=E3=80=90db=E3=80=91?=
 =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=A0=A1=E9=AA=8C=E6=95=B0=E6=8D=AE=E5=BA=93?=
 =?UTF-8?q?=E8=BF=9E=E6=8E=A5=E6=80=A7=E7=9A=84=E5=B7=A5=E5=85=B7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../kernel/rule/util/DbConnectionUtil.java    | 45 +++++++++++++++++++
 1 file changed, 45 insertions(+)
 create mode 100644 kernel-a-rule/src/main/java/cn/stylefeng/roses/kernel/rule/util/DbConnectionUtil.java

diff --git a/kernel-a-rule/src/main/java/cn/stylefeng/roses/kernel/rule/util/DbConnectionUtil.java b/kernel-a-rule/src/main/java/cn/stylefeng/roses/kernel/rule/util/DbConnectionUtil.java
new file mode 100644
index 000000000..5aecf779c
--- /dev/null
+++ b/kernel-a-rule/src/main/java/cn/stylefeng/roses/kernel/rule/util/DbConnectionUtil.java
@@ -0,0 +1,45 @@
+package cn.stylefeng.roses.kernel.rule.util;
+
+import cn.hutool.db.DbUtil;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+
+/**
+ * 数据库检测相关的工具
+ *
+ * @author fengshuonan
+ * @date 2022/9/15 11:50
+ */
+public class DbConnectionUtil {
+
+    /**
+     * 检测数据库的链接是否连通，默认5秒超时
+     *
+     * @author fengshuonan
+     * @date 2022/9/15 11:49
+     */
+    public static boolean getValidFlag(String className, String url, String account, String password) {
+        return getValidFlag(className, url, account, password, 5);
+    }
+
+    /**
+     * 检测数据库的链接是否连通
+     *
+     * @author fengshuonan
+     * @date 2022/9/15 11:49
+     */
+    public static boolean getValidFlag(String className, String url, String account, String password, Integer timeoutSeconds) {
+        Connection connection = null;
+        try {
+            Class.forName(className);
+            connection = DriverManager.getConnection(url, account, password);
+            return connection.isValid(timeoutSeconds);
+        } catch (Exception e) {
+            return false;
+        } finally {
+            DbUtil.close(connection);
+        }
+    }
+
+}