thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-21 15:12:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

less crazy test

Browse Source
This commit is contained in:
kssenii 2021-03-18 07:02:12 +00:00
parent 7847b78af9
commit b135b814fb
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tests/integration/test_storage_postgresql/test.py
View File

@ -176,7 +176,7 @@ def test_concurrent_queries(started_cluster):
cursor.execute('CREATE TABLE test_table (key integer, value integer)')
def node_insert(_):
for i in range(100):
for i in range(5):
result = node1.query("INSERT INTO test_table SELECT number, number FROM numbers(100)", user='default')
busy_pool = Pool(10)
@ -184,7 +184,7 @@ def test_concurrent_queries(started_cluster):
p.wait()
result = node1.query("SELECT count() FROM test_table", user='default')
print(result)
assert(int(result) == 10 * 100 * 100)
assert(int(result) == 10 * 5 * 100)
def node_select(_):
for i in range(5):
@ -195,7 +195,7 @@ def test_concurrent_queries(started_cluster):
p.wait()
def node_insert_select(_):
for i in range(25):
for i in range(5):
result = node1.query("INSERT INTO test_table SELECT number, number FROM numbers(100)", user='default')
result = node1.query("SELECT * FROM test_table LIMIT 100", user='default')
@ -204,7 +204,7 @@ def test_concurrent_queries(started_cluster):
p.wait()
result = node1.query("SELECT count() FROM test_table", user='default')
print(result)
assert(int(result) == 10 * 100 * 100 + 10 * 25 * 100)
assert(int(result) == 10 * 5 * 100 * 2)
if __name__ == '__main__':