github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-02 19:50:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'hotfix/TD-12422' of github.com:taosdata/DataX into hotfix/TD-12422

Browse Source
This commit is contained in:
dingbo 2022-02-21 14:38:09 +08:00
commit 3a0b52ac88
2 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tdenginewriter/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Stream2TDengineTest.java
View File

@ -12,7 +12,6 @@ import java.sql.Statement;
public class Stream2TDengineTest { public class Stream2TDengineTest {
private String host2 = "192.168.56.105"; private String host2 = "192.168.56.105";
private String precision;
@Test @Test
public void s2t_case1() throws Throwable { public void s2t_case1() throws Throwable {
@ -56,7 +55,8 @@ public class Stream2TDengineTest {
stmt.execute("drop database if exists db2"); stmt.execute("drop database if exists db2");
stmt.execute("create database if not exists db2 precision '" + precision + "'"); 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," + 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," + "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," + "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))"); "t13 double, t14 bool, t15 binary(100), t16 nchar(100))");

17
tdenginewriter/src/test/resources/defaultJob.json
View File

@ -41,6 +41,18 @@
"type": "string", "type": "string",
"value": "2022-02-20 12:00:07.123456789" "value": "2022-02-20 12:00:07.123456789"
}, },
{
"type": "long",
"value": 1645329608000
},
{
"type": "long",
"value": 1645329609000000
},
{
"type": "long",
"value": 1645329610000000000
},
{ {
"type": "long", "type": "long",
"random": "0, 10" "random": "0, 10"
@ -75,7 +87,7 @@
}, },
{ {
"type": "string", "type": "string",
"random": "0, 10" "random": "10, 50"
}, },
{ {
"type": "date", "type": "date",
@ -162,6 +174,9 @@
"ts5", "ts5",
"ts6", "ts6",
"ts7", "ts7",
"ts8",
"ts9",
"ts10",
"f1", "f1",
"f2", "f2",
"f3", "f3",