diff --git a/tdenginewriter/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Stream2TDengineTest.java b/tdenginewriter/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Stream2TDengineTest.java index cfd77fdf..e54bcbde 100644 --- a/tdenginewriter/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Stream2TDengineTest.java +++ b/tdenginewriter/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Stream2TDengineTest.java @@ -12,7 +12,6 @@ import java.sql.Statement; public class Stream2TDengineTest { private String host2 = "192.168.56.105"; - private String precision; @Test public void s2t_case1() throws Throwable { @@ -56,7 +55,8 @@ public class Stream2TDengineTest { stmt.execute("drop database if exists db2"); stmt.execute("create database if not exists db2 precision '" + precision + "'"); stmt.execute("create table db2.stb2(ts1 timestamp, ts2 timestamp,ts3 timestamp,ts4 timestamp,ts5 timestamp," + - "ts6 timestamp,ts7 timestamp, f1 tinyint, f2 smallint, f3 int, f4 bigint, f5 float, f6 double," + + "ts6 timestamp,ts7 timestamp, ts8 timestamp, ts9 timestamp, ts10 timestamp, f1 tinyint, f2 smallint," + + "f3 int, f4 bigint, f5 float, f6 double," + "f7 bool, f8 binary(100), f9 nchar(100)) tags(t1 timestamp,t2 timestamp,t3 timestamp,t4 timestamp," + "t5 timestamp,t6 timestamp,t7 timestamp, t8 tinyint, t9 smallint, t10 int, t11 bigint, t12 float," + "t13 double, t14 bool, t15 binary(100), t16 nchar(100))"); diff --git a/tdenginewriter/src/test/resources/defaultJob.json b/tdenginewriter/src/test/resources/defaultJob.json index 2548fc94..2a36dfd0 100644 --- a/tdenginewriter/src/test/resources/defaultJob.json +++ b/tdenginewriter/src/test/resources/defaultJob.json @@ -41,6 +41,18 @@ "type": "string", "value": "2022-02-20 12:00:07.123456789" }, + { + "type": "long", + "value": 1645329608000 + }, + { + "type": "long", + "value": 1645329609000000 + }, + { + "type": "long", + "value": 1645329610000000000 + }, { "type": "long", "random": "0, 10" @@ -75,7 +87,7 @@ }, { "type": "string", - "random": "0, 10" + "random": "10, 50" }, { "type": "date", @@ -162,6 +174,9 @@ "ts5", "ts6", "ts7", + "ts8", + "ts9", + "ts10", "f1", "f2", "f3",