网站建设和挂标情况清理表,河北建设工程信息网站,wordpress 国人原创,wordpress 专业模板下载最近学习了TDengine数据库#xff0c;因为我们公司有硬件设备#xff0c;设备按照每分钟#xff0c;每十分钟#xff0c;每小时上传数据#xff0c;存入数据库。而这些数据会经过sql查询#xff0c;统计返回展示到前端。但时间积累后现在数据达到了百万级数据#xff0c…最近学习了TDengine数据库因为我们公司有硬件设备设备按照每分钟每十分钟每小时上传数据存入数据库。而这些数据会经过sql查询统计返回展示到前端。但时间积累后现在数据达到了百万级数据导致查询很慢综合考虑下决定使用这个时序数据库来存入数据。关于TDengine详情可去官网https://docs.taosdata.com/查看。具体理解超级表和子表。接下来展示我的简单使用建入连接有两种方式建入连接一种是安装客户端驱动一种是安装连接器我这边使用的是安装连接器。安装连接器又有两种方式一种是原声连接一种是REST连接。两种连接端口不同(自行配置)。我使用的REST连接首先导入依赖 dependencygroupIdcom.taosdata.jdbc/groupIdartifactIdtaos-jdbcdriver/artifactIdversion3.0.0/version/dependency接下来是建入连接代码application.yml:tdengine:forward: false #是否启用该数据库开关ip: 127.0.0.49 #tdengine服务ipport: 8041database: hle_datauser: rootpassword: Hle8888TdengineConfig.javaConfiguration
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.javaComponent
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();}}}操作数据执行sqlTdengineConnectConfig.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);注表名中如果含有大写会自动转为小写不能带有“-”符号可以使用“_”。再展示一下数据库界面哈哈哈哈这就是我的简单使用更多的自行去官网看看哦
