td:时序数据库相关代码

dk-modules/system/pom.xml

@@ -92,7 +92,11 @@
             <groupId>org.dromara</groupId>
             <artifactId>common-encrypt</artifactId>
         </dependency>
-
+        <dependency>
+            <groupId>com.taosdata.jdbc</groupId>
+            <artifactId>taos-jdbcdriver</artifactId>
+            <version>3.3.3</version>
+        </dependency>
         <dependency>
             <groupId>org.dromara</groupId>
             <artifactId>common-oss</artifactId>

dk-modules/system/src/main/java/org/dromara/system/controller/system/TdengineController.java

@@ -0,0 +1,31 @@
+package org.dromara.system.controller.system;
+
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import org.dromara.common.web.core.BaseController;
+import org.dromara.system.service.impl.TdengineServiceImpl;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author yq183
+ * @data 2025/6/26 15:18
+ */
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/td")
+@Validated
+@Tag(name="td测试")
+public class TdengineController extends BaseController {
+    private final TdengineServiceImpl tdengineService;
+
+
+    @GetMapping("/test")
+    public void list(String db) {
+        System.out.println("执行新建超级表");
+        tdengineService.tdengine(db);
+    }
+
+}

dk-modules/system/src/main/java/org/dromara/system/mapper/TdengineMapper.java

@@ -0,0 +1,32 @@
+package org.dromara.system.mapper;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Insert;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
+import org.dromara.system.domain.SysDepartBoundary;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author yq183
+ * @data 2025/6/26 9:49
+ */
+@DS("tdengine")
+public interface TdengineMapper  {
+
+
+
+
+    @Select("SELECT * FROM dkcy.meters  \n" +
+        "ORDER BY ts DESC\n" +
+        "LIMIT 5; ")
+    List<Map<String,Object>> tdengine(String db);
+
+
+    @Insert("INSERT INTO d1001 USING dkcy.meters TAGS (\"California.SanFrancisco\", 2) VALUES (now, 10.2, 219, 0.32);")
+    void insert();
+
+}

dk-modules/system/src/main/java/org/dromara/system/service/TdengineService.java

@@ -0,0 +1,11 @@
+package org.dromara.system.service;
+
+/**
+ * @author yq183
+ * @data 2025/6/26 9:47
+ */
+public interface TdengineService {
+
+
+    void tdengine(String db);
+}

dk-modules/system/src/main/java/org/dromara/system/service/impl/TdengineServiceImpl.java

@@ -0,0 +1,25 @@
+package org.dromara.system.service.impl;
+
+import lombok.RequiredArgsConstructor;
+import org.dromara.system.mapper.TdengineMapper;
+import org.dromara.system.service.TdengineService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author yq183
+ * @data 2025/6/26 9:47
+ */
+@RequiredArgsConstructor
+@Service
+public class TdengineServiceImpl implements TdengineService {
+    private final TdengineMapper tdengineMapper;
+
+    @Override
+    public void tdengine(String db) {
+        List<Map<String, Object>> tdengine = tdengineMapper.tdengine(db);
+        System.out.println(tdengine);
+    }
+}