clickhouse-ts - npm Package Compare versions

Comparing version 1.3.1 to 1.3.2

dist/src/clickhouse/Clickhouse.d.ts

		@@ -13,13 +13,4 @@ import { ClickhouseNamespace } from './interface';
		insert(table: string, rows: ClickhouseNamespace.InsertRows, options?: ClickhouseNamespace.InsertOptions): Promise<{
		r: number;
		result: {
		chunk: string;
		cached: number;
		};
		} \| {
		r: number;
		result: {
		inserted: number;
		data: ClickhouseNamespace.InsertRows;
		};
		inserted: number;
		data: ClickhouseNamespace.InsertRows;
		}>;
		@@ -26,0 +17,0 @@ /**

dist/src/clickhouse/Clickhouse.js

		@@ -60,12 +60,2 @@ "use strict";
		async insert(table, rows, options = {}) {
		if (__classPrivateFieldGet(this, _Clickhouse_cacheManager, "f")) {
		if (__classPrivateFieldGet(this, _Clickhouse_isFirstInsert, "f")) {
		console.log('first insert');
		await __classPrivateFieldGet(this, _Clickhouse_cacheManager, "f").useRedisInstance(__classPrivateFieldGet(this, _Clickhouse_redisClient, "f"));
		__classPrivateFieldSet(this, _Clickhouse_isFirstInsert, false, "f");
		}
		const result = await __classPrivateFieldGet(this, _Clickhouse_cacheManager, "f")
		.cache(table, rows.map(row => JSON.stringify(row)));
		return { r: 1, result };
		}
		const keys = Object.keys(rows[0]).join(',');
		@@ -76,6 +66,3 @@ const values = rows.map(row => `(${Object.values(row).map(v => sqlstring_1.default.escape(v)).join(',')})`).join(',');
		});
		return {
		r: 1,
		result: { inserted: rows.length, data: rows }
		};
		return { inserted: rows.length, data: rows };
		}
		@@ -106,4 +93,9 @@ /**
		}
		return await __classPrivateFieldGet(this, _Clickhouse_cacheManager, "f").cache(table, rows.map(row => JSON.stringify(row)));
		// return await this.#cacheClient.cacheTableRows(table, rows)
		if (__classPrivateFieldGet(this, _Clickhouse_isFirstInsert, "f")) {
		await __classPrivateFieldGet(this, _Clickhouse_cacheManager, "f").useRedisInstance(__classPrivateFieldGet(this, _Clickhouse_redisClient, "f"));
		__classPrivateFieldSet(this, _Clickhouse_isFirstInsert, false, "f");
		}
		const result = await __classPrivateFieldGet(this, _Clickhouse_cacheManager, "f")
		.cache(table, rows.map(row => JSON.stringify(row)));
		return result;
		}
		@@ -110,0 +102,0 @@ }

package.json

		@@ -12,3 +12,3 @@ {
		],
		"version": "1.3.1",
		"version": "1.3.2",
		"license": "MIT",
		@@ -15,0 +15,0 @@ "description": "Clickhouse client on TypeScript using nodejs ot redis caching queries",

README.md

		@@ -79,3 +79,3 @@ # clickhouse-ts
		const response = clickhouseInstance
		.insert(
		.cache(
		'strings',
		@@ -82,0 +82,0 @@ [{ date: '2021-01-01', string: 'str1' }, { date: '2021-01-02', string: 'str2' }],

src/clickhouse/Clickhouse.ts

		@@ -59,17 +59,2 @@ import { ClickhouseHttpClient } from '../httpClient/ClickhouseHttpClient'
		) {
		if (this.#cacheManager) {
		if (this.#isFirstInsert) {
		console.log('first insert')
		await this.#cacheManager.useRedisInstance(this.#redisClient!)
		this.#isFirstInsert = false
		}

		const result = await this.#cacheManager
		.cache(
		table,
		rows.map(row => JSON.stringify(row))
		)
		return { r: 1, result }
		}

		const keys = Object.keys(rows[0]).join(',')
		@@ -82,6 +67,3 @@ const values = rows.map(row => `(${Object.values(row).map(v => sqlstring.escape(v)).join(',')})`).join(',')

		return {
		r: 1,
		result: { inserted: rows.length, data: rows }
		}
		return { inserted: rows.length, data: rows }
		}
		@@ -124,5 +106,15 @@
		}
		return await this.#cacheManager.cache(table, rows.map(row => JSON.stringify(row)))
		// return await this.#cacheClient.cacheTableRows(table, rows)

		if (this.#isFirstInsert) {
		await this.#cacheManager.useRedisInstance(this.#redisClient!)
		this.#isFirstInsert = false
		}

		const result = await this.#cacheManager
		.cache(
		table,
		rows.map(row => JSON.stringify(row))
		)
		return result
		}
		}

clickhouse-ts - npm Package Compare versions

New alerts

Fixed alerts

Worsened metrics