Java：MultiDataSource 新增 DuckDB 版

Author: TommyLemon

APIJSON-Java-Server/APIJSONBoot-MultiDataSource/pom.xml

@@ -56,11 +56,11 @@
 
 
         <!-- 可使用 libs 目录的 apijson-orm.jar, apijson-framework.jar, apijson-column.jar 来替代，两种方式二选一 <<<<<<<<<< -->
-        <dependency>
-            <groupId>com.github.Tencent</groupId>
-            <artifactId>APIJSON</artifactId>
-            <version>7.0.3</version>
-        </dependency>
+<!--        <dependency>-->
+<!--            <groupId>com.github.Tencent</groupId>-->
+<!--            <artifactId>APIJSON</artifactId>-->
+<!--            <version>7.2.0</version>-->
+<!--        </dependency>-->
         <dependency>
             <groupId>com.github.APIJSON</groupId>
             <artifactId>apijson-framework</artifactId>

APIJSON-Java-Server/APIJSONBoot-MultiDataSource/src/main/java/apijson/boot/DemoApplication.java

@@ -204,6 +204,16 @@ public void addCorsMappings(CorsRegistry registry) {
             Log.e(TAG, "加载 IoTDB 驱动失败，请检查 pom.xml 中 org.apache.iotdb.jdbc 版本是否存在以及可用 ！！！");
         }
 
+        try { //加载驱动程序
+            Log.d(TAG, "尝试加载 DuckDB 驱动 <<<<<<<<<<<<<<<<<<<<< ");
+            Class.forName("org.duckdb.DuckDBDriver");
+            Log.d(TAG, "成功加载 DuckDB 驱动！>>>>>>>>>>>>>>>>>>>>> ");
+        }
+        catch (ClassNotFoundException e) {
+            e.printStackTrace();
+            Log.e(TAG, "加载 DuckDB 驱动失败，请检查 pom.xml 中 org.duckdb 版本是否存在以及可用 ！！！");
+        }
+
         //    try { //加载驱动程序
         //      Log.d(TAG, "尝试加载 TDengine 驱动 <<<<<<<<<<<<<<<<<<<<< ");
         //      Class.forName("com.taosdata.jdbc.TSDBDriver");

APIJSON-Java-Server/APIJSONBoot-MultiDataSource/src/main/java/apijson/demo/DemoSQLConfig.java

@@ -180,6 +180,9 @@ public String getDBVersion() {
 		if (isCassandra()) {
 			return "4.0.1"; //TODO 改成你自己的
 		}
+		if (isDuckDB()) {
+			return "1.1.3"; //TODO 改成你自己的
+		}
 
 		return null;
 	}
@@ -225,19 +228,22 @@ public String getDBUri() {
 			return "jdbc:TAOS-RS://localhost:6041"; //TODO 改成你自己的
 		}
 		if (isInfluxDB()) {
-			return "http://203.189.6.3:8086";
+			return "http://203.189.6.3:8086"; //TODO 改成你自己的
 		}
 		if (isMilvus()) {
-			return "http://localhost:19530";
+			return "http://localhost:19530"; //TODO 改成你自己的
 		}
 		if (isIoTDB()) {
-			return "jdbc:iotdb://localhost:6667"; // ?charset=GB18030 加参数会报错 URI 格式错误
+			return "jdbc:iotdb://localhost:6667"; // ?charset=GB18030 加参数会报错 URI 格式错误 //TODO 改成你自己的
 		}
 		if (isMongoDB()) {
-			return "jdbc:mongodb://atlas-sql-6593c65c296c5865121e6ebe-xxskv.a.query.mongodb.net/myVirtualDatabase?ssl=true&authSource=admin";
+			return "jdbc:mongodb://atlas-sql-6593c65c296c5865121e6ebe-xxskv.a.query.mongodb.net/myVirtualDatabase?ssl=true&authSource=admin"; //TODO 改成你自己的
 		}
 		if (isCassandra()) {
-			return "http://localhost:7001";
+			return "http://localhost:7001"; //TODO 改成你自己的
+		}
+		if (isDuckDB()) {
+			return "jdbc:duckdb:/Users/tommylemon/my_database.duckdb"; //TODO 改成你自己的
 		}
 
 		return null;
@@ -294,6 +300,9 @@ public String getDBAccount() {
 		if (isCassandra()) {
 			return "root"; //TODO 改成你自己的
 		}
+		if (isDuckDB()) {
+			return "root"; //TODO 改成你自己的
+		}
 
 		return null;
 	}
@@ -349,6 +358,9 @@ public String getDBPassword() {
 		if (isCassandra()) {
 			return "apijson";  //TODO 改成你自己的
 		}
+		if (isDuckDB()) {
+			return ""; //TODO 改成你自己的
+		}
 
 		return null;
 	}

APIJSON-Java-Server/APIJSONBoot-MultiDataSource/src/main/java/apijson/demo/DemoSQLExecutor.java

@@ -25,6 +25,7 @@
 import apijson.orm.SQLConfig;
 import com.alibaba.druid.pool.DruidDataSource;
 import com.alibaba.fastjson.JSONObject;
+//import org.duckdb.JsonNode;
 import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
 import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
 import org.springframework.data.redis.core.RedisTemplate;
@@ -303,6 +304,10 @@ public void close() {
 //    @Override
 //    protected Object getValue(SQLConfig<Long> config, ResultSet rs, ResultSetMetaData rsmd, int tablePosition, JSONObject table, int columnIndex, String lable, Map<String, JSONObject> childMap) throws Exception {
 //        Object v = super.getValue(config, rs, rsmd, tablePosition, table, columnIndex, lable, childMap);
-//        return MongoUtil.getValue(v);
+////        if (v instanceof JsonNode) { // DuckDB json 类型需要转换
+////            JsonNode jn = (JsonNode) v;
+////            v = jn.isNull() ? null : JSON.parse(jn.toString());
+////        }
+//        return v; // MongoUtil.getValue(v);
 //    }
 }