Update tests

This commit is contained in:
sundy-li 2021-01-05 11:22:53 +00:00
parent afb2cbe813
commit 3dda607059

View File

@ -83,7 +83,7 @@ def get_query_user_info(node, query_pattern):
def get_query_setting_on_shard(node, query_pattern, setting): def get_query_setting_on_shard(node, query_pattern, setting):
node.query("SYSTEM FLUSH LOGS") node.query("SYSTEM FLUSH LOGS")
return node.query(""" return node.query("""
SELECT (arrayFilter(x -> ((x.1) = '{}'), arrayZip(Settings.Names, Settings.Values))[1]).2 SELECT Settings.Values['%s']
FROM system.query_log FROM system.query_log
WHERE WHERE
query LIKE '%{}%' AND query LIKE '%{}%' AND
@ -91,7 +91,7 @@ def get_query_setting_on_shard(node, query_pattern, setting):
query NOT LIKE '%system.query_log%' AND query NOT LIKE '%system.query_log%' AND
type = 'QueryFinish' type = 'QueryFinish'
LIMIT 1 LIMIT 1
""".format(setting, query_pattern)).strip() """.format(setting, setting, query_pattern)).strip()
def test_insecure(): def test_insecure():
n1.query('SELECT * FROM dist_insecure') n1.query('SELECT * FROM dist_insecure')