Add support for URL connection string in ClickHouse client

__tests__/unit/client.test.ts

@@ -8,21 +8,28 @@ describe('createClient', () => {
     )
   })
 
-  it('should not mutate provided configuration', async () => {
+  it('throws on incorrect "url" config value', () => {
+    expect(() => createClient({ url: 'bar' })).toThrowError(
+      'Configuration parameter "url" contains malformed url.'
+    )
+  })
+
+  it('should accept url connection string and not mutate provided configuration', async () => {
     const config: ClickHouseClientConfigOptions = {
-      host: 'http://localhost',
+      url: 'clickhouse://default:password@localhost/default',
+      password: 'foobar',
     }
     createClient(config)
     // none of the initial configuration settings are overridden
     // by the defaults we assign when we normalize the specified config object
     expect(config).toEqual({
-      host: 'http://localhost',
+      url: 'clickhouse://default:password@localhost/default',
       request_timeout: undefined,
       max_open_connections: undefined,
       tls: undefined,
       compression: undefined,
       username: undefined,
-      password: undefined,
+      password: 'foobar',
       application: undefined,
       database: undefined,
       clickhouse_settings: undefined,

src/client.ts

@@ -14,6 +14,10 @@ import type { ClickHouseSettings } from './settings'
 import type { InputJSON, InputJSONObjectEachRow } from './clickhouse_types'
 
 export interface ClickHouseClientConfigOptions {
+  /** ClickHouse connection string url
+   * ```clickhouse://[user_info@][hosts_and_ports][/dbname][?query_parameters]```
+   */
+  url?: string
   /** A ClickHouse instance URL.
    * <br/> Default value: `http://localhost:8123`. */
   host?: string
@@ -135,11 +139,11 @@ function validateConfig({ url }: NormalizedConfig): void {
   // TODO add SSL validation
 }
 
-function createUrl(host: string): URL {
+function createUrl(url: string, type: 'host' | 'url'): URL {
   try {
-    return new URL(host)
+    return new URL(url)
   } catch (err) {
-    throw new Error('Configuration parameter "host" contains malformed url.')
+    throw new Error(`Configuration parameter "${type}" contains malformed url.`)
   }
 }
 
@@ -158,20 +162,29 @@ function normalizeConfig(config: ClickHouseClientConfigOptions) {
       }
     }
   }
+
+  const url = config.url && createUrl(config.url, 'url')
+
   return {
     application_id: config.application,
-    url: createUrl(config.host ?? 'http://localhost:8123'),
+    url: createUrl(
+      config.host ?? (url && `http://${url.host}`) ?? 'http://localhost:8123',
+      'host'
+    ),
     request_timeout: config.request_timeout ?? 300_000,
     max_open_connections: config.max_open_connections ?? Infinity,
     tls,
     compression: {
       decompress_response: config.compression?.response ?? true,
       compress_request: config.compression?.request ?? false,
     },
-    username: config.username ?? 'default',
-    password: config.password ?? '',
-    database: config.database ?? 'default',
-    clickhouse_settings: config.clickhouse_settings ?? {},
+    username: config.username ?? (url && url.username) ?? 'default',
+    password: config.password ?? (url && url.password) ?? '',
+    database: config.database ?? (url && url.pathname.slice(1)) ?? 'default',
+    clickhouse_settings:
+      config.clickhouse_settings ??
+      (url && Object.fromEntries(url.searchParams)) ??
+      {},
     log: {
       LoggerClass: config.log?.LoggerClass ?? DefaultLogger,
     },