### 使用 Python 的 `clickhouse_driver` 进行操作 #### 1. 安装 `clickhouse_driver` 在使用 `clickhouse_driver` 之前，需要先安装该库。可以通过以下命令安装： ```bash pip install clickhouse-driver ``` #### 2. 建立连接 通过 `clickhouse_driver.Client` 创建与 ClickHouse 数据库的连接。以下是建立连接的基本示例[^2]： ```python from clickhouse_driver import Client # 创建连接对象 client = Client( host='localhost', # ClickHouse 服务器地址 port=9000, # ClickHouse 端口 user='default', # 用户名 password='', # 密码 database='test' # 数据库名称 ) ``` #### 3. 执行查询 可以使用 `execute` 方法执行 SQL 查询。以下是一个简单的查询示例[^2]： ```python # 执行查询 result = client.execute('SELECT * FROM test LIMIT 10') # 打印结果 for row in result: print(row) ``` #### 4. 创建表 可以使用 `execute` 方法创建表。以下是一个创建表的示例[^2]： ```python # 创建表 client.execute(''' CREATE TABLE IF NOT EXISTS test ( id Int32, value String ) ENGINE = Memory ''') ``` #### 5. 插入数据 可以使用 `execute` 方法插入单条或多条数据。以下是一个插入数据的示例： ```python # 插入单条数据 client.execute('INSERT INTO test (id, value) VALUES', [(1, 'value_1')]) # 插入多条数据 data = [(i, f'value_{i}') for i in range(2, 1001)] client.execute('INSERT INTO test (id, value) VALUES', data) ``` #### 6. 分布式查询 如果需要进行分布式查询，可以在查询时设置 `distributed=True` 参数。以下是一个分布式查询的示例[^2]： ```python # 分布式查询 query = 'SELECT count(*) FROM test' result = client.execute(query, distributed=True) print(f'Total records: {result[0][0]}') ``` --- ### 注意事项 - 在插入大量数据时，建议批量插入以提高性能。 - 如果需要处理复杂的数据类型或场景，可以参考 `clickhouse-driver` 的官方文档[^1]。 ---