diff --git a/src/connector/python/README.md b/src/connector/python/README.md index fbc67a6a8701dd173f3dd04f7a6dc35ef418b2d2..b5d841601f20fbad5bdc1464d5d83f512b25dfc4 100644 --- a/src/connector/python/README.md +++ b/src/connector/python/README.md @@ -401,16 +401,16 @@ conn.select_db(dbname) lines = [ 'st,t1=3i64,t2=4f64,t3="t3" c1=3i64,c3=L"pass",c2=false,c4=4f64 1626006833639000000ns', - 'st,t1=4i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"pass it again",c2=true,c4=5f64,c5=5f64,c6=7u64 1626006933640000000ns', - 'stf,t1=4i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"pass it again_stf",c2=false,c5=5f64,c6=7u64 1626006933641000000ns', + 'st,t1=4i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"pass it again",c2=true,c4=5f64,c5=5f64,c6=7u64 1626006933640000000', + 'stf,t1=4i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"pass it again_stf",c2=false,c5=5f64,c6=7u64 1626006933641000000', ] -conn.schemaless_insert(lines, 0) +conn.schemaless_insert(lines, 0, "ns") print("inserted") lines = [ - 'stf,t1=5i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"pass it again_stf",c2=false,c5=5f64,c6=7u64 1626006933641000000ns', + 'stf,t1=5i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"pass it again_stf",c2=false,c5=5f64,c6=7u64 1626006933641000000', ] -conn.schemaless_insert(lines, 0) +conn.schemaless_insert(lines, 0, "ns") result = conn.query("show tables") for row in result: diff --git a/src/connector/python/examples/insert-lines.py b/src/connector/python/examples/insert-lines.py index aceffe39889b157e9b32c8bdf4f4e61d45ae3488..755050dfb52b180567dd80e87b63508fc4101172 100644 --- a/src/connector/python/examples/insert-lines.py +++ b/src/connector/python/examples/insert-lines.py @@ -7,12 +7,12 @@ conn.execute("create database if not exists %s precision 'us'" % dbname) conn.select_db(dbname) lines = [ - 'st,t1=3i64,t2=4f64,t3="t3" c1=3i64,c3=L"pass",c2=false,c4=4f64 1626006833639000000ns', + 'st,t1=3i64,t2=4f64,t3="t3" c1=3i64,c3=L"pass",c2=false,c4=4f64 1626006833639000000', ] -conn.schemaless_insert(lines, 0) +conn.schemaless_insert(lines, 0, "ns") print("inserted") -conn.schemaless_insert(lines, 0) +conn.schemaless_insert(lines, 0, "ns") result = conn.query("show tables") for row in result: diff --git a/src/connector/python/taos/__init__.py b/src/connector/python/taos/__init__.py index bf2be15afee92a5740c605cbab2dbe889181e8e3..ebbad68c5a8a148a601fb5ec48f9658a1920ed62 100644 --- a/src/connector/python/taos/__init__.py +++ b/src/connector/python/taos/__init__.py @@ -402,17 +402,17 @@ conn.exec("create database if not exists %s precision 'us'" % dbname) conn.select_db(dbname) lines = [ - 'st,t1=3i64,t2=4f64,t3="t3" c1=3i64,c3=L"passit",c2=false,c4=4f64 1626006833639000000ns', - 'st,t1=4i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"passitagin",c2=true,c4=5f64,c5=5f64,c6=7u64 1626006933640000000ns', - 'stf,t1=4i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"passitagin_stf",c2=false,c5=5f64,c6=7u64 1626006933641000000ns', + 'st,t1=3i64,t2=4f64,t3="t3" c1=3i64,c3=L"passit",c2=false,c4=4f64 1626006833639000000', + 'st,t1=4i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"passitagin",c2=true,c4=5f64,c5=5f64,c6=7u64 1626006933640000000', + 'stf,t1=4i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"passitagin_stf",c2=false,c5=5f64,c6=7u64 1626006933641000000', ] -conn.schemaless_insert(lines, 0) +conn.schemaless_insert(lines, 0, "ns") print("inserted") lines = [ - 'stf,t1=5i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"passitagin_stf",c2=false,c5=5f64,c6=7u64 1626006933641000000ns', + 'stf,t1=5i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"passitagin_stf",c2=false,c5=5f64,c6=7u64 1626006933641000000', ] -conn.schemaless_insert(lines, 0) +conn.schemaless_insert(lines, 0, "ns") result = conn.query("show tables") for row in result: diff --git a/src/connector/python/taos/cinterface.py b/src/connector/python/taos/cinterface.py index e389c1ae94be841719fbc3aef733ca6d5c70d31e..7ee71fae8a64bbdd41055999dcc39faf61adadad 100644 --- a/src/connector/python/taos/cinterface.py +++ b/src/connector/python/taos/cinterface.py @@ -817,13 +817,13 @@ except AttributeError: -def taos_schemaless_insert(connection, lines, protocol): +def taos_schemaless_insert(connection, lines, protocol, precision): # type: (c_void_p, list[str] | tuple(str)) -> None num_of_lines = len(lines) lines = (c_char_p(line.encode("utf-8")) for line in lines) lines_type = ctypes.c_char_p * num_of_lines p_lines = lines_type(*lines) - errno = _libtaos.taos_schemaless_insert(connection, p_lines, num_of_lines, protocol) + errno = _libtaos.taos_schemaless_insert(connection, p_lines, num_of_lines, protocol, precision) if errno != 0: raise SchemalessError("schemaless insert error", errno) diff --git a/src/connector/python/taos/connection.py b/src/connector/python/taos/connection.py index 65ed89a85d3cc1c5ecab109abfb50aca3b1fec9c..dfac42f244d19267124c5ea790d4503e28fd5a78 100644 --- a/src/connector/python/taos/connection.py +++ b/src/connector/python/taos/connection.py @@ -117,7 +117,7 @@ class TaosConnection(object): stream = taos_open_stream(self._conn, sql, callback, stime, param, callback2) return TaosStream(stream) - def schemaless_insert(self, lines, protocol): + def schemaless_insert(self, lines, protocol, precision): # type: (list[str]) -> None """ 1.Line protocol and schemaless support @@ -132,7 +132,7 @@ class TaosConnection(object): lines = [ 'ste,t2=5,t3=L"ste" c1=true,c2=4,c3="string" 1626056811855516532', ] - conn.schemaless_insert(lines, 0) + conn.schemaless_insert(lines, 0, "ns") ``` 2.OpenTSDB telnet style API format support @@ -145,7 +145,7 @@ class TaosConnection(object): lines = [ 'cpu_load 1626056811855516532ns 2.0f32 id="tb1",host="host0",interface="eth0"', ] - conn.schemaless_insert(lines, 1) + conn.schemaless_insert(lines, 1, None) 3.OpenTSDB HTTP JSON format support @@ -168,10 +168,10 @@ class TaosConnection(object): } } '''] - conn.schemaless_insert(lines, 2) + conn.schemaless_insert(lines, 2, None) """ - return taos_schemaless_insert(self._conn, lines, protocol) + return taos_schemaless_insert(self._conn, lines, protocol, precision) def cursor(self): diff --git a/src/connector/python/tests/test_lines.py b/src/connector/python/tests/test_lines.py index ceef25b0e65f02af0bdcbadcb7f59efe775cba5e..157580f8466ce765246184421f0756958455a54b 100644 --- a/src/connector/python/tests/test_lines.py +++ b/src/connector/python/tests/test_lines.py @@ -23,17 +23,17 @@ def test_schemaless_insert(conn): conn.select_db(dbname) lines = [ - 'st,t1=3i64,t2=4f64,t3="t3" c1=3i64,c3=L"passit",c2=false,c4=4f64 1626006833639000000ns', - 'st,t1=4i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"passitagin",c2=true,c4=5f64,c5=5f64,c6=7u64 1626006933640000000ns', - 'stf,t1=4i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"passitagin_stf",c2=false,c5=5f64,c6=7u64 1626006933641000000ns', + 'st,t1=3i64,t2=4f64,t3="t3" c1=3i64,c3=L"passit",c2=false,c4=4f64 1626006833639000000', + 'st,t1=4i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"passitagin",c2=true,c4=5f64,c5=5f64,c6=7u64 1626006933640000000', + 'stf,t1=4i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"passitagin_stf",c2=false,c5=5f64,c6=7u64 1626006933641000000', ] - conn.schemaless_insert(lines, 0) + conn.schemaless_insert(lines, 0, "ns") print("inserted") lines = [ - 'stf,t1=5i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"passitagin_stf",c2=false,c5=5f64,c6=7u64 1626006933641000000ns', + 'stf,t1=5i64,t3="t4",t2=5f64,t4=5f64 c1=3i64,c3=L"passitagin_stf",c2=false,c5=5f64,c6=7u64 1626006933641000000', ] - conn.schemaless_insert(lines, 0) + conn.schemaless_insert(lines, 0, "ns") print("inserted") result = conn.query("select * from st") print(*result.fields) diff --git a/tests/pytest/insert/insertJSONPayload.py b/tests/pytest/insert/insertJSONPayload.py index b7cf82857f8ed964dd0681233d6791cd4064b87d..6f120e93b53aef5f973d28c06d55e9337371b9eb 100644 --- a/tests/pytest/insert/insertJSONPayload.py +++ b/tests/pytest/insert/insertJSONPayload.py @@ -46,7 +46,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe _stb_0_") @@ -67,7 +67,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb0_0") @@ -86,7 +86,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb0_1") @@ -105,7 +105,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb0_2") @@ -124,7 +124,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb0_3") @@ -143,7 +143,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb0_4") @@ -162,7 +162,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb0_5") @@ -184,7 +184,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) ### timestamp 10 digits second ### @@ -201,7 +201,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) print("============= step3 : test tags ================") @@ -216,7 +216,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb0_8") @@ -232,7 +232,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb0_9") @@ -248,7 +248,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb0_10") @@ -274,7 +274,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("select ts from stb1_0") @@ -297,7 +297,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("select ts from stb1_1") @@ -320,7 +320,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("select ts from stb1_2") @@ -343,7 +343,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("select ts from stb1_3") @@ -367,7 +367,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) ### metric value ### @@ -390,7 +390,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb2_0") @@ -415,7 +415,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb2_1") @@ -440,7 +440,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb2_2") @@ -465,7 +465,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb2_3") @@ -490,7 +490,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb2_4") @@ -515,7 +515,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb2_5") @@ -540,7 +540,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb2_6") @@ -565,7 +565,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb2_7") @@ -590,7 +590,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb2_8") @@ -649,7 +649,7 @@ class TDTestCase: } } '''] - code = self._conn.schemaless_insert(payload, 2) + code = self._conn.schemaless_insert(payload, 2, None) print("schemaless_insert result {}".format(code)) tdSql.query("describe stb3_0") diff --git a/tests/pytest/insert/insertTelnetLines.py b/tests/pytest/insert/insertTelnetLines.py index 1c3505df90b5976ebd21aae9c17a2730d0048816..24c86e0fd3aaff5f70044e17e788bc97065092ab 100644 --- a/tests/pytest/insert/insertTelnetLines.py +++ b/tests/pytest/insert/insertTelnetLines.py @@ -39,7 +39,7 @@ class TDTestCase: ".stb0.3. 1626006833639000000ns 4i8 host=\"host0\" interface=\"eth0\"", ] - code = self._conn.schemaless_insert(lines0, 1) + code = self._conn.schemaless_insert(lines0, 1, None) print("schemaless_insert result {}".format(code)) tdSql.query("show stables") @@ -69,7 +69,7 @@ class TDTestCase: "stb1 0 7i8 host=\"host0\"", ] - code = self._conn.schemaless_insert(lines1, 1) + code = self._conn.schemaless_insert(lines1, 1, None) print("schemaless_insert result {}".format(code)) tdSql.query("select * from stb1") @@ -83,7 +83,7 @@ class TDTestCase: "stb2_0 1626006833651ms -127i8 host=\"host0\"", "stb2_0 1626006833652ms 127i8 host=\"host0\"" ] - code = self._conn.schemaless_insert(lines2_0, 1) + code = self._conn.schemaless_insert(lines2_0, 1, None) print("schemaless_insert result {}".format(code)) tdSql.query("select * from stb2_0") @@ -98,7 +98,7 @@ class TDTestCase: "stb2_1 1626006833651ms -32767i16 host=\"host0\"", "stb2_1 1626006833652ms 32767i16 host=\"host0\"" ] - code = self._conn.schemaless_insert(lines2_1, 1) + code = self._conn.schemaless_insert(lines2_1, 1, None) print("schemaless_insert result {}".format(code)) tdSql.query("select * from stb2_1") @@ -114,7 +114,7 @@ class TDTestCase: "stb2_2 1626006833652ms 2147483647i32 host=\"host0\"" ] - code = self._conn.schemaless_insert(lines2_2, 1) + code = self._conn.schemaless_insert(lines2_2, 1, None) print("schemaless_insert result {}".format(code)) tdSql.query("select * from stb2_2") @@ -130,7 +130,7 @@ class TDTestCase: "stb2_3 1626006833652ms 9223372036854775807i64 host=\"host0\"" ] - code = self._conn.schemaless_insert(lines2_3, 1) + code = self._conn.schemaless_insert(lines2_3, 1, None) print("schemaless_insert result {}".format(code)) tdSql.query("select * from stb2_3") @@ -154,7 +154,7 @@ class TDTestCase: "stb2_4 1626006833710ms -3.4E38f32 host=\"host0\"" ] - code = self._conn.schemaless_insert(lines2_4, 1) + code = self._conn.schemaless_insert(lines2_4, 1, None) print("schemaless_insert result {}".format(code)) tdSql.query("select * from stb2_4") @@ -179,7 +179,7 @@ class TDTestCase: "stb2_5 1626006833710ms 3 host=\"host0\"" ] - code = self._conn.schemaless_insert(lines2_5, 1) + code = self._conn.schemaless_insert(lines2_5, 1, None) print("schemaless_insert result {}".format(code)) tdSql.query("select * from stb2_5") @@ -203,7 +203,7 @@ class TDTestCase: "stb2_6 1626006833700ms FALSE host=\"host0\"" ] - code = self._conn.schemaless_insert(lines2_6, 1) + code = self._conn.schemaless_insert(lines2_6, 1, None) print("schemaless_insert result {}".format(code)) tdSql.query("select * from stb2_6") @@ -220,7 +220,7 @@ class TDTestCase: "stb2_7 1626006833630ms \"binary_val.()[]{}<>\" host=\"host0\"" ] - code = self._conn.schemaless_insert(lines2_7, 1) + code = self._conn.schemaless_insert(lines2_7, 1, None) print("schemaless_insert result {}".format(code)) tdSql.query("select * from stb2_7") @@ -236,7 +236,7 @@ class TDTestCase: "stb2_8 1626006833620ms L\"nchar_val数值二\" host=\"host0\"" ] - code = self._conn.schemaless_insert(lines2_8, 1) + code = self._conn.schemaless_insert(lines2_8, 1, None) print("schemaless_insert result {}".format(code)) tdSql.query("select * from stb2_8") @@ -254,7 +254,7 @@ class TDTestCase: "stb3_0 1626006833610ms 2 t1=-127i8 t2=-32767i16 t3=-2147483647i32 t4=-9223372036854775807i64 t5=-3.4E38f32 t6=-1.7E308f64 t7=false t8=\"binary_val_2\" t9=L\"标签值2\"" ] - code = self._conn.schemaless_insert(lines3_0, 1) + code = self._conn.schemaless_insert(lines3_0, 1, None) print("schemaless_insert result {}".format(code)) tdSql.query("select * from stb3_0") @@ -298,7 +298,7 @@ class TDTestCase: "stb3_1 1626006833610ms 3 ID=child_table3 host=host3" ] - code = self._conn.schemaless_insert(lines3_1, 1) + code = self._conn.schemaless_insert(lines3_1, 1, None) print("schemaless_insert result {}".format(code)) tdSql.query("select * from stb3_1") diff --git a/tests/pytest/insert/line_insert.py b/tests/pytest/insert/line_insert.py index 766142604a19732247833909b8e40af4fea95cb7..eeff5f14bc544b5814255f1322b7c2b47985eef8 100644 --- a/tests/pytest/insert/line_insert.py +++ b/tests/pytest/insert/line_insert.py @@ -31,28 +31,28 @@ class TDTestCase: tdSql.execute('create stable ste(ts timestamp, f int) tags(t1 bigint)') - lines = [ "st,t1=3i64,t2=4f64,t3=\"t3\" c1=3i64,c3=L\"passit\",c2=false,c4=4f64 1626006833639000000ns", - "st,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64 1626006833640000000ns", - "ste,t2=5f64,t3=L\"ste\" c1=true,c2=4i64,c3=\"iam\" 1626056811823316532ns", - "stf,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64,c6=7u64 1626006933640000000ns", - "st,t1=4i64,t2=5f64,t3=\"t4\" c1=3i64,c3=L\"passitagain\",c2=true,c4=5f64 1626006833642000000ns", - "ste,t2=5f64,t3=L\"ste2\" c3=\"iamszhou\",c4=false 1626056811843316532ns", - "ste,t2=5f64,t3=L\"ste2\" c3=\"iamszhou\",c4=false,c5=32i8,c6=64i16,c7=32i32,c8=88.88f32 1626056812843316532ns", - "st,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64,c6=7u64 1626006933640000000ns", - "stf,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin_stf\",c2=false,c5=5f64,c6=7u64 1626006933641000000ns" + lines = [ "st,t1=3i64,t2=4f64,t3=\"t3\" c1=3i64,c3=L\"passit\",c2=false,c4=4f64 1626006833639000000", + "st,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64 1626006833640000000", + "ste,t2=5f64,t3=L\"ste\" c1=true,c2=4i64,c3=\"iam\" 1626056811823316532", + "stf,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64,c6=7u64 1626006933640000000", + "st,t1=4i64,t2=5f64,t3=\"t4\" c1=3i64,c3=L\"passitagain\",c2=true,c4=5f64 1626006833642000000", + "ste,t2=5f64,t3=L\"ste2\" c3=\"iamszhou\",c4=false 1626056811843316532", + "ste,t2=5f64,t3=L\"ste2\" c3=\"iamszhou\",c4=false,c5=32i8,c6=64i16,c7=32i32,c8=88.88f32 1626056812843316532", + "st,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64,c6=7u64 1626006933640000000", + "stf,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin_stf\",c2=false,c5=5f64,c6=7u64 1626006933641000000" ] - code = self._conn.schemaless_insert(lines, 0) + code = self._conn.schemaless_insert(lines, 0, "ns") print("schemaless_insert result {}".format(code)) - lines2 = [ "stg,t1=3i64,t2=4f64,t3=\"t3\" c1=3i64,c3=L\"passit\",c2=false,c4=4f64 1626006833639000000ns", - "stg,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64 1626006833640000000ns" + lines2 = [ "stg,t1=3i64,t2=4f64,t3=\"t3\" c1=3i64,c3=L\"passit\",c2=false,c4=4f64 1626006833639000000", + "stg,t1=4i64,t3=\"t4\",t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin\",c2=true,c4=5f64,c5=5f64 1626006833640000000" ] - code = self._conn.schemaless_insert([ lines2[0] ], 0) + code = self._conn.schemaless_insert([ lines2[0] ], 0, "ns") print("schemaless_insert result {}".format(code)) - self._conn.schemaless_insert([ lines2[1] ], 0) + self._conn.schemaless_insert([ lines2[1] ], 0, "ns") print("schemaless_insert result {}".format(code)) tdSql.query("select * from st") @@ -74,9 +74,9 @@ class TDTestCase: tdSql.checkData(2, 2, 14) self._conn.schemaless_insert([ - "sth,t1=4i64,t2=5f64,t4=5f64,ID=\"childtable\" c1=3i64,c3=L\"passitagin_stf\",c2=false,c5=5f64,c6=7u64 1626006933641ms", - "sth,t1=4i64,t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin_stf\",c2=false,c5=5f64,c6=7u64 1626006933654ms" - ], 0) + "sth,t1=4i64,t2=5f64,t4=5f64,ID=\"childtable\" c1=3i64,c3=L\"passitagin_stf\",c2=false,c5=5f64,c6=7u64 1626006933641", + "sth,t1=4i64,t2=5f64,t4=5f64 c1=3i64,c3=L\"passitagin_stf\",c2=false,c5=5f64,c6=7u64 1626006933654" + ], 0, "ms") tdSql.execute('reset query cache') tdSql.query('select tbname, * from sth')