提交 c0aa5881 编写于 作者: S shenglian zhou

change to adopt new python connector api

上级 a614653b
...@@ -110,7 +110,7 @@ class TDTestCase: ...@@ -110,7 +110,7 @@ class TDTestCase:
''' '''
input_sql = self.getPerfSql(count=count, init=True) input_sql = self.getPerfSql(count=count, init=True)
print(threading.current_thread().name, "create stb line:", input_sql) print(threading.current_thread().name, "create stb line:", input_sql)
self._conn.insertLines([input_sql]) self._conn.insert_lines([input_sql])
print(threading.current_thread().name, "create stb end") print(threading.current_thread().name, "create stb end")
def batchCreateTable(self, batch_list): def batchCreateTable(self, batch_list):
...@@ -121,7 +121,7 @@ class TDTestCase: ...@@ -121,7 +121,7 @@ class TDTestCase:
print(threading.current_thread().name, 'firstline', batch_list[0][0:50], '...', batch_list[0][-50:-1]) print(threading.current_thread().name, 'firstline', batch_list[0][0:50], '...', batch_list[0][-50:-1])
print(threading.current_thread().name, 'lastline:', batch_list[-1][0:50], '...', batch_list[-1][-50:-1]) print(threading.current_thread().name, 'lastline:', batch_list[-1][0:50], '...', batch_list[-1][-50:-1])
begin = time.time_ns(); begin = time.time_ns();
self._conn.insertLines(batch_list) self._conn.insert_lines(batch_list)
end = time.time_ns(); end = time.time_ns();
print(threading.current_thread().name, 'end time:', (end-begin)/10**9) print(threading.current_thread().name, 'end time:', (end-begin)/10**9)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册