thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix code style

Browse Source
This commit is contained in:
JackyWoo 2023-05-31 20:32:34 +08:00
parent 7cc37ab4b8
commit 4302ba44d4
2 changed files with 71 additions and 56 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/integration/test_storage_redis/test.py
View File

@ -147,7 +147,6 @@ def test_select_int(started_cluster):
assert response[0] == ["0", "0"]
def test_create_table(started_cluster):
address = get_address_for_ch()
@ -215,7 +214,7 @@ def test_simple_insert(started_cluster):
# clean all
client.flushall()
drop_table('test_simple_insert')
drop_table("test_simple_insert")
node.query(
f"""
@ -386,5 +385,4 @@ def test_truncate(started_cluster):
response = TSV.toMat(node.query("SELECT COUNT(*) FROM test_truncate FORMAT TSV"))
assert len(response) == 1
assert esponse[0] == ["0"]
assert response[0] == ["0"]

121
tests/integration/test_table_function_redis/test.py
View File

@ -81,30 +81,36 @@ def test_simple_select(started_cluster):
client.mset(data)
client.close()
response = TSV.toMat(node.query(
f"""
SELECT
key, value
FROM
redis('{address}', 'key', 'key String, value String', 0, 'clickhouse', 10)
WHERE
key='0'
FORMAT TSV
"""))
response = TSV.toMat(
node.query(
f"""
SELECT
key, value
FROM
redis('{address}', 'key', 'key String, value String', 0, 'clickhouse', 10)
WHERE
key='0'
FORMAT TSV
"""
)
)
assert len(response) == 1
assert response[0] == ["0", "0"]
response = TSV.toMat(node.query(
f"""
SELECT
*
FROM
redis('{address}', 'key', 'key String, value String', 0, 'clickhouse', 10)
ORDER BY
key
FORMAT TSV
"""))
response = TSV.toMat(
node.query(
f"""
SELECT
*
FROM
redis('{address}', 'key', 'key String, value String', 0, 'clickhouse', 10)
ORDER BY
key
FORMAT TSV
"""
)
)
assert len(response) == 100
assert response[0] == ["0", "0"]
@ -124,7 +130,8 @@ def test_create_table(started_cluster):
*
FROM
redis('{address}', 'k', 'k String, v UInt32', 0, 'clickhouse', 10)
""")
"""
)
# illegal data type
with pytest.raises(QueryRuntimeException):
@ -134,7 +141,8 @@ def test_create_table(started_cluster):
*
FROM
redis('{address}', 'k', 'k not_exist_type, v String', 0, 'clickhouse', 10)
""")
"""
)
# illegal key
with pytest.raises(QueryRuntimeException):
@ -156,16 +164,19 @@ def test_data_type(started_cluster):
value = serialize_binary_for_string("0")
client.set(value, value)
response = TSV.toMat(node.query(
f"""
SELECT
*
FROM
redis('{address}', 'k', 'k String, v String', 0, 'clickhouse', 10)
WHERE
k='0'
FORMAT TSV
"""))
response = TSV.toMat(
node.query(
f"""
SELECT
*
FROM
redis('{address}', 'k', 'k String, v String', 0, 'clickhouse', 10)
WHERE
k='0'
FORMAT TSV
"""
)
)
assert len(response) == 1
assert response[0] == ["0", "0"]
@ -175,16 +186,19 @@ def test_data_type(started_cluster):
value = serialize_binary_for_uint32(0)
client.set(value, value)
response = TSV.toMat(node.query(
f"""
SELECT
*
FROM
redis('{address}', 'k', 'k UInt32, v UInt32', 0, 'clickhouse', 10)
WHERE
k=0
FORMAT TSV
"""))
response = TSV.toMat(
node.query(
f"""
SELECT
*
FROM
redis('{address}', 'k', 'k UInt32, v UInt32', 0, 'clickhouse', 10)
WHERE
k=0
FORMAT TSV
"""
)
)
assert len(response) == 1
assert response[0] == ["0", "0"]
@ -197,16 +211,19 @@ def test_data_type(started_cluster):
value = serialize_binary_for_uint32(int(seconds_since_epoch))
client.set(value, value)
response = TSV.toMat(node.query(
f"""
SELECT
*
FROM
redis('{address}', 'k', 'k DateTime, v DateTime', 0, 'clickhouse', 10)
WHERE
k='2023-06-01 00:00:00'
FORMAT TSV
"""))
response = TSV.toMat(
node.query(
f"""
SELECT
*
FROM
redis('{address}', 'k', 'k DateTime, v DateTime', 0, 'clickhouse', 10)
WHERE
k='2023-06-01 00:00:00'
FORMAT TSV
"""
)
)
assert len(response) == 1
assert response[0] == ["2023-06-01 00:00:00", "2023-06-01 00:00:00"]