【8.0.1】更新sql接口规范

kernel-a-rule/src/main/java/cn/stylefeng/roses/kernel/rule/enums/DbTypeEnum.java

@@ -36,17 +36,22 @@ public enum DbTypeEnum {
     /**
      * 达梦（使用oracle的mapping.xml）
      */
-    DM("jdbc:dm", "oracle", "select 1 from dual"),
+    DM("jdbc:dm", "dm", "select 1 from dual"),
 
     /**
      * 海量数据库
      */
-    VAST_DATA("jdbc:vastbase", "pgsql", "select version()"),
+    VAST_DATA("jdbc:vastbase", "vastbase", "select version()"),
 
     /**
      * 人大金仓
      */
-    KING_BASE("jdbc:kingbase8", "pgsql", "select version()");
+    KING_BASE("jdbc:kingbase8", "kingbase8", "select version()"),
+
+    /**
+     * 华为OpenGauss
+     */
+    OPEN_GAUSS("jdbc:opengauss", "opengauss", "select version()");
 
     /**
      * spring.datasource.url中包含的关键字

kernel-d-db/db-api/src/main/java/cn/stylefeng/roses/kernel/db/api/sqladapter/AbstractSql.java

@@ -65,6 +65,9 @@ public abstract class AbstractSql {
         if (jdbcUrl.contains(DbTypeEnum.KING_BASE.getUrlWords())) {
             return kingbase();
         }
+        if (jdbcUrl.contains(DbTypeEnum.OPEN_GAUSS.getUrlWords())) {
+            return openGauss();
+        }
         return mysql();
     }
 
@@ -131,4 +134,13 @@ public abstract class AbstractSql {
      */
     protected abstract String vastbase();
 
+    /**
+     * 华为的OpenGauss sql
+     *
+     * @return 具体的sql
+     * @author fengshuonan
+     * @since 2023/10/20 13:46
+     */
+    protected abstract String openGauss();
+
 }

kernel-d-db/db-api/src/main/java/cn/stylefeng/roses/kernel/db/api/sqladapter/database/CreateDatabaseSql.java

@@ -73,4 +73,9 @@ public class CreateDatabaseSql extends AbstractSql {
         return pgSql();
     }
 
+    @Override
+    protected String openGauss() {
+        return pgSql();
+    }
+
 }

kernel-d-db/db-api/src/main/java/cn/stylefeng/roses/kernel/db/api/sqladapter/database/DropDatabaseSql.java

@@ -71,4 +71,9 @@ public class DropDatabaseSql extends AbstractSql {
         return pgSql();
     }
 
+    @Override
+    protected String openGauss() {
+        return pgSql();
+    }
+
 }

kernel-d-db/db-api/src/main/java/cn/stylefeng/roses/kernel/db/api/sqladapter/database/GetDatabasesSql.java

@@ -71,4 +71,9 @@ public class GetDatabasesSql extends AbstractSql {
         return pgSql();
     }
 
+    @Override
+    protected String openGauss() {
+        return pgSql();
+    }
+
 }

kernel-d-db/db-api/src/main/java/cn/stylefeng/roses/kernel/db/api/sqladapter/table/TableFieldListSql.java

@@ -87,4 +87,9 @@ public class TableFieldListSql extends AbstractSql {
         return pgSql();
     }
 
+    @Override
+    protected String openGauss() {
+        return pgSql();
+    }
+
 }

kernel-d-db/db-api/src/main/java/cn/stylefeng/roses/kernel/db/api/sqladapter/table/TableListSql.java

@@ -90,4 +90,9 @@ public class TableListSql extends AbstractSql {
         return pgSql();
     }
 
+    @Override
+    protected String openGauss() {
+        return pgSql();
+    }
+
 }

kernel-d-ds-container/ds-container-sdk/src/main/java/cn/stylefeng/roses/kernel/dsctn/persist/sqladapter/AddDatabaseInfoSql.java

@@ -47,4 +47,9 @@ public class AddDatabaseInfoSql extends AbstractSql {
         return pgSql();
     }
 
+    @Override
+    protected String openGauss() {
+        return pgSql();
+    }
+
 }

kernel-d-ds-container/ds-container-sdk/src/main/java/cn/stylefeng/roses/kernel/dsctn/persist/sqladapter/DatabaseListSql.java

@@ -70,4 +70,10 @@ public class DatabaseListSql extends AbstractSql {
     protected String vastbase() {
         return pgSql();
     }
+
+    @Override
+    protected String openGauss() {
+        return pgSql();
+    }
+
 }

kernel-d-ds-container/ds-container-sdk/src/main/java/cn/stylefeng/roses/kernel/dsctn/persist/sqladapter/DeleteDatabaseInfoSql.java

@@ -70,4 +70,10 @@ public class DeleteDatabaseInfoSql extends AbstractSql {
     protected String vastbase() {
         return pgSql();
     }
+
+    @Override
+    protected String openGauss() {
+        return pgSql();
+    }
+
 }