clickhouse_connect_quickstart_create_table_insert_and_query.py

1import clickhouse_connect
2
3# Initialize the client
4client = clickhouse_connect.get_client(
5    host='localhost',
6    username='default',
7    password='',
8    port=8123
9)
10
11# Create a table
12client.command('CREATE TABLE IF NOT EXISTS test_table (id UInt32, name String) ENGINE = MergeTree() ORDER BY id')
13
14# Insert data using a list of lists
15data = [[1, 'First row'], [2, 'Second row']]
16client.insert('test_table', data, column_names=['id', 'name'])
17
18# Query the data
19result = client.query('SELECT * FROM test_table')
20
21# Print results
22for row in result.result_rows:
23    print(row)
24
25# Clean up (optional)
26client.command('DROP TABLE test_table')