taos读写

electricity/meter/build.gradle

@@ -36,7 +36,7 @@ dependencies {
     implementation "com.baomidou:mybatis-plus-boot-starter:$mybatisPlusVersion"
     implementation "com.baomidou:mybatis-plus-generator:$mybatisPlusVersion"
     implementation("com.alibaba:druid:$alibabaDruidVersion")
-    implementation("com.alibaba:fastjson:$fastjsonVersion")
+    implementation("com.alibaba:fastjson:1.2.83")
 
     implementation("$bootGroup:spring-boot-starter-test")
     implementation("com.xuxueli:xxl-job-core:$xxlJobVersion")

electricity/meter/src/main/java/com/gyee/gaia/meter/entity/TDLineFDL15Min.java

@@ -27,32 +27,29 @@ public class TDLineFDL15Min extends Model<TDLineFDL15Min> implements Serializabl
     /**
      * 子表名
      */
-    private String tName;
-
+    private String tbname;
 
 
     /**
      * 开始时间
      */
-    private long  ts;
+    private Timestamp  ts;
 
     /**
      * 开始值
      */
-    private double startValue;
-
-
+    private float meter;
 
 
     /**
      * 测点编码
      */
-    private String windpowerstationId;
+    private String windpowerstation;
 
     /**
      * 创建人;创建人
      */
-    private String projectId;
+    private String project;
 
     /**
      * 底码字段名称

electricity/meter/src/main/java/com/gyee/gaia/meter/mapper/TDLineFDL15MinMapper.java

@@ -6,12 +6,42 @@ import com.gyee.gaia.meter.entity.ProMeterLineFDL15Min;
 import com.gyee.gaia.meter.entity.TDLineFDL15Min;
 import org.apache.ibatis.annotations.Insert;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.List;
 
 
 @Mapper
+@DS("meter")
 public interface TDLineFDL15MinMapper extends BaseMapper<TDLineFDL15Min> {
 
     @Insert("insert into ${entity}")
     int insert(String entity);
 
+
+    @Insert("INSERT INTO #{tbName} VALUES (#{ts}, #{value})")
+    void insertLineFDL15Min1(@Param("tbName") String tbName, @Param("ts") long ts, @Param("value") double value);
+
+    @Insert("INSERT INTO #{tbName} USING LineFDL15Min TAGS(#{windpowerstationId},#{projectId},#{name}) VALUES (#{ts}, #{value})")
+    void insertLineFDL15Min(
+            @Param("tbName") String tbName,
+            @Param("windpowerstationId") String windpowerstationId,
+            @Param("projectId") String projectId,
+            @Param("name") String name,
+            @Param("ts") long ts,
+            @Param("value") double value
+    );
+
+
+//    @Select("select * from  MHSDJL_NX_GD_MHSF_DD_P1_L1_001_ZXYG045;")
+//    int selectLineFDL15Min1(@Param("tbName") String tbName);
+     List<TDLineFDL15Min> selectLineFDL15Min2();
+
+    @Select("select * from  tb1")
+    List<TDLineFDL15Min> selectLineFDL15Min1();
+
+
+
+
 }

electricity/meter/src/main/java/com/gyee/gaia/meter/service/impl/TDLineFDL15MinServiceImpl.java

@@ -16,7 +16,6 @@ import javax.annotation.Resource;
 import java.util.List;
 
 @Service
-@DS("meter")
 public class TDLineFDL15MinServiceImpl extends ServiceImpl<TDLineFDL15MinMapper, TDLineFDL15Min> implements ITDLineFDL15MinService {
 
     @Resource
@@ -26,7 +25,7 @@ public class TDLineFDL15MinServiceImpl extends ServiceImpl<TDLineFDL15MinMapper,
 
         int count = 0;
 
-            count += tdLineFDL15MinMapper.insert(" MHSDJL_NX_GD_MHSF_DD_P1_L1_001_ZXYG045  VALUES (NOW, 10000);");
+            count += tdLineFDL15MinMapper.insert(" MHSDJL_NX_GD_MHSF_DD_P1_L1_001_ZXYG045  VALUES (NOW, 888);");
 
         return count;
     }

electricity/meter/src/main/java/com/gyee/gaia/meter/service/saveTDengine/TDSaveLineFDL15MinTest.java

@@ -6,6 +6,7 @@ import cn.hutool.core.date.LocalDateTimeUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.gyee.gaia.meter.adapter.Adapter;
 import com.gyee.gaia.meter.entity.*;
+import com.gyee.gaia.meter.mapper.TDLineFDL15MinMapper;
 import com.gyee.gaia.meter.service.impl.MeterPointServiceImpl;
 import com.gyee.gaia.meter.service.impl.PowerStationServiceImpl;
 import com.gyee.gaia.meter.service.impl.ProMeterLineFDL15MinServiceImpl;
@@ -13,10 +14,12 @@ import com.gyee.gaia.meter.service.impl.TDLineFDL15MinServiceImpl;
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.test.context.SpringBootTest;
+import sun.util.calendar.BaseCalendar;
 
 import javax.annotation.Resource;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
+import java.sql.SQLOutput;
 import java.time.LocalDateTime;
 import java.time.temporal.ChronoUnit;
 import java.util.ArrayList;
@@ -31,38 +34,40 @@ import java.util.List;
 class TDSaveLineFDL15MinTest {
     @Resource
     TDLineFDL15MinServiceImpl tdLineFDL15MinService;
+    @Resource
+    TDLineFDL15MinMapper tdLineFDL15MinMapper;
 
 
-    @Resource
-    Adapter adapter;
-    @Resource
-    PowerStationServiceImpl powerStationService;
-    @Resource
-    MeterPointServiceImpl meterPointService;
-    @Resource
-    ProMeterLineFDL15MinServiceImpl proMeterLineFDL15MinService;
+
+    @Test
+    void TDSaveSaveLineFDL15Min() {
+
+        //Service层拼接字符串
+//        tdLineFDL15MinService.saveBatch();
+
+        //mapper@insert
+//        tdLineFDL15MinMapper.insertLineFDL15Min("MHSDJL_NX_GD_MHSF_DD_P1_L1_001_ZXYG044","场站","期次","名称",new Date().getTime(),444);
+
+
+
+        List<TDLineFDL15Min> list1 = tdLineFDL15MinMapper.selectLineFDL15Min1();
+        System.out.println("查询结果:"+list1 );
+
+
+//        List<TDLineFDL15Min> list = tdLineFDL15MinService.list(new QueryWrapper<TDLineFDL15Min>()
+//                .select("*")
+//        );
+//        System.out.println(list);
+
 
 
-    @Value("${start.time}")
-    private String startTimeString;
-    @Value("${end.time}")
-    private String endTimeString;
 
 
 
-    @Test
-    void TDSaveSaveLineFDL15Min() {
 
 
-        TDLineFDL15Min tdLineFDL15Min = new TDLineFDL15Min();
-//        tdLineFDL15Min.setTName("MHSDJL.NX_GD_MHSF_DD_P1_L1_001_ZXYG045");
-        tdLineFDL15Min.setTs(new Date().getTime());
-        tdLineFDL15Min.setStartValue(100);
-        tdLineFDL15Min.setWindpowerstationId("NX_GDDL_MHS_FDC_STA");
-        tdLineFDL15Min.setProjectId("NX_GDDL_MHSF02_EG");
 
 
-        tdLineFDL15MinService.saveBatch();
 
 
 

electricity/meter/src/main/resources/bootstrap.yaml

@@ -3,7 +3,7 @@ spring:
     name: meter
   profiles:
     # 环境配置
-    active: prod
+    active: dev
   cloud:
     nacos:
       discovery:
@@ -16,9 +16,9 @@ spring:
         # 配置文件格式
         file-extension: yml
         #开发环境配置命名空间
-#        namespace: fe339fbd-7113-405f-8d2a-70659c5d53e4
+        namespace: fe339fbd-7113-405f-8d2a-70659c5d53e4
         #生产环境配置命名空间
-        namespace: d148acca-95e7-4e07-a566-9a69012bcf01
+#        namespace: d148acca-95e7-4e07-a566-9a69012bcf01
         group: meter
         refresh-enabled: true
         # 共享配置

electricity/meter/src/main/resources/mappers-postgresql/TDLineFDL15MinMapper.xml

@@ -2,4 +2,10 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.gyee.gaia.meter.mapper.TDLineFDL15MinMapper">
 
+
+    <select id="selectLineFDL15Min2" resultType="com.gyee.gaia.meter.entity.TDLineFDL15Min">
+        select tbname,ts,meter,powerstation ,project ,name  from  tb1;
+--         select *  from  tb1;
+    </select>
+
 </mapper>