clickhouse - npm Package Compare versions

Comparing version 1.2.20 to 1.2.21

index.d.ts

@@ -15,3 +15,3 @@ /// <reference types="node" />
 
-  export class WriteStream extends stream.Transform {
+  export class WriteStream extends Stream.Transform {
     writeRow(data: Array<any>);
@@ -22,3 +22,3 @@ exec();
   class QueryCursor {
-    async toPromise(): Promise<Object[]>;
+    toPromise(): Promise<Object[]>;
     exec(callback: callbackExec);
@@ -25,0 +25,0 @@ stream(): Stream | WriteStream;

index.js

@@ -194,13 +194,7 @@ 'use strict';
 		return new Promise((resolve, reject) => {
-			let error = null;
-			
 			me.ws
 				.on('error', function(err) {
-					error = err;
+					reject(err);
 				})
 				.on('response', function (res) {
-					if (error) {
-						return reject(error);
-					}
-					
 					if (res.statusCode === 200) {
@@ -207,0 +201,0 @@ return resolve({ r: 1 });

package.json

@@ -55,3 +55,3 @@ {
     "JSONStream": "1.3.4",
-    "lodash": "4.17.11",
+    "lodash": "4.17.15",
     "querystring": "0.2.0",
@@ -93,3 +93,3 @@ "request": "2.88.0",
   "types": "index.d.ts",
-  "version": "1.2.20"
+  "version": "1.2.21"
 }

test/test.js

@@ -295,2 +295,22 @@ const
 	});
+
+
+	it('insert into select', async () => {
+		clickhouse.sessionId = Date.now();
+
+		await clickhouse.query('DROP TABLE IF EXISTS source_table').toPromise();
+		await clickhouse.query('DROP TABLE IF EXISTS dist_table').toPromise();
+		await clickhouse.query('CREATE TABLE source_table (id UInt32) ENGINE=MergeTree PARTITION BY tuple() ORDER BY tuple()').toPromise();
+		await clickhouse.query('CREATE TABLE dist_table (id UInt32) ENGINE=MergeTree PARTITION BY tuple() ORDER BY tuple()').toPromise();
+
+		await clickhouse.query(
+			'INSERT INTO source_table SELECT number FROM system.numbers LIMIT 1000000'
+		).toPromise();
+
+		await clickhouse.query(
+			'INSERT INTO dist_table SELECT * FROM dist_table'
+		).toPromise();
+
+		clickhouse.sessionId = null;
+	});
 	
@@ -297,0 +317,0 @@

No alert changes

Improved metrics

Total package byte prevSize

38262

increased by1.76%

Lines of code

1016

increased by0.99%

Dependency changes

• + Addedlodash@4.17.15(transitive)

• - Removedlodash@4.17.11(transitive)

• Updatedlodash@4.17.15