新增支持 Databend - 带 AI 的新一代云原生数据湖仓(Snowflake 开源替代)

Author: TommyLemon

APIJSONORM/src/main/java/apijson/orm/AbstractSQLConfig.java

@@ -190,6 +190,7 @@ public abstract class AbstractSQLConfig<T, M extends Map<String, Object>, L exte
 		DATABASE_LIST.add(DATABASE_QUESTDB);
 		DATABASE_LIST.add(DATABASE_IOTDB);
 		DATABASE_LIST.add(DATABASE_SNOWFLAKE);
+		DATABASE_LIST.add(DATABASE_DATABEND);
 		DATABASE_LIST.add(DATABASE_DATABRICKS);
 		DATABASE_LIST.add(DATABASE_REDIS);
 		DATABASE_LIST.add(DATABASE_MONGODB);
@@ -1252,6 +1253,14 @@ public static boolean isSnowflake(String db) {
 		return DATABASE_SNOWFLAKE.equals(db);
 	}
 
+	@Override
+	public boolean isDatabend() {
+		return isDatabend(gainSQLDatabase());
+	}
+	public static boolean isDatabend(String db) {
+		return DATABASE_DATABEND.equals(db);
+	}
+
 	@Override
 	public boolean isDatabricks() {
 		return isDatabricks(gainSQLDatabase());

APIJSONORM/src/main/java/apijson/orm/SQLConfig.java

@@ -35,6 +35,7 @@ public interface SQLConfig<T, M extends Map<String, Object>, L extends List<Obje
 	String DATABASE_TRINO = "TRINO"; // PrestoSQL  https://trino.io
 	String DATABASE_DORIS = "DORIS"; // https://doris.apache.org
 	String DATABASE_SNOWFLAKE = "SNOWFLAKE"; // https://www.snowflake.com
+	String DATABASE_DATABEND = "DATABEND"; // https://www.databend.com
 	String DATABASE_DATABRICKS = "DATABRICKS"; // https://www.databricks.com
 	String DATABASE_CASSANDRA = "CASSANDRA"; // https://cassandra.apache.org
 	String DATABASE_MILVUS = "MILVUS"; // https://milvus.io
@@ -100,6 +101,7 @@ public interface SQLConfig<T, M extends Map<String, Object>, L extends List<Obje
 	boolean isPresto();
 	boolean isTrino();
 	boolean isSnowflake();
+	boolean isDatabend();
 	boolean isDatabricks();
 	boolean isCassandra();
 	boolean isMilvus();

APIJSONORM/src/main/java/apijson/orm/exception/CommonException.java

@@ -253,6 +253,9 @@ else if (config.isDoris()) {
         else if (config.isSnowflake()) {
           db = SQLConfig.DATABASE_SNOWFLAKE + " " + dbVersion;
         }
+        else if (config.isDatabend()) {
+          db = SQLConfig.DATABASE_DATABEND + " " + dbVersion;
+        }
         else if (config.isDatabricks()) {
           db = SQLConfig.DATABASE_DATABRICKS + " " + dbVersion;
         }