（作者：陈玓玏）
使用clickhouse-driver包，先通过pip install clickhouse-driver安装包，再通过以下代码执行sql。
from clickhouse_driver import Client
client = Client(host='10.43.234.214', port=9000, user='clickhouse', password='c1ickh0use0perator')
# 执行一个创建数据库的语句
#query = 'create table cdl'
#result = client.execute(query)
# 执行一个创建表的语句
query = '''CREATE TABLE IF NOT EXISTS cdl.star
(
week Int32,
star Int32
)ENGINE = MergeTree()
ORDER BY week
PARTITION BY week
PRIMARY KEY week'''
result = client.execute(query)
data = [
{'week': 1, 'star': 1},
{'week': 2, 'star': 10},
{'week': 3, 'star': 100},
{'week': 4, 'star': 300},
{'week': 5, 'star': 500},
{'week': 6, 'star': 1000}
]
#执行插入语句
query = "INSERT INTO cdl.star VALUES" + ','.join(["(%s,%s)" % (d['week'], d['star']) for d in data])
result = client.execute(query)
#执行查询
query = 'select * from cdl.star limit 10'
result = client.execute(query)
# 打印结果
for row in result:
print(row)
