From 7a6f8a85a6b1bf40accc0753911ba1d04eb339db Mon Sep 17 00:00:00 2001 From: yq183 <645046984@qq.com> Date: Thu, 26 Jun 2025 16:19:25 +0800 Subject: [PATCH] =?UTF-8?q?td:=E6=97=B6=E5=BA=8F=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=BA=93=E7=9B=B8=E5=85=B3=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- dk-modules/system/pom.xml | 6 +++- .../controller/system/TdengineController.java | 31 ++++++++++++++++++ .../dromara/system/mapper/TdengineMapper.java | 32 +++++++++++++++++++ .../system/service/TdengineService.java | 11 +++++++ .../service/impl/TdengineServiceImpl.java | 25 +++++++++++++++ 5 files changed, 104 insertions(+), 1 deletion(-) create mode 100644 dk-modules/system/src/main/java/org/dromara/system/controller/system/TdengineController.java create mode 100644 dk-modules/system/src/main/java/org/dromara/system/mapper/TdengineMapper.java create mode 100644 dk-modules/system/src/main/java/org/dromara/system/service/TdengineService.java create mode 100644 dk-modules/system/src/main/java/org/dromara/system/service/impl/TdengineServiceImpl.java diff --git a/dk-modules/system/pom.xml b/dk-modules/system/pom.xml index 62cef53..59eab68 100644 --- a/dk-modules/system/pom.xml +++ b/dk-modules/system/pom.xml @@ -92,7 +92,11 @@ org.dromara common-encrypt - + + com.taosdata.jdbc + taos-jdbcdriver + 3.3.3 + org.dromara common-oss diff --git a/dk-modules/system/src/main/java/org/dromara/system/controller/system/TdengineController.java b/dk-modules/system/src/main/java/org/dromara/system/controller/system/TdengineController.java new file mode 100644 index 0000000..282a59a --- /dev/null +++ b/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); + } + +} diff --git a/dk-modules/system/src/main/java/org/dromara/system/mapper/TdengineMapper.java b/dk-modules/system/src/main/java/org/dromara/system/mapper/TdengineMapper.java new file mode 100644 index 0000000..65a8561 --- /dev/null +++ b/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> tdengine(String db); + + + @Insert("INSERT INTO d1001 USING dkcy.meters TAGS (\"California.SanFrancisco\", 2) VALUES (now, 10.2, 219, 0.32);") + void insert(); + +} diff --git a/dk-modules/system/src/main/java/org/dromara/system/service/TdengineService.java b/dk-modules/system/src/main/java/org/dromara/system/service/TdengineService.java new file mode 100644 index 0000000..1d393bb --- /dev/null +++ b/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); +} diff --git a/dk-modules/system/src/main/java/org/dromara/system/service/impl/TdengineServiceImpl.java b/dk-modules/system/src/main/java/org/dromara/system/service/impl/TdengineServiceImpl.java new file mode 100644 index 0000000..c88f2c2 --- /dev/null +++ b/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> tdengine = tdengineMapper.tdengine(db); + System.out.println(tdengine); + } +}