当前位置：首页 > news >正文

TDengine时序数据库的简单使用

news 2025/6/26 20:18:15

最近学习了TDengine数据库，因为我们公司有硬件设备，设备按照每分钟，每十分钟，每小时上传数据，存入数据库。而这些数据会经过sql查询，统计返回展示到前端。但时间积累后现在数据达到了百万级数据，导致查询很慢，综合考虑下，决定使用这个时序数据库来存入数据。

关于TDengine详情，可去官网https://docs.taosdata.com/查看。具体理解超级表和子表。

接下来展示我的简单使用：

建入连接

有两种方式建入连接，一种是安装客户端驱动，一种是安装连接器，我这边使用的是安装连接器。

安装连接器，又有两种方式，一种是原声连接，一种是REST连接。两种连接端口不同(自行配置)。

我使用的REST连接：

首先导入依赖：

       <dependency><groupId>com.taosdata.jdbc</groupId><artifactId>taos-jdbcdriver</artifactId><version>3.0.0</version></dependency>

接下来是建入连接代码：

application.yml:

tdengine:forward: false #是否启用该数据库开关ip: 127.0.0.49 #tdengine服务ipport: 8041database: hle_datauser: rootpassword: Hle8888

TdengineConfig.java

@Configuration
public class TdengineConfig {public static String ip;public static String port;public static String database;public static String user;public static String password;public static Boolean forward;@Value("${tdengine.ip}")public void setIp(String ip) {TdengineConfig.ip = ip;}@Value("${tdengine.port}")public void setPort(String port) {TdengineConfig.port = port;}@Value("${tdengine.database}")public void setDatabase(String database) {TdengineConfig.database = database;}@Value("${tdengine.user}")public void setUser(String user) {TdengineConfig.user = user;}@Value("${tdengine.password}")public void setPassword(String password) {TdengineConfig.password = password;}@Value("${tdengine.forward}")public void setForward(Boolean forward) {TdengineConfig.forward = forward;}}

TdengineConnectConfig.java

@Component
public class TdengineConnectConfig {//8030原生连接端口  8041public static Connection conn = null;public static String URL = TdengineConfig.ip + ":" + TdengineConfig.port + "/" + TdengineConfig.database;@PostConstructpublic static Connection getConnection(){if(!TdengineConfig.forward) return null;try{System.out.println("---------------start Connected");String jdbcUrl = "jdbc:TAOS-RS://"+ URL +"?user="+ TdengineConfig.user +"&password=" + TdengineConfig.password;Properties connProps = new Properties();//connProps.setProperty(TSDBDriver.PROPERTY_KEY_BATCH_LOAD, "true");  //开启批量拉取功能conn = DriverManager.getConnection(jdbcUrl, connProps);System.out.println("---------------Connected success");}catch (Exception e){System.out.println("---------------Connected fail");e.printStackTrace();}return conn;}//执行sqlpublic static void executeSql(String sql){try{if(conn == null) conn = getConnection();if(conn != null){Statement statement = conn.createStatement();statement.execute(sql);}}catch (Exception e){System.out.println("sql执行失败");e.printStackTrace();}}}

操作数据，执行sql

TdengineConnectConfig.executeSql(sql.toString());

具体语法可以去看官网。给你们展示一下写入数据的sql:

--------执行sql:INSERT INTO D_LE202012210190_2011_a24088 USING data_2011 TAGS ('LE202012210190','a24088','非甲烷总烃','mg/m³') VALUES (1675844844000,0.011,null,null,null,null)D_LE202012210190_2011_a34001 USING data_2011 TAGS ('LE202012210190','a34001','总悬浮颗粒物TSP','mg/m³') VALUES (1675844844000,0.132,null,null,null,null)D_LE202012210190_2011_a01012 USING data_2011 TAGS ('LE202012210190','a01012','烟气温度','°C') VALUES (1675844844000,14.9,null,null,null,null)D_LE202012210190_2011_GGY03 USING data_2011 TAGS ('LE202012210190','GGY03','油烟浓度','mg/m³') VALUES (1675844844000,0.028,null,null,null,null);

注：表名中如果含有大写会自动转为小写，不能带有“-”符号，可以使用“_”。

再展示一下数据库界面：