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

fix test for postgresql addresses_expr

Browse Source
This commit is contained in:
joelynch 2023-12-18 10:41:12 +01:00
parent b4bef78e63
commit 403d9c809d
No known key found for this signature in database
2 changed files with 33 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/integration/test_storage_postgresql/configs/named_collections.xml
View File

@ -16,7 +16,8 @@
<postgres3>
<user>postgres</user>
<password>mysecretpassword</password>
<addresses_expr>postgres1:1111</addresses_expr>
<host>postgres1</host>
<port>1111</port>
<database>postgres</database>
<table>test_table</table>
</postgres3>
@ -28,5 +29,12 @@
<database>postgres</database>
<table>test_replicas</table>
</postgres4>
<postgres5>
<user>postgres</user>
<password>mysecretpassword</password>
<addresses_expr>postgres1:5432</addresses_expr>
<database>postgres</database>
<table>test_table</table>
</postgres5>
</named_collections>
</clickhouse>

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

@ -82,6 +82,30 @@ def test_postgres_select_insert(started_cluster):
cursor.execute(f"DROP TABLE {table_name} ")
def test_postgres_addresses_expr(started_cluster):
cursor = started_cluster.postgres_conn.cursor()
table_name = "test_table"
table = f"""postgresql(`postgres5`)"""
cursor.execute(f"DROP TABLE IF EXISTS {table_name}")
cursor.execute(f"CREATE TABLE {table_name} (a integer, b text, c integer)")
node1.query(
f"""
INSERT INTO TABLE FUNCTION {table}
SELECT number, concat('name_', toString(number)), 3 from numbers(10000)"""
)
check1 = f"SELECT count() FROM {table}"
check2 = f"SELECT Sum(c) FROM {table}"
check3 = f"SELECT count(c) FROM {table} WHERE a % 2 == 0"
check4 = f"SELECT count() FROM {table} WHERE b LIKE concat('name_', toString(1))"
assert (node1.query(check1)).rstrip() == "10000"
assert (node1.query(check2)).rstrip() == "30000"
assert (node1.query(check3)).rstrip() == "5000"
assert (node1.query(check4)).rstrip() == "1"
cursor.execute(f"DROP TABLE {table_name} ")
def test_postgres_conversions(started_cluster):
cursor = started_cluster.postgres_conn.cursor()
cursor.execute(f"DROP TABLE IF EXISTS test_types")