TDEngine(taos) 涛思数据库-java写入数据

一、java写入taos简单案例：

pom.xml 中加入以下依赖。

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

java代码

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Arrays;
import java.util.List;public class RestInsertExample {private static Connection getConnection() throws SQLException {/*** 默认用户名 root* 默认端口号 6041*/String jdbcUrl = "jdbc:TAOS-RS://安装taos的ip地址:6041?user=root&password=taosdata";return DriverManager.getConnection(jdbcUrl);}private static List<String> getRawData() {return Arrays.asList("d1001,2018-10-03 14:38:05.000,10.30000,219,0.31000,'California.SanFrancisco',2","d1001,2018-10-03 14:38:15.000,12.60000,218,0.33000,'California.SanFrancisco',2","d1001,2018-10-03 14:38:16.800,12.30000,221,0.31000,'California.SanFrancisco',2","d1002,2018-10-03 14:38:16.650,10.30000,218,0.25000,'California.SanFrancisco',3","d1003,2018-10-03 14:38:05.500,11.80000,221,0.28000,'California.LosAngeles',2","d1003,2018-10-03 14:38:16.600,13.40000,223,0.29000,'California.LosAngeles',2","d1004,2018-10-03 14:38:05.000,10.80000,223,0.29000,'California.LosAngeles',3","d1004,2018-10-03 14:38:06.500,11.50000,221,0.35000,'California.LosAngeles',3");}/*** 对应涛思数据库插入语句:* INSERT INTO power.d1001 USING power.meters TAGS(California.SanFrancisco, 2) VALUES('2018-10-03 14:38:05.000',10.30000,219,0.31000)* power.d1001 USING power.meters TAGS(California.SanFrancisco, 2) VALUES('2018-10-03 14:38:15.000',12.60000,218,0.33000)* power.d1001 USING power.meters TAGS(California.SanFrancisco, 2) VALUES('2018-10-03 14:38:16.800',12.30000,221,0.31000)* power.d1002 USING power.meters TAGS(California.SanFrancisco, 3) VALUES('2018-10-03 14:38:16.650',10.30000,218,0.25000)* power.d1003 USING power.meters TAGS(California.LosAngeles, 2) VALUES('2018-10-03 14:38:05.500',11.80000,221,0.28000)* power.d1003 USING power.meters TAGS(California.LosAngeles, 2) VALUES('2018-10-03 14:38:16.600',13.40000,223,0.29000)* power.d1004 USING power.meters TAGS(California.LosAngeles, 3) VALUES('2018-10-03 14:38:05.000',10.80000,223,0.29000)* power.d1004 USING power.meters TAGS(California.LosAngeles, 3) VALUES('2018-10-03 14:38:06.500',11.50000,221,0.35000)*/private static String getSQL() {// 拼接插入sqlStringBuilder sb = new StringBuilder("INSERT INTO ");for (String line : getRawData()) {String[] ps = line.split(",");sb.append("power." + ps[0]).append(" USING power.meters TAGS(").append(ps[5]).append(", ") // tag: location.append(ps[6]) // tag: groupId.append(") VALUES(").append('\'').append(ps[1]).append('\'').append(",") // ts.append(ps[2]).append(",") // current.append(ps[3]).append(",") // voltage.append(ps[4]).append(") "); // phase}return sb.toString();}public static void insertData() throws SQLException {try (Connection conn = getConnection()) {try (Statement stmt = conn.createStatement()) {//写入的数据的时间戳必须大于当前时间减去数据库配置参数 KEEP 的时间。// 如果 KEEP 配置为 3650 天，那么无法写入比 3650 天还早的数据stmt.execute("CREATE DATABASE power KEEP 3650");stmt.execute("CREATE STABLE power.meters (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT) " +"TAGS (location BINARY(64), groupId INT)");String sql = getSQL();int rowCount = stmt.executeUpdate(sql);System.out.println("rowCount=" + rowCount); // rowCount=8}}}public static void main(String[] args) throws SQLException {insertData();}
}

执行结果插入成功：