8ae482b8bbdfe4de555e837be3984a8280aa2874,tests/integration_tests/flows/test_clickhouse.py,,query_ch,#Any#,26

Before Change

def query_ch(query):
    config = Config(set_get_config_path())
    if "CREATE " not in query.upper() and "INSERT " not in query.upper():
        query += " FORMAT JSON"

    connect_string = "http://{}:{}".format(
        config["integrations"]["default_clickhouse"]["host"],
        config["integrations"]["default_clickhouse"]["port"]
    )

After Change

def query_ch(query):
    config = Config(set_get_config_path())
    query = query.lower()
    add = "format json"
    for ele in ["drop ", "create ","insert "]:
        if ele in query:
            add = ""

Instances