Commit 4fed749
committed
新增支持 Doris-高性能实时湖仓一体数据库：https://doris.apache.org
1 parent 107fd37 commit 4fed749
3 files changed
Lines changed: 16 additions & 1 deletion
File tree
- APIJSONORM/src/main/java/apijson/orm
- exception
Lines changed: 11 additions & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -199,6 +199,7 @@ public abstract class AbstractSQLConfig<T, M extends Map<String, Object>, L exte | |||
| 199 | 199 | DATABASE_LIST.add(DATABASE_DUCKDB); | |
| 200 | 200 | DATABASE_LIST.add(DATABASE_SURREALDB); | |
| 201 | 201 | DATABASE_LIST.add(DATABASE_OPENGAUSS); | |
| 202 | + DATABASE_LIST.add(DATABASE_DORIS); | ||
| 202 | 203 | ||
| 203 | 204 | ||
| 204 | 205 | RAW_MAP = new LinkedHashMap<>(); // 保证顺序，避免配置冲突等意外情况 | |
@@ -298,6 +299,7 @@ public abstract class AbstractSQLConfig<T, M extends Map<String, Object>, L exte | |||
| 298 | 299 | RAW_MAP.put("BY", ""); | |
| 299 | 300 | RAW_MAP.put("DESC", ""); | |
| 300 | 301 | RAW_MAP.put("ASC", ""); | |
| 302 | + RAW_MAP.put("PRECEDING", ""); // 往前 | ||
| 301 | 303 | RAW_MAP.put("FOLLOWING", ""); // 往后 | |
| 302 | 304 | RAW_MAP.put("BETWEEN", ""); | |
| 303 | 305 | RAW_MAP.put("ROWS", ""); | |
@@ -1379,12 +1381,20 @@ public static boolean isOpenGauss(String db) { | |||
| 1379 | 1381 | return DATABASE_OPENGAUSS.equals(db); | |
| 1380 | 1382 | } | |
| 1381 | 1383 | ||
| 1384 | + @Override | ||
| 1385 | + public boolean isDoris() { | ||
| 1386 | + return isDoris(gainSQLDatabase()); | ||
| 1387 | + } | ||
| 1388 | + public static boolean isDoris(String db) { | ||
| 1389 | + return DATABASE_DORIS.equals(db); | ||
| 1390 | + } | ||
| 1391 | + | ||
| 1382 | 1392 | @Override | |
| 1383 | 1393 | public String getQuote() { // MongoDB 同时支持 `tbl` 反引号 和 "col" 双引号 | |
| 1384 | 1394 | if(isElasticsearch() || isManticore() || isIoTDB() || isSurrealDB()) { | |
| 1385 | 1395 | return ""; | |
| 1386 | 1396 | } | |
| 1387 | - return isMySQL() || isMariaDB() || isTiDB() || isClickHouse() || isTDengine() || isMilvus() ? "`" : "\""; | ||
| 1397 | + return isMySQL() || isMariaDB() || isTiDB() || isClickHouse() || isTDengine() || isMilvus() || isDoris() ? "`" : "\""; | ||
| 1388 | 1398 | } | |
| 1389 | 1399 | ||
| 1390 | 1400 | public String quote(String s) { | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -33,6 +33,7 @@ public interface SQLConfig<T, M extends Map<String, Object>, L extends List<Obje | |||
| 33 | 33 | String DATABASE_HIVE = "HIVE"; // https://hive.apache.org | |
| 34 | 34 | String DATABASE_PRESTO = "PRESTO"; // Facebook PrestoDB https://prestodb.io | |
| 35 | 35 | String DATABASE_TRINO = "TRINO"; // PrestoSQL https://trino.io | |
| 36 | + String DATABASE_DORIS = "DORIS"; // https://doris.apache.org | ||
| 36 | 37 | String DATABASE_SNOWFLAKE = "SNOWFLAKE"; // https://www.snowflake.com | |
| 37 | 38 | String DATABASE_DATABRICKS = "DATABRICKS"; // https://www.databricks.com | |
| 38 | 39 | String DATABASE_CASSANDRA = "CASSANDRA"; // https://cassandra.apache.org | |
@@ -115,6 +116,7 @@ public interface SQLConfig<T, M extends Map<String, Object>, L extends List<Obje | |||
| 115 | 116 | boolean isDuckDB(); | |
| 116 | 117 | boolean isSurrealDB(); | |
| 117 | 118 | boolean isOpenGauss(); | |
| 119 | + boolean isDoris(); | ||
| 118 | 120 | ||
| 119 | 121 | ||
| 120 | 122 | // 暂时只兼容以上几种 | |
Lines changed: 3 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -247,6 +247,9 @@ else if (config.isPresto()) { | |||
| 247 | 247 | else if (config.isTrino()) { | |
| 248 | 248 | db = SQLConfig.DATABASE_TRINO + " " + dbVersion; | |
| 249 | 249 | } | |
| 250 | + else if (config.isDoris()) { | ||
| 251 | + db = SQLConfig.DATABASE_DORIS + " " + dbVersion; | ||
| 252 | + } | ||
| 250 | 253 | else if (config.isSnowflake()) { | |
| 251 | 254 | db = SQLConfig.DATABASE_SNOWFLAKE + " " + dbVersion; | |
| 252 | 255 | } | |
0 commit comments