Skip to content

Commit e20074d

Browse files
committed
feat: support StarRocks - The world's fastest open query engine for sub-second analytics both on and off the data lakehouse
1 parent ee359ae commit e20074d

5 files changed

Lines changed: 17 additions & 3 deletions

File tree

APIJSONORM/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55

66
<groupId>com.github.Tencent</groupId>
77
<artifactId>APIJSON</artifactId>
8-
<version>8.1.8</version>
8+
<version>8.2.0</version>
99
<packaging>jar</packaging>
1010

1111
<name>APIJSONORM</name>

APIJSONORM/src/main/java/apijson/Log.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
*/
1313
public class Log {
1414
public static boolean DEBUG = false;
15-
public static final String VERSION = "8.1.8";
15+
public static final String VERSION = "8.2.0";
1616

1717
public static final String LEVEL_VERBOSE = "VERBOSE";
1818
public static final String LEVEL_INFO = "INFO";

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

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -178,6 +178,7 @@ public abstract class AbstractSQLConfig<T, M extends Map<String, Object>, L exte
178178
DATABASE_LIST.add(DATABASE_SURREALDB);
179179
DATABASE_LIST.add(DATABASE_OPENGAUSS);
180180
DATABASE_LIST.add(DATABASE_DORIS);
181+
DATABASE_LIST.add(DATABASE_STARROCKS);
181182

182183

183184
RAW_MAP = new LinkedHashMap<>(); // 保证顺序,避免配置冲突等意外情况
@@ -1375,12 +1376,20 @@ public static boolean isDoris(String db) {
13751376
return DATABASE_DORIS.equals(db);
13761377
}
13771378

1379+
@Override
1380+
public boolean isStarRocks() {
1381+
return isStarRocks(gainSQLDatabase());
1382+
}
1383+
public static boolean isStarRocks(String db) {
1384+
return DATABASE_STARROCKS.equals(db);
1385+
}
1386+
13781387
@Override
13791388
public String getQuote() { // MongoDB 同时支持 `tbl` 反引号 和 "col" 双引号
13801389
if(isElasticsearch() || isManticore() || isIoTDB() || isSurrealDB()) {
13811390
return "";
13821391
}
1383-
return isMySQL() || isMariaDB() || isTiDB() || isClickHouse() || isTDengine() || isMilvus() || isDoris() ? "`" : "\"";
1392+
return isMySQL() || isMariaDB() || isTiDB() || isClickHouse() || isTDengine() || isMilvus() || isDoris() || isStarRocks() ? "`" : "\"";
13841393
}
13851394

13861395
public String quote(String s) {

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@ public interface SQLConfig<T, M extends Map<String, Object>, L extends List<Obje
5252
String DATABASE_DUCKDB = "DUCKDB"; // https://duckdb.org
5353
String DATABASE_SURREALDB = "SURREALDB"; // https://surrealdb.com
5454
String DATABASE_OPENGAUSS = "OPENGAUSS"; // https://opengauss.org
55+
String DATABASE_STARROCKS = "STARROCKS"; // https://docs.starrocks.io/zh/docs/quick_start/shared-nothing
5556

5657
String DATABASE_MQ = "MQ"; //
5758

@@ -119,6 +120,7 @@ public interface SQLConfig<T, M extends Map<String, Object>, L extends List<Obje
119120
boolean isSurrealDB();
120121
boolean isOpenGauss();
121122
boolean isDoris();
123+
boolean isStarRocks();
122124

123125

124126
// 暂时只兼容以上几种

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -250,6 +250,9 @@ else if (config.isTrino()) {
250250
else if (config.isDoris()) {
251251
db = SQLConfig.DATABASE_DORIS + " " + dbVersion;
252252
}
253+
else if (config.isStarRocks()) {
254+
db = SQLConfig.DATABASE_STARROCKS + " " + dbVersion;
255+
}
253256
else if (config.isSnowflake()) {
254257
db = SQLConfig.DATABASE_SNOWFLAKE + " " + dbVersion;
255258
}

0 commit comments

Comments
 (0)