import clickhouse_connect
# 创建一个连接到 ClickHouse 数据库的客户端
client = clickhouse_connect.get_client(host='localhost', port=8123, username='default', password='')
# 执行一个简单的查询并获取结果
query = "SELECT * FROM my_table LIMIT 10"
result = client.query(query)
# 打印查询结果
print(result.result_rows)
# 插入数据到 ClickHouse 表中
data_to_insert = [
{'column1': 'value1', 'column2': 123},
{'column1': 'value2', 'column2': 456}
]
client.insert('my_table', data_to_insert, column_names=['column1', 'column2'])
# 关闭连接
client.close()
clickhouse_connect 是用于连接 ClickHouse 数据库的 Python 库。clickhouse_connect.get_client 方法创建一个连接对象,指定主机、端口、用户名和密码。client.query 方法执行 SQL 查询,并获取查询结果。result.result_rows 包含查询返回的数据行。client.insert 方法将数据插入到指定表中。需要提供数据列表和列名。client.close 方法关闭连接。如果你需要更复杂的操作或有其他需求,请告知!
上一篇:python序列化和反序列化
下一篇:print函数用法python
Laravel PHP 深圳智简公司。版权所有©2023-2043 LaravelPHP 粤ICP备2021048745号-3
Laravel 中文站