4 Commits

Author SHA1 Message Date
bd9b3bb985 2.0.4 2022-07-27 08:32:55 +02:00
169e49b93d fix(core): update 2022-07-27 08:32:55 +02:00
2db4010648 2.0.3 2022-07-27 08:29:59 +02:00
b4ae49b604 fix(core): update 2022-07-27 08:29:59 +02:00
7 changed files with 5154 additions and 574 deletions

5678
package-lock.json generated

File diff suppressed because it is too large Load Diff

View File

@ -1,6 +1,6 @@
{ {
"name": "@pushrocks/smartclickhouse", "name": "@pushrocks/smartclickhouse",
"version": "2.0.2", "version": "2.0.4",
"private": false, "private": false,
"description": "an odm for talking to clickhouse", "description": "an odm for talking to clickhouse",
"main": "dist_ts/index.js", "main": "dist_ts/index.js",
@ -15,17 +15,18 @@
"createClickhouse": "docker run --name some-clickhouse-server --ulimit nofile=262144:262144 -p 8123:8123 -p 9000:9000 --volume=$PWD/.nogit/testdatabase:/var/lib/clickhouse yandex/clickhouse-server" "createClickhouse": "docker run --name some-clickhouse-server --ulimit nofile=262144:262144 -p 8123:8123 -p 9000:9000 --volume=$PWD/.nogit/testdatabase:/var/lib/clickhouse yandex/clickhouse-server"
}, },
"devDependencies": { "devDependencies": {
"@gitzone/tsbuild": "^2.1.61", "@gitzone/tsbuild": "^2.1.63",
"@gitzone/tsbundle": "^2.0.3", "@gitzone/tsbundle": "^2.0.6",
"@gitzone/tstest": "^1.0.71", "@gitzone/tstest": "^1.0.72",
"@pushrocks/tapbundle": "^5.0.3", "@pushrocks/tapbundle": "^5.0.4",
"@types/node": "^17.0.33", "@types/node": "^18.6.1",
"tslint": "^6.1.3", "tslint": "^6.1.3",
"tslint-config-prettier": "^1.15.0" "tslint-config-prettier": "^1.15.0"
}, },
"dependencies": { "dependencies": {
"@depyronick/clickhouse-client": "^1.0.13", "@depyronick/clickhouse-client": "^1.0.14",
"@pushrocks/smartobject": "^1.0.10" "@pushrocks/smartobject": "^1.0.10",
"@pushrocks/smarturl": "^3.0.1"
}, },
"browserslist": [ "browserslist": [
"last 1 chrome versions" "last 1 chrome versions"

View File

@ -7,6 +7,8 @@ tap.test('first test', async () => {
testClickhouseDb = new smartclickhouse.SmartClickHouseDb({ testClickhouseDb = new smartclickhouse.SmartClickHouseDb({
host: 'localhost', host: 'localhost',
database: 'test2', database: 'test2',
port: 8123,
protocol: 'http',
}); });
}); });

View File

@ -3,6 +3,6 @@
*/ */
export const commitinfo = { export const commitinfo = {
name: '@pushrocks/smartclickhouse', name: '@pushrocks/smartclickhouse',
version: '2.0.2', version: '2.0.4',
description: 'an odm for talking to clickhouse' description: 'an odm for talking to clickhouse'
} }

View File

@ -2,7 +2,7 @@ import * as plugins from './smartclickhouse.plugins.js';
import { TimeDataTable } from './smartclickhouse.classes.timedatatable.js'; import { TimeDataTable } from './smartclickhouse.classes.timedatatable.js';
export interface IClickhouseConstructorOptions { export interface IClickhouseConstructorOptions {
host: string; url: string;
database: string; database: string;
password?: string; password?: string;
} }
@ -20,8 +20,20 @@ export class SmartClickHouseDb {
*/ */
public async start(dropOld = false) { public async start(dropOld = false) {
console.log(`Connecting to default database first.`); console.log(`Connecting to default database first.`);
const defaultOptions: {[keyArg: string]: string} = {};
// the protocol, url and host
const parsedUrl = plugins.smarturl.Smarturl.createFromUrl(this.options.url);
parsedUrl.protocol === 'https' ? defaultOptions.protocol = plugins.clickhouse.ClickHouseConnectionProtocol.HTTPS : null;
parsedUrl.protocol === 'http' ? defaultOptions.protocol = plugins.clickhouse.ClickHouseConnectionProtocol.HTTP : null;
defaultOptions.host = parsedUrl.hostname;
defaultOptions.port = parsedUrl.port;
// the database
defaultOptions.database = this.options.database;
// the password
this.options.password ? defaultOptions.password = this.options.password : null;
// lets connect
const defaultClient = new plugins.clickhouse.ClickHouseClient({ const defaultClient = new plugins.clickhouse.ClickHouseClient({
...this.options, ...defaultOptions,
database: 'default', database: 'default',
}); });
console.log(`Create database ${this.options.database}, if it does not exist...`); console.log(`Create database ${this.options.database}, if it does not exist...`);
@ -32,7 +44,7 @@ export class SmartClickHouseDb {
console.log(`Ensured database. Now connecting to wanted database: ${this.options.database}`); console.log(`Ensured database. Now connecting to wanted database: ${this.options.database}`);
this.clickhouseClient = new plugins.clickhouse.ClickHouseClient({ this.clickhouseClient = new plugins.clickhouse.ClickHouseClient({
...this.options, ...defaultOptions
}); });
console.log(`trying to ping database...`); console.log(`trying to ping database...`);
const result = await this.clickhouseClient.ping(); const result = await this.clickhouseClient.ping();

View File

@ -1,8 +1,10 @@
// @pushrocks scope // @pushrocks scope
import * as smartobject from '@pushrocks/smartobject'; import * as smartobject from '@pushrocks/smartobject';
import * as smarturl from '@pushrocks/smarturl';
export { export {
smartobject smartobject,
smarturl
} }
// thirdparty // thirdparty

View File

@ -1,5 +1,10 @@
{ {
"compilerOptions": { "compilerOptions": {
"moduleResolution": "node12" "experimentalDecorators": true,
"useDefineForClassFields": false,
"target": "ES2022",
"module": "ES2022",
"moduleResolution": "nodenext",
"esModuleInterop": true
} }
} }