add log information to printlines
This commit is contained in:
parent
9126417086
commit
1380e6c4ba
|
@ -190,7 +190,10 @@ class TDTestCase:
|
||||||
|
|
||||||
def batchInsertTable(self, batch_list):
|
def batchInsertTable(self, batch_list):
|
||||||
for insert_list in batch_list:
|
for insert_list in batch_list:
|
||||||
|
print(threading.current_thread().name, "length=", len(insert_list))
|
||||||
|
print(threading.current_thread().name, 'firstline', insert_list[0], 'lastline:', insert_list[-1])
|
||||||
self._conn.insert_lines(insert_list)
|
self._conn.insert_lines(insert_list)
|
||||||
|
print(threading.current_thread().name, 'end')
|
||||||
|
|
||||||
def genTableThread(self, thread_count=10):
|
def genTableThread(self, thread_count=10):
|
||||||
threads = list()
|
threads = list()
|
||||||
|
@ -228,7 +231,6 @@ class TDTestCase:
|
||||||
self.createStb()
|
self.createStb()
|
||||||
table_list, end_list = self.splitTableList()
|
table_list, end_list = self.splitTableList()
|
||||||
batchInsertTableThread = self.threadInsertTable(end_list=end_list)
|
batchInsertTableThread = self.threadInsertTable(end_list=end_list)
|
||||||
print(end_list)
|
|
||||||
self.multiThreadRun(batchInsertTableThread)
|
self.multiThreadRun(batchInsertTableThread)
|
||||||
# print(end_list)
|
# print(end_list)
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue