@clickhouse/client - npm Package Compare versions

Comparing version 1.4.0 to 1.4.1

dist/connection/node_base_connection.js

@@ -8,2 +8,3 @@ "use strict";
 const client_common_1 = require("@clickhouse/client-common");
+const client_common_2 = require("@clickhouse/client-common");
 const crypto_1 = __importDefault(require("crypto"));
@@ -81,3 +82,3 @@ const stream_1 = __importDefault(require("stream"));
                 method: 'GET',
-                url: (0, client_common_1.transformUrl)({ url: this.params.url, pathname: '/ping' }),
+                url: (0, client_common_2.transformUrl)({ url: this.params.url, pathname: '/ping' }),
                 abort_signal: abortController.signal,
@@ -106,4 +107,4 @@ headers: this.buildRequestHeaders(),
         const query_id = this.getQueryId(params.query_id);
-        const clickhouse_settings = (0, client_common_1.withHttpSettings)(params.clickhouse_settings, this.params.compression.decompress_response);
-        const searchParams = (0, client_common_1.toSearchParams)({
+        const clickhouse_settings = (0, client_common_2.withHttpSettings)(params.clickhouse_settings, this.params.compression.decompress_response);
+        const searchParams = (0, client_common_2.toSearchParams)({
             database: this.params.database,
@@ -120,3 +121,3 @@ clickhouse_settings,
                 method: 'POST',
-                url: (0, client_common_1.transformUrl)({ url: this.params.url, searchParams }),
+                url: (0, client_common_2.transformUrl)({ url: this.params.url, searchParams }),
                 body: params.query,
@@ -154,3 +155,3 @@ abort_signal: controller.signal,
         const query_id = this.getQueryId(params.query_id);
-        const searchParams = (0, client_common_1.toSearchParams)({
+        const searchParams = (0, client_common_2.toSearchParams)({
             database: this.params.database,
@@ -167,3 +168,3 @@ clickhouse_settings: params.clickhouse_settings,
                 method: 'POST',
-                url: (0, client_common_1.transformUrl)({ url: this.params.url, searchParams }),
+                url: (0, client_common_2.transformUrl)({ url: this.params.url, searchParams }),
                 body: params.values,
@@ -311,3 +312,3 @@ abort_signal: controller.signal,
         };
-        const searchParams = (0, client_common_1.toSearchParams)(toSearchParamsOptions);
+        const searchParams = (0, client_common_2.toSearchParams)(toSearchParamsOptions);
         const { controller, controllerCleanup } = this.getAbortController(params);
@@ -317,3 +318,3 @@ try {
                 method: 'POST',
-                url: (0, client_common_1.transformUrl)({ url: this.params.url, searchParams }),
+                url: (0, client_common_2.transformUrl)({ url: this.params.url, searchParams }),
                 body: sendQueryInParams ? params.values : params.query,
@@ -350,2 +351,5 @@ abort_signal: controller.signal,
     async request(params, op) {
+        // allows the event loop to process the idle socket timers, if the CPU load is high
+        // otherwise, we can occasionally get an expired socket, see https://github.com/ClickHouse/clickhouse-js/issues/294
+        await (0, client_common_1.sleep)(0);
         return new Promise((resolve, reject) => {
@@ -364,3 +368,3 @@ const start = Date.now();
                 }
-                if ((0, client_common_1.isSuccessfulResponse)(_response.statusCode)) {
+                if ((0, client_common_2.isSuccessfulResponse)(_response.statusCode)) {
                     return resolve({
@@ -375,3 +379,3 @@ stream: decompressionResult.response,
                 else {
-                    reject((0, client_common_1.parseError)(await (0, utils_1.getAsText)(decompressionResult.response)));
+                    reject((0, client_common_2.parseError)(await (0, utils_1.getAsText)(decompressionResult.response)));
                 }
@@ -378,0 +382,0 @@ };

dist/index.d.ts

@@ -1,2 +0,2 @@
-export type { NodeClickHouseClient as ClickHouseClient, QueryResult, } from './client';
+export { NodeClickHouseClient as ClickHouseClient, type QueryResult, } from './client';
 export { createClient } from './client';
@@ -3,0 +3,0 @@ export { type NodeClickHouseClientConfigOptions as ClickHouseClientConfigOptions } from './config';

dist/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.SettingsMap = exports.ClickHouseLogLevel = exports.ClickHouseError = exports.drainStream = exports.ResultSet = exports.createClient = void 0;
+exports.SettingsMap = exports.ClickHouseLogLevel = exports.ClickHouseError = exports.drainStream = exports.ResultSet = exports.createClient = exports.ClickHouseClient = void 0;
 var client_1 = require("./client");
-Object.defineProperty(exports, "createClient", { enumerable: true, get: function () { return client_1.createClient; } });
+Object.defineProperty(exports, "ClickHouseClient", { enumerable: true, get: function () { return client_1.NodeClickHouseClient; } });
+var client_2 = require("./client");
+Object.defineProperty(exports, "createClient", { enumerable: true, get: function () { return client_2.createClient; } });
 var result_set_1 = require("./result_set");
@@ -7,0 +9,0 @@ Object.defineProperty(exports, "ResultSet", { enumerable: true, get: function () { return result_set_1.ResultSet; } });

dist/version.d.ts

@@ -1,2 +0,2 @@
-declare const _default: "1.4.0";
+declare const _default: "1.4.1";
 export default _default;

dist/version.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.default = '1.4.0';
+exports.default = '1.4.1';
 //# sourceMappingURL=version.js.map

package.json

@@ -5,3 +5,3 @@ {
   "homepage": "https://clickhouse.com",
-  "version": "1.4.0",
+  "version": "1.4.1",
   "license": "Apache-2.0",
@@ -27,4 +27,4 @@ "keywords": [
   "dependencies": {
-    "@clickhouse/client-common": "1.4.0"
+    "@clickhouse/client-common": "1.4.1"
   }
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

110736

increased by0.58%

Lines of code

1482

increased by0.41%

Dependency changes

• + Added@clickhouse/client-common@1.4.1(transitive)

• - Removed@clickhouse/client-common@1.4.0(transitive)

• Updated@clickhouse/client-common@1.4.1