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

change

Browse Source
This commit is contained in:
zyyang 2022-02-21 13:43:57 +08:00
parent 7436176b27
commit 788cca5ab9
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 {
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))");

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

@ -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",