i5eFUGs3

1  (async () => {
2        const { ClickHouse } = require('clickhouse');
3 
4        const clickhouse = new ClickHouse();
5 
6        const createTableSql = `
7            CREATE TABLE IF NOT EXISTS session_temp (
8                ClientID UUID,
9                FirstName String,
10                Address String,
11                City String,
12                StartDate DateTime DEFAULT now()
13            ) ENGINE = MergeTree()
14            PRIMARY KEY ClientID
15            ORDER BY ClientID
16        `;
17       
18        await clickhouse.query(createTableSql).toPromise();
19       
20       
21        const insertSession = await clickhouse
22            .insert('INSERT INTO session_temp (ClientID, FirstName, Address, City)')
23            .stream();
24       
25        await insertSession.writeRow([
26            '223',
27            'firstname1',
28            'address1',
29            'city1',
30        ]);
31       
32        await insertSession.exec();
33})().then(() => {})