Python 连接clickhouse常用的三种方式

在Python中，连接ClickHouse数据库常用的三种方式是使用clickhouse-driver、pymysql和clickhouse-sqlalchemy。以下是每种方式的简单示例代码：

1. 使用clickhouse-driver:

from clickhouse_driver import Client
 
# 连接ClickHouse
client = Client('localhost', 'default', '', 'your_database')
 
# 执行查询
result = client.execute('SELECT * FROM your_table LIMIT 10')
for row in result:
    print(row)

2. 使用pymysql:

import pymysql
 
# 连接ClickHouse
conn = pymysql.connect(host='localhost', user='default', password='', db='your_database', charset='utf8mb4')
 
# 创建游标对象
cursor = conn.cursor()
 
# 执行SQL查询
cursor.execute('SELECT * FROM your_table LIMIT 10')
 
# 获取查询结果
rows = cursor.fetchall()
for row in rows:
    print(row)
 
# 关闭游标和连接
cursor.close()
conn.close()

3. 使用clickhouse-sqlalchemy:

首先安装clickhouse-sqlalchemy:

pip install clickhouse-sqlalchemy

然后使用如下代码连接和查询:

from sqlalchemy import create_engine
 
# 创建连接引擎
engine = create_engine('clickhouse://localhost:8123/your_database')
 
# 使用引擎执行查询
with engine.connect() as connection:
    result = connection.execute('SELECT * FROM your_table LIMIT 10')
    for row in result:
        print(row)

这些示例展示了如何使用不同的库连接到ClickHouse数据库并执行查询。选择哪种方式取决于你的项目需求和已有的依赖库。