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); + } +}