spring-boot-starter-influxdb

spring:
  influx:
    url: http://127.0.0.1:8086
    password: 123456
    user: admin
    mapper-location: com.github.betacatcode

import lombok.Data;
import org.influxdb.annotation.Column;
import org.influxdb.annotation.Measurement;
import org.influxdb.annotation.TimeColumn;

import java.time.Instant;

@Data
@Measurement(database = "test",name = "student")
public class Student {
    private String id;

    @Column(name = "sname",tag = true)
    private String sname;

    @Column(name = "value")
    private Double value;

    @TimeColumn
    @Column(name = "time")
    private Instant time;
}

public interface StudentMapper extends InfluxDBBaseMapper {

    @Select(value = "select * from test.autogen.student where sname=#{sname}",resultType = Student.class)
    List<Student> selectByName(@Param("sname")String sname);

    @Delete(value = "delete from student",database = "test")
    void deleteAll();

}

@RunWith(SpringRunner.class)
@SpringBootTest
class InfluxdbAnnotationApplicationTests {

    @Autowired
    StudentMapper studentMapper;

    @Test
    void contextLoads() {
    }

    //单条插入
    @Test
    void testInsertOne(){
        Student student1 = new Student();
        student1.setSname("ww");
        student1.setValue(235.12);
        student1.setTime(Instant.ofEpochMilli(1640966500000L));
        studentMapper.insertOne(student1);
    }

    //批量插入
    @Test
    void testInsertBatch(){
        Student student1 = new Student();
        student1.setSname("zs");
        student1.setValue(123.45);
        student1.setTime(Instant.ofEpochMilli(1640966400000L));

        Student student2 = new Student();
        student2.setSname("ls");
        student2.setValue(666.21);
        student2.setTime(Instant.ofEpochMilli(1640966300000L));

        List<Student> studentList = new ArrayList<>();

        studentList.add(student1);
        studentList.add(student2);
        studentMapper.insertBatch(studentList);
    }

    //查询
    @Test
    void testSelect(){
        List<Student> studentList = studentMapper.selectByName("zs");
        for (Student student : studentList) {
            System.out.println(student);
        }
    }

    //删除
    @Test
    void testDelete(){
        studentMapper.deleteAll();
    }

}