1.0.3

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "@pushrocks/smartclickhouse",
-  "version": "1.0.2",
+  "version": "1.0.3",
   "lockfileVersion": 2,
   "requires": true,
   "packages": {
     "": {
       "name": "@pushrocks/smartclickhouse",
-      "version": "1.0.2",
+      "version": "1.0.3",
       "license": "MIT",
       "dependencies": {
         "clickhouse": "^2.4.4"

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartclickhouse",
-  "version": "1.0.2",
+  "version": "1.0.3",
   "private": false,
   "description": "an odm for talking to clickhouse",
   "main": "dist_ts/index.js",

test/test.ts

@@ -15,7 +15,7 @@ tap.test('should start the clickhouse db', async () => {
 })
 
 tap.test('should write something to the clickhouse db', async () => {
-  const result = await testClickhouseDb.clickhouseClient.query(`CREATE DATABASE IF NOT EXISTS lossless`);
+  const result = await testClickhouseDb.clickhouseClient.query(`CREATE DATABASE IF NOT EXISTS lossless`).toPromise();
   console.log(result);
   const result2 = await testClickhouseDb.clickhouseClient.query(`CREATE TABLE IF NOT EXISTS lossless.visits (
     timestamp UInt64,
@@ -23,8 +23,23 @@ tap.test('should write something to the clickhouse db', async () => {
     os String,
     userAgent String,
     version String
-  )`);
+  ) ENGINE=MergeTree() ORDER BY timestamp`).toPromise();
-  console.log(result);
+  console.log(result2);
+  const ws = testClickhouseDb.clickhouseClient.insert('INSERT INTO lossless.visits FORMAT JSONEachRow').stream();
+  for(let i = 0; i <= 1000; i++) {
+    await ws.writeRow(
+      JSON.stringify({
+        timestamp: Date.now(),
+        ip: '127.0.01',
+        os: 'Mac OS X',
+        userAgent: 'some',
+        version: 'someversion'
+      })
+    );
+  }
+
+  //wait stream finish
+  const result3 = await ws.exec();
 })
 
 tap.start();

ts/index.ts

@@ -17,6 +17,10 @@ export class ClickhouseDb {
    * starts the connection to the Clickhouse db
    */
   public start() {
-    this.clickhouseClient = new plugins.clickhouse.ClickHouse(this.options);
+    this.clickhouseClient = new plugins.clickhouse.ClickHouse({
+      ...this.options,
+      basicAuth: null,
+      format: 'json'
+    });
   }
 }