smartclickhouse/ts/smartclickhouse.classes.smartclickhouse.ts

import * as plugins from './smartclickhouse.plugins.js';
import { TimeDataTable } from './smartclickhouse.classes.timedatatable.js';

export interface IClickhouseConstructorOptions {
  host: string;
  database: string;
  password?: string;
}

export class SmartClickHouseDb {
  public options: IClickhouseConstructorOptions;
  public clickhouseClient: plugins.clickhouse.ClickHouseClient;

  constructor(optionsArg: IClickhouseConstructorOptions) {
    this.options = optionsArg;
  }

  /**
   * starts the connection to the Clickhouse db
   */
  public async start(dropOld = false) {
    console.log(`Connecting to default database first.`);
    const defaultClient = new plugins.clickhouse.ClickHouseClient({
      ...this.options,
      database: 'default',
    });
    console.log(`Create database ${this.options.database}, if it does not exist...`);
    if (dropOld) {
      await defaultClient.queryPromise(`DROP DATABASE IF EXISTS ${this.options.database}`);
    }
    await defaultClient.queryPromise(`CREATE DATABASE IF NOT EXISTS ${this.options.database}`);

    console.log(`Ensured database. Now connecting to wanted database: ${this.options.database}`);
    this.clickhouseClient = new plugins.clickhouse.ClickHouseClient({
      ...this.options,
    });
    console.log(`trying to ping database...`);
    const result = await this.clickhouseClient.ping();
    console.log(`Ping successfull?: ${result}`);
  }

  /**
   * gets a table
   */
  public async getTable(tableName: string) {
    const newTable = TimeDataTable.getTable(this, tableName);
    return newTable;
  }
}