修复OceanBase validateQuery问题

alibaba · Oct 20, 2022 · 569f4a6 · 569f4a6
1 parent 118c21c
commit 569f4a6
Showing 1 changed file with 2 additions and 7 deletions.
diff --git a/core/src/main/java/com/alibaba/druid/pool/vendor/OceanBaseValidConnectionChecker.java b/core/src/main/java/com/alibaba/druid/pool/vendor/OceanBaseValidConnectionChecker.java
@@ -25,8 +25,7 @@
 import java.sql.Statement;
 
 public class OceanBaseValidConnectionChecker extends ValidConnectionCheckerAdapter implements ValidConnectionChecker {
-    private String oracleModeValidateQuery = "SELECT 'x' FROM DUAL";
-    private String mysqlModeValidateQuery = "SELECT 'x'";
+    private String commonValidateQuery = "SELECT 'x' FROM DUAL";
     private DbType dbType;
 
     public OceanBaseValidConnectionChecker() {
@@ -47,11 +46,7 @@ public boolean isValidConnection(final Connection c,
         }
         if (validateQuery == null || validateQuery.isEmpty()) {
             if (dbType != null) {
-                if (dbType == DbType.oceanbase) {
-                    validateQuery = mysqlModeValidateQuery;
-                } else {
-                    validateQuery = oracleModeValidateQuery;
-                }
+                validateQuery = commonValidateQuery;
             }
         }