diff --git a/casic-metering-common/src/main/java/com/casic/missiles/config/druid/BusDruidDataSource.java b/casic-metering-common/src/main/java/com/casic/missiles/config/druid/BusDruidDataSource.java index 118811f..4ec6530 100644 --- a/casic-metering-common/src/main/java/com/casic/missiles/config/druid/BusDruidDataSource.java +++ b/casic-metering-common/src/main/java/com/casic/missiles/config/druid/BusDruidDataSource.java @@ -1,8 +1,6 @@ package com.casic.missiles.config.druid; import com.alibaba.druid.pool.DruidDataSource; -import com.alibaba.druid.pool.DruidPooledConnection; -import lombok.extern.slf4j.Slf4j; import java.sql.Connection; import java.sql.DriverManager; @@ -13,7 +11,6 @@ * @Author: wangpeng * @Date: 2023/6/16 18:04 */ -@Slf4j public class BusDruidDataSource extends DruidDataSource { private boolean lastInited; @@ -36,18 +33,6 @@ } } - private boolean isDatabaseAvailable() { - try { - DruidPooledConnection connection = this.getConnection(10000); - connection.nativeSQL("SELECT 1"); - // 如果查询成功,则返回 true,说明数据库可用 - return true; - } catch (SQLException e) { - // 发生异常,则返回 false,说明数据库不可用 - return false; - } - } - class ValidateUrlTask implements Runnable { @Override public void run() { @@ -57,7 +42,7 @@ break; } //如果这个数据源已经被初始化了,同时连接异常才进行处理 - if (isInited() && !isDatabaseAvailable()) { + if (isInited() && isFailContinuous()) { for (String thisUrl : urls) { Connection connection = null; try {