提交 78705d13 编写于 作者: S shenglian zhou

modifying for better debugging

上级 f318024a
...@@ -109,16 +109,16 @@ class TDTestCase: ...@@ -109,16 +109,16 @@ class TDTestCase:
create 1 stb create 1 stb
''' '''
input_sql = self.getPerfSql(count=count, init=True) input_sql = self.getPerfSql(count=count, init=True)
self._conn.insert_lines([input_sql]) self._conn.insertLines([input_sql])
def batchCreateTable(self, batch_list): def batchCreateTable(self, batch_list):
''' '''
schemaless insert api schemaless insert api
''' '''
print(threading.current_thread().name, "length=", len(batch_list)) print(threading.current_thread().name, "length=", len(batch_list))
print(threading.current_thread().name, 'firstline', batch_list[0]) 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]) print(threading.current_thread().name, 'lastline:', batch_list[-1][0:50], '...', batch_list[-1][-50:-1])
self._conn.insert_lines(batch_list) self._conn.insertLines(batch_list)
print(threading.current_thread().name, 'end') print(threading.current_thread().name, 'end')
def splitGenerator(self, table_list, sub_list_len): def splitGenerator(self, table_list, sub_list_len):
...@@ -236,14 +236,14 @@ class TDTestCase: ...@@ -236,14 +236,14 @@ class TDTestCase:
tdCom.cleanTb() tdCom.cleanTb()
for i in range(test_times): for i in range(test_times):
time_used = self.schemalessPerfTest(count=100, table_count=table_count, sub_list_len=sub_list_len, thread_count=thread_count)[0] time_used = self.schemalessPerfTest(count=1000, table_count=table_count, sub_list_len=sub_list_len, thread_count=thread_count)[0]
col1000_time += time_used col1000_time += time_used
col1000_time /= test_times col1000_time /= test_times
print(col1000_time) print(col1000_time)
tdCom.cleanTb() tdCom.cleanTb()
for i in range(test_times): for i in range(test_times):
time_used = self.schemalessPerfTest(count=400, table_count=table_count, sub_list_len=sub_list_len, thread_count=thread_count)[0] time_used = self.schemalessPerfTest(count=4000, table_count=table_count, sub_list_len=sub_list_len, thread_count=thread_count)[0]
col4000_time += time_used col4000_time += time_used
col4000_time /= test_times col4000_time /= test_times
print(col4000_time) print(col4000_time)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册