- OpenTelemetry: richer, more actionable spans (requested by Langfuse, #948). (#950)
- The
X-ClickHouse-Summaryheader is now parsed on the Web client and attached to the operation spans (query/command/exec/insert), including the outerclickhouse.queryspan. Previously the Web client did not parse the summary header at all. - Every key present in the summary header is recorded as
clickhouse.summary.<key>(the set is not hardcoded). This surfacestotal_rows_to_readandmemory_usage(peak query memory, in bytes; sent by newer servers), and picks up future server-side additions (e.g.real_time_microseconds) automatically. db.response.returned_rowsis now recorded for non-streaming result consumption too (json()onJSON/JSONObjectEachRow/ the other single-document JSON formats), not just row-streaming paths.- Added a
span_attributesfield to the per-request query params (query/command/exec/insert/ping). Use it to enrich the operation span with application-level context — e.g. mirroring the tags you also send via thelog_commentsetting (route, tenant, surface, etc.). Caller-provided attributes never override the client's owndb.*/server.*/clickhouse.*attributes. - Added a
dangerously_log_query_textclient option (defaultfalse). When enabled, the raw SQL statement is attached to spans as the OpenTelemetrydb.query.textattribute. The query text may contain sensitive literals, which is why it is off by default; boundquery_paramsvalues and credentials are never traced regardless of this setting.
- The
- Fixed
Array(Date)/Array(Date32)query-parameter binding (and other temporal element types nested in arrays, tuples, and maps). A JSDateinside a container was serialized as a bare Unix timestamp (e.g.[1683244800]), which the server'sArray(Date)element parser rejects (CANNOT_PARSE_INPUT_ASSERTION_FAILED). Container-nestedDatevalues are now emitted as a quoted UTC date string (e.g.['2023-05-05']), the one encoding every temporal element type accepts. Note: aDateused insideArray(DateTime)/Array(DateTime64)is now bound at day precision (the time-of-day is dropped), since date-only is the only formArray(Date)accepts; scalarDate/DateTimebinding is unchanged. (#947)
- Re-export
EXCEPTION_TAG_HEADER_NAMEandextractErrorAtTheEndOfChunkfrom@clickhouse/client-web. Both are part of the (now deprecated)@clickhouse/client-commonpublic API but were missed when its surface was bundled into and re-exported from the client packages in 1.23.0 (#845). Reported downstream by Langfuse. (#935)
-
Node.js 26.x was added to the CI matrix, and Node.js 18.x is no longer supported. The
engines.nodefloor of@clickhouse/client(previously>=16) and@clickhouse/datatype-parser(previously>=18.0.0) was raised to>=20. Node.js 20.x, 22.x, 24.x, and 26.x are supported and exercised in CI. -
The
@clickhouse/client-commonpackage is deprecated.@clickhouse/client(Node.js) and@clickhouse/client-web(Web) no longer depend on it; the shared code is now bundled into each client package. Everything previously importable from@clickhouse/client-commonshould be imported from@clickhouse/clientor@clickhouse/client-webinstead. The@clickhouse/client-commonpackage itself will no longer receive updates. (#845) -
The
parseColumnTypefunction and itsSimpleColumnTypescompanion (exported from@clickhouse/client,@clickhouse/client-web, and@clickhouse/client-common) are deprecated and slated for removal in a future major version. They are superseded by the new standalone@clickhouse/datatype-parserpackage (parseDataTypeplus itsNodeAST), which parses the full ClickHouse data-type grammar and emits an AST that mirrors the server's. (#893)
-
(Node.js) Added a RowBinary reader library and agent skill under
skills/clickhouse-js-node-rowbinary-parser. It ships type-specific, monomorphizable building blocks for decodingRowBinary/RowBinaryWithNames/RowBinaryWithNamesAndTypesstreams (full-buffer and chunked), plus a skill that guides an agent to generate bespoke high-performance parsers from a query's column types. The skill is bundled into@clickhouse/client(registered inagents.skills) and is also published independently as the@clickhouse/rowbinarypackage. A matching RowBinary writer is planned. (#864) -
Published the
@clickhouse/datatype-parserpackage: a small, dependency-free standalone parser for ClickHouse data-type strings (the kind sent in the types row ofRowBinaryWithNamesAndTypes, e.g.Array(Nullable(UInt64)),Tuple(a UInt8, b String),Enum8('a' = 1)). It is a faithful port of the server'sParserDataTypeand emits a JSON AST that is byte-identical to the server'sEXPLAIN AST json = 1data-type subtree. It supersedes the deprecatedparseColumnType(see Migration Notes). (#893) -
(Node.js,
@experimental) Added an additiveconnection?: Connection<Stream.Readable>option tocreateClientthat lets a caller plug an externally-built backendConnection-like object in place of the default HTTP(S) factory. Only supposed to be used for testing thechDBintegration. ([#879]) -
Added
ClickHouseSettingsInterface, a package-neutral structural counterpart toClickHouseSettings, exported from@clickhouse/client,@clickhouse/client-web, and@clickhouse/client-common. It is identical toClickHouseSettingsexcept that its index signature omitsSettingsMap(a class with a private member, which TypeScript compares nominally). Because each client package now bundles its own copy of the common module, theirClickHouseSettingstypes are mutually unassignable;ClickHouseSettingsInterfaceis structurally identical across all three packages and assignable into each package'sClickHouseSettings, so a consumer that shares a single settings-producing helper across both the Node.js and Web clients can type it against this one type without casts. Values typed asSettingsMapcannot be carried through it — useClickHouseSettingsif you need them. (#889)
-
(Node.js) The
compression.request/compression.responseclient options now accept an explicit codec via an object, in addition to the existing boolean:truekeeps gzip (backwards compatible), and{ codec: "zstd" }selects zstd. The object form is intentionally extensible for future codecs and codec-specific options. zstd typically yields a similar-or-better ratio than gzip at noticeably lower CPU cost (gzip/DEFLATE is comparatively CPU-heavy and decompressed single-threaded by the ClickHouse server), and it uses the built-inzlibzstd support, so it requires Node.js >= 22.15.0 (@clickhouse/clientthrows a clear error at client creation otherwise). Response decompression is driven by the server's actualContent-Encoding, so it degrades gracefully. The request object form also accepts an optionallevel({ codec, level }) to set the codec-specific compression level (zlib level for gzip, zstd compression level for zstd); the response compression level is controlled by the server. Supported only by@clickhouse/client(Node.js);@clickhouse/client-webrejects thezstdcodec at client creation. -
(Node.js) Brotli (
{ codec: "br" }) is now supported forcompression.request/compression.response, alongside gzip and zstd. Unlike zstd, Brotli is available on every supported Node.js version (no minimum-version requirement). Thecompression.requestoption is a per-codec discriminated union, so each codec exposes its own tuning option: alevelfor gzip/zstd, aqualityfor Brotli ({ codec: "br", quality }). When omitted, Brotli defaults to quality 4 for request bodies, since zlib's brotli default of 11 (max) is far too slow for a streaming insert path. Response decompression follows the server'sContent-Encoding. Supported only by@clickhouse/client(Node.js).
These only affect code that imports the low-level connection primitives from the deprecated
@clickhouse/client-commonpackage directly (e.g. a customConnectionimplementation). ThecreateClientcompressionoption is unchanged and fully backwards compatible — if you only use@clickhouse/clientor@clickhouse/client-web, you are not affected.
To carry the codec (and its optional compression level) instead of a bare on/off flag, the internal compression representation changed shape:
CompressionSettings.compress_request/decompress_responseare no longerboolean. They are now a normalized codec object orundefined(disabled):{ codec: "gzip" | "zstd"; level?: number } | { codec: "br"; quality?: number }for the request,{ codec: "gzip" | "zstd" | "br" }for the response (response compression options are chosen by the server).getConnectionParamsnormalizes the public request option into this form (true→{ codec: "gzip" }).withCompressionHeadersnow takesrequest_compression_codec/response_compression_codec(aCompressionMethod | undefined) instead of the booleanenable_request_compression/enable_response_compression; the codec value is also theContent-Encoding/Accept-Encodingit emits.withHttpSettingsnow takes the response codec object ({ codec } | undefined) instead of aboolean.- New exported types:
CompressionMethod,RequestCompression,ResponseCompression.
Why: a single boolean could not express which codec to use or its level, and a separate level field on CompressionSettings would have mixed a codec-specific option into the shared type. Discriminating by codec keeps each codec's options on the codec it belongs to.
- Added two tracer adapter recipes to
docs/howto/tracing.mdandexamples/node/coding/otel_tracing.ts, demonstrating how common OpenTelemetry auto-instrumentation options compose as thin userland wrappers around thetracerAPI instead of being baked into the client:requireParentSpan(skip ClickHouse spans when there is no active parent span — e.g. background health checks) and suppressing the duplicate nested HTTP spans emitted by@opentelemetry/instrumentation-http(viasuppressTracingfrom@opentelemetry/core).
-
The tracer API (unreleased, introduced in #776) now follows the OpenTelemetry database semantic conventions and matches the attribute vocabulary of the Rust client (clickhouse-rs); see
docs/howto/tracing.mdfor the documentation. In particular (#828):- Spans now carry
db.system.name(instead ofdb.system),server.address+server.port(instead of a combinedhost:port),clickhouse.request.query_id/clickhouse.request.session_id(instead ofclickhouse.query_id/clickhouse.session_id),clickhouse.response.formatonqueryandclickhouse.request.formatoninsert(instead ofclickhouse.format), anddb.operation.name+db.collection.nameoninsert(instead ofclickhouse.table). - The span status is left unset on success (per the OTEL spec recommendation for client spans, previously set to
OK); on failure, the span gets theerror.typeattribute (the error class name) and, for server-side errors,clickhouse.error.code(the numeric ClickHouse error code). - Spans record response-side attributes:
db.response.status_code(HTTP status) and, when theX-ClickHouse-Summaryheader is available,clickhouse.summary.*counters (read_rows,written_rows, etc.). query()now emits two spans:clickhouse.querycovers the HTTP request lifetime and ends as soon as the response headers are received; a childclickhouse.query.streamspan is handed to theResultSetand tracks the stream consumption, ending when the response is fully read, closed, or fails - with the finalclickhouse.response.decoded_bytesand (for row-streaming)db.response.returned_rowsmetrics. This separation makes it easy to distinguish the original request duration from a stream that may never end (e.g. tailing a live table).- Fixed a span leak in the Web
ResultSet.stream()path: if the underlying fetch response stream was aborted (e.g. due to a network error), theclickhouse.query.streamspan was never ended. The TransformStream now handles both source-stream aborts and consumer-side cancellations via acancelcallback. - The
insertspan recordsclickhouse.request.sent_rowsfor array-based inserts.
- Spans now carry
-
Added a
use_multipart_params_autoclient option (default:false). When enabled,query()automatically sendsquery_paramsasmultipart/form-databody parts (the same mechanism asuse_multipart_params) once their URL-encoded length exceeds 4096 characters, avoiding HTTP 414/400 errors from HTTP intermediaries (nginx, AWS ALB, CloudFront) caused by over-long URLs - for example, a largeINlist or a high-dimensional vector embedding. Smaller parameter payloads remain in the URL query string, so existing behavior is unchanged unless the threshold is crossed.use_multipart_params: truestill forces multipart for all queries regardless of size. This does not change the server's per-value size limit, which is governed byhttp_max_field_value_size. Supported on both@clickhouse/clientand@clickhouse/client-web, and overridable per request viause_multipart_params_autoonquery(). Ported from clickhouse-connect#789. (#827)
const client = createClient({ use_multipart_params_auto: true });
await client.query({
query: "SELECT * FROM events WHERE id IN {ids:Array(UInt64)}",
// Sent in the URL when small, auto-promoted to the multipart body when large
query_params: { ids: veryLargeArrayOfIds },
});- Added a
use_multipart_paramsclient option (default:false). When enabled,query()sendsquery_paramsasmultipart/form-databody parts (with the SQL moved into aquerypart) instead of URL query-string entries, avoiding HTTP 400 errors caused by over-long URLs when parameters contain large arrays (25K+ values). All other URL search params (database, query_id, settings, session_id, role) remain in the URL. Supported on both@clickhouse/clientand@clickhouse/client-web, and overridable per request viause_multipart_paramsonquery(). (#825)
const client = createClient({ use_multipart_params: true });
await client.query({
query: "SELECT * FROM events WHERE id IN {ids:Array(UInt64)}",
query_params: { ids: veryLargeArrayOfIds },
// Per-request override is also supported:
// use_multipart_params: false,
});- The client now checks the
X-ClickHouse-Exception-Coderesponse header to detect server errors even when the HTTP status code indicates success. In some scenarios (for example, when an exception occurs while streaming the response progress in headers, or with certain proxy setups), ClickHouse responds with HTTP 200 but sets theX-ClickHouse-Exception-Codeheader. Previously, such responses were treated as successful, and the exception text could surface as malformed response data; now the request is rejected with a parsedClickHouseError(with the propercodeandtype), consistent with non-2xx error responses. This applies to both the Node.js and Web clients. (#554, supersedes #350, related issue: #332)
- Added an optional tracer API that the user can pass through the client config (
tracer) and that gets called around key lifecycle operations (query,command,exec,insert,ping). TheClickHouseTracerinterface is a structural subset of the OpenTelemetryTracer/SpanAPIs, so a raw OTEL tracer (trace.getTracer(...)) can be passed to the client as-is - but the client itself ships no tracing dependency. Each operation runs insidetracer.startActiveSpan(...), so auto-instrumented child spans nest under the ClickHouse operation spans; for OpenTelemetry, this requires theAsyncLocalStorageContextManagerto be registered (the default in the OpenTelemetry Node.js SDK). Tracer exceptions are NOT caught, so a broken tracer will break client operations. Seedocs/howto/tracing.mdfor the full surface description, andexamples/node/coding/otel_tracing.tsfor a runnable Node.js example. (#776)
import { createClient } from "@clickhouse/client";
import { trace } from "@opentelemetry/api";
// a raw OpenTelemetry tracer is structurally compatible - no adapter needed
const client = createClient({
url: "http://localhost:8123",
tracer: trace.getTracer("@clickhouse/client"),
});- TypeScript:
ClickHouseLogLevelis now exported as a literal numeric union type (0 | 1 | 2 | 3 | 4 | 127) instead of a TypeScriptenumtype. If you were assigning arbitrarynumbervalues toClickHouseLogLevel, you may need to narrow/cast those values during migration.
- Added TypeScript typings for the remaining HTTP-specific ClickHouse settings, so they are now suggested by autocomplete when used in
clickhouse_settings:buffer_size,compress,decompress,quota_key, andstacktrace(in addition to the existingwait_end_of_query,default_format,session_timeout, andsession_check).
await client.query({
query: "SELECT 1",
clickhouse_settings: {
// Buffer the entire response on the server before sending it to the client
wait_end_of_query: 1,
buffer_size: "1048576",
},
});- (Node.js only) Fixed a race condition in
ResultSet.json()andResultSet.stream()onJSONEachRow(and other streamable) result sets where callingjson()on a fast/small response could throwStream has been already consumedif the underlying stream ended between internalreadableEndedchecks. The consumption guard has been hardened: the stream is now shielded through a singleconsume()path that marks the result set as consumed in the appropriate branches, after format validation, so a successfuljson()call no longer races against the stream finishing. (#603)
- Re-exported the
ResponseHeaderstype from@clickhouse/clientand@clickhouse/client-web. Previously this type was only available from@clickhouse/client-common; it is now part of the public re-export surface of both flavored packages, alongside the other commonly used types. This is part of an ongoing effort to make@clickhouse/client-commonan internal-only package so downstream consumers can depend solely on@clickhouse/clientor@clickhouse/client-web. (#758)
- Enum type parsing now correctly unescapes backslash escape sequences in enum names. Previously,
parseEnumTypereturned enum names with raw escape sequences (e.g.,f\'instead off'). Now it properly decodes escape sequences including\'(single quote),\\(backslash),\n(newline),\t(tab), and\r(carriage return). This matches the behavior of ClickHouse string literals and ensures consistency with how the client encodes strings when sending data to the server. If you were relying on the previous incorrect behavior where backslash escape sequences were preserved in enum names, you will need to update your code to handle properly unescaped values.
Example:
// Before (incorrect):
parseEnumType({
columnType: "Enum8('f\\'' = 1)",
sourceType: "Enum8('f\\'' = 1)",
});
// returned: { values: { 1: "f\\'" } } // with backslash
// After (correct):
parseEnumType({
columnType: "Enum8('f\\'' = 1)",
sourceType: "Enum8('f\\'' = 1)",
});
// returns: { values: { 1: "f'" } } // unescaped- (Node.js only) Added
max_response_headers_sizeclient option that forwards themaxHeaderSizeoption to the underlyinghttp(s).requestcall. This raises the per-request limit on the total size of HTTP response headers received from the server (Node.js default is ~16 KB). It is most useful when running long-running queries withsend_progress_in_http_headersenabled — theX-ClickHouse-Progressheaders accumulate over the lifetime of the request and can exceed the default limit, causing the request to fail withHPE_HEADER_OVERFLOW. Setting this option avoids the need to use the global--max-http-header-sizeNode.js CLI flag or theNODE_OPTIONSenvironment variable. Has no effect for the Web client (which usesfetch) and no effect when a customhttp_agentis configured with a request implementation that does not honor the option.
const client = createClient({
request_timeout: 400_000,
max_response_headers_size: 1024 * 1024, // accept up to 1 MiB of response headers
clickhouse_settings: {
send_progress_in_http_headers: 1,
http_headers_progress_interval_ms: "110000",
},
});- The
@clickhouse/clientnpm package now ships embedded AI-agent skills,clickhouse-js-node-codingandclickhouse-js-node-troubleshooting, undernode_modules/@clickhouse/client/skills/. These skills are also declared in theagents.skillsfield of the package manifest for discovery tools that scannode_modules. This allows agentic coding tools to load focused, Node-client-specific coding and troubleshooting guidance without any additional setup. (#682)
A release-infrastructure-only version bump (no user-facing changes). See 1.18.5 for the next release with user-facing improvements.
- Added
keep_alive.eagerly_destroy_stale_socketsoption (Node.js only, default:false). When enabled, sockets that have been idle for longer thanidle_socket_ttlare destroyed immediately before each request, rather than waiting for the idle timeout to fire. This helps reclaim stale sockets during event loop delays, where the timeout callback may not run on time.
const client = createClient({
keep_alive: {
enabled: true,
idle_socket_ttl: 2500,
eagerly_destroy_stale_sockets: true,
},
});- Added auto-detection and warning when
request_timeoutis high (> 60 seconds) but progress headers are not configured. Long-running queries may fail with socket hang-up errors if they exceed the load balancer idle timeout. The client now warns users to enablesend_progress_in_http_headersandhttp_headers_progress_interval_mssettings to prevent such issues.
// This will now trigger a warning
const client = createClient({
request_timeout: 120_000, // 120 seconds
// send_progress_in_http_headers is not configured
});
// ✓ Properly configured to avoid load balancer timeouts
const client = createClient({
request_timeout: 400_000,
clickhouse_settings: {
send_progress_in_http_headers: 1,
http_headers_progress_interval_ms: "110000", // ~10s below LB timeout
},
});- Added a helping
WARNlevel log message with a suggestion to check thekeep_aliveconfiguration if the client receives anECONNRESETerror from the server, which can happen when the server closes idle connections after a certain timeout, and the client tries to reuse such a connection from the pool. This can be especially helpful for new users who might not be aware of this aspect of HTTP connection management. The log message is only emitted if thekeep_aliveoption is enabled in the client configuration, and it includes the server's keep-alive timeout value (if available) to assist with troubleshooting. (#597)
How to reproduce the issue that triggers the log message:
const client = createClient({
// ...
keep_alive: {
enabled: true,
// ❌ DON'T SET THIS VALUE SO HIGH IN PRODUCTION
idle_socket_ttl: 1_000_000,
},
log: {
level: ClickHouseLogLevel.WARN, // to see the warning logs
},
});
for (let i = 0; i < 1000; i++) {
await client.ping({
// To use a regular query instead of the /ping endpoint
// which might be configured differently on the server side
// and have different timeout settings.
select: true,
});
// Wait long enough to let the server close the idle connection,
// but not too long to let the client remove it from the pool,
// in other words try to hit the scenario when the race condition
// happens between the server closing the connection and the client
// trying to reuse it.
await sleep(SERVER_KEEP_ALIVE_TIMEOUT_MS - 100);
}Example log message:
{
"message": "Ping: idle socket TTL is greater than server keep-alive timeout, try setting idle socket TTL to a value lower than the server keep-alive timeout to prevent unexpected connection resets, see https://github.com/ClickHouse/clickhouse-js/blob/main/docs/howto/keep_alive_timeout.md for more details.",
"args": {
"operation": "Ping",
"connection_id": "8dc1c9bd-7895-49b1-8a95-276470151c65",
"query_id": "beee95af-2e83-4dcb-8e1e-045bd61f4985",
"request_id": "8dc1c9bd-7895-49b1-8a95-276470151c65:2",
"socket_id": "8dc1c9bd-7895-49b1-8a95-276470151c65:1",
"server_keep_alive_timeout_ms": 10000,
"idle_socket_ttl": 15000
},
"module": "HTTP Adapter"
}- Setting
log.leveldefault value toClickHouseLogLevel.WARNinstead ofClickHouseLogLevel.OFFto provide better visibility into potential issues without overwhelming users with too much information by default.
const client = createClient({
// ...
log: {
level: ClickHouseLogLevel.WARN, // default is now ClickHouseLogLevel.WARN instead of ClickHouseLogLevel.OFF
},
});- Logging is now lazy, which means that the log messages will only be constructed if the log level is appropriate for the message. This can improve performance in cases where constructing the log message is expensive, and the log level is set to ignore such messages. See
ClickHouseLogLevelenum for the complete list of log levels. (#520)
const client = createClient({
// ...
log: {
level: ClickHouseLogLevel.TRACE, // to log everything available down to the network level events
},
});- Enhanced the logging of the HTTP request / socket lifecycle with additional trace messages and context such as Connection ID (UUID) and Request ID and Socket ID that embed the connection ID for ease of tracing the logs of a particular request across the connection lifecycle. To enable such logs, set the
log.levelconfig option toClickHouseLogLevel.TRACE. (#567)
[2026-02-25T09:19:13.511Z][TRACE][@clickhouse/client][Connection] Insert: received 'close' event, 'free' listener removed
Arguments: {
operation: 'Insert',
connection_id: 'da3c9796-5dc5-46ef-83b0-ed1f4422094c',
query_id: '9dfda627-39a2-41a6-9fc9-8f8716574826',
request_id: 'da3c9796-5dc5-46ef-83b0-ed1f4422094c:3',
socket_id: 'da3c9796-5dc5-46ef-83b0-ed1f4422094c:2',
event: 'close'
}
[2026-02-25T09:19:13.502Z][TRACE][@clickhouse/client][Connection] Query: reusing socket
Arguments: {
operation: 'Query',
connection_id: 'da3c9796-5dc5-46ef-83b0-ed1f4422094c',
query_id: 'ad0127e8-b1c7-4ed6-9681-c0162f7a0ea9',
request_id: 'da3c9796-5dc5-46ef-83b0-ed1f4422094c:4',
socket_id: 'da3c9796-5dc5-46ef-83b0-ed1f4422094c:2',
usage_count: 1
}- A step towards structured logging: the client now passes rich context to the logger
argsparameter (e.g.connection_id,query_id,request_id,socket_id). (#576)
-
The
drainStreamutility function is now deprecated, as the client will handle draining the stream internally when needed. Useclient.command()instead, which will handle draining the stream internally when needed. (#578) -
The
sleeputility function is now deprecated, as it is not intended to be used outside of the client implementation. UsesetTimeoutdirectly or a more full-featured utility library if you need additional features like cancellation or timers management. (#578)
A beta version. See 1.18.1 for the stable release.
- Added
http_status_codeto query, insert, and exec commands (#525, Kinzeng) - Fixed
ignore_error_responsenot getting passed when usingcommand(#536, Kinzeng)
- Added support for the new Disposable API (a.k.a the
usingkeyword) (#500)
async function main() {
using resultSet = await client.query(…);
// some code that can throw
// but thanks to `using` the resultSet will still get disposed
// resultSet is also automatically disposed here by calling [Symbol.dispose]
}Without the new using keyword it is required to wrap the code that might leak expensive resources like sockets and big buffers in try / finally
async function main() {
let client
try {
client = await createClient(…);
// some code that can throw
} finally {
if (client) {
await client.close()
}
}
}- It is now possible to specify custom
parseandstringifyfunctions that will be used instead of the standardJSON.parseandJSON.stringifymethods for JSON serialization/deserialization when working withJSON*family formats. SeeClickHouseClientConfigOptions.json, and a new custom_json_handling example for more details. (#481, looskie) - (Node.js only) Added an
ignore_error_responseparam toClickHouseClient.exec, which allows callers to manually handle request errors on the application side. (#483, Kinzeng)
- Server-side exceptions that occur in the middle of the HTTP stream are now handled correctly. This requires ClickHouse 25.11+. Previous ClickHouse versions are unaffected by this change. (#478)
- Fixed boolean value formatting in query parameters. Boolean values within
Array,Tuple, andMaptypes are now correctly formatted asTRUE/FALSEinstead of1/0to ensure proper type compatibility with ClickHouse. (#475, baseballyama)
- Added Node.js 24.x to the CI matrix. Node.js 18.x was removed from the CI due to EOL.
- Add missing
allow_experimental_join_conditiontoClickHouseSettingstyping. (#430, looskie) - Fixed
JSONEachRowWithProgressTypeScript flow after the breaking changes in ClickHouse 25.1.RowOrProgress<T>now has an additional variant:SpecialEventRow<T>. The library now additionally exports theparseErrormethod, and newly addedisRow/isExceptiontype guards. See the updated JSONEachRowWithProgress example (#443) - Added missing
allow_experimental_variant_type(24.1+),allow_experimental_dynamic_type(24.5+),allow_experimental_json_type(24.8+),enable_json_type(25.3+),enable_time_time64_type(25.6+) toClickHouseSettingstyping. (#445)
- Add a warning on a socket closed without fully consuming the stream (e.g., when using
queryorexecmethod). (#441) - (Node.js only) An option to use a simple SELECT query for ping checks instead of
/pingendpoint. See the new optional argument to theClickHouseClient.pingmethod andPingParamstypings. Note that the Web version always used a SELECT query by default, as the/pingendpoint does not support CORS, and that cannot be changed. (#442)
A minor release to allow further investigation regarding uncaught error issues with #410.
- Added missing
lightweight_deletes_synctyping toClickHouseSettings(#422, pratimapatel2008)
- Added a new configuration option:
capture_enhanced_stack_trace; see the JS doc in the Node.js client package. Note that it is disabled by default due to a possible performance impact. (#427) - Added more try-catch blocks to the Node.js connection layer. (#427)
- Fixed an issue with URLEncoded special characters in the URL configuration for username or password. (#407)
- Added support for streaming on 32-bit platforms. (#403, shevchenkonik)
- It is now possible to provide custom HTTP headers when calling the
query/insert/command/execmethods using thehttp_headersoption. NB:http_headersspecified this way will overridehttp_headersset on the client instance level. (#394, @DylanRJohnston) - (Web only) It is now possible to provide a custom
fetchimplementation to the client. (#315, @lucacasonato)
- Fixed
NULLparameter binding withTuple,Array, andMaptypes. (#374)
ClickHouseSettingstypings now includesession_timeoutandsession_checksettings. (#370)
-
Added support for JWT authentication (ClickHouse Cloud feature) in both Node.js and Web API packages. JWT token can be set via
access_tokenclient configuration option.const client = createClient({ // ... access_token: "<JWT access token>", });
Access token can also be configured via the URL params, e.g.,
https://host:port?access_token=....It is also possible to override the access token for a particular request (see
BaseQueryParams.authfor more details).NB: do not mix access token and username/password credentials in the configuration; the client will throw an error if both are set.
- Fixed an uncaught exception that could happen in case of malformed ClickHouse response when response compression is enabled (#363)
- Added
input_format_json_throw_on_bad_escape_sequenceto theClickhouseSettingstype. (#355, @emmanuel-bonin) - The client now exports
TupleParamwrapper class, allowing tuples to be properly used as query parameters. Added support for JS Map as a query parameter. (#359)
- The client will throw a more informative error if the buffered response is larger than the max allowed string length in V8, which is
2**29 - 24bytes. (#357)
- When a custom HTTP agent is used, the HTTP or HTTPS request implementation is now correctly chosen based on the URL protocol. (#352)
- Added support for specifying roles via request query parameters. See this example for more details. (@pulpdrew, #328)
- (Web only) Fixed an issue where streaming large datasets could provide corrupted results. See #333 (PR) for more details.
-
Added
JSONEachRowWithProgressformat support,ProgressRowinterface, andisProgressRowtype guard. See this Node.js example for more details. It should work similarly with the Web version. -
(Experimental) Exposed the
parseColumnTypefunction that takes a string representation of a ClickHouse type (e.g.,FixedString(16),Nullable(Int32), etc.) and returns an AST-like object that represents the type. For example:for (const type of [ "Int32", "Array(Nullable(String))", `Map(Int32, DateTime64(9, 'UTC'))`, ]) { console.log(`##### Source ClickHouse type: ${type}`); console.log(parseColumnType(type)); }
The above code will output:
##### Source ClickHouse type: Int32 { type: 'Simple', columnType: 'Int32', sourceType: 'Int32' } ##### Source ClickHouse type: Array(Nullable(String)) { type: 'Array', value: { type: 'Nullable', sourceType: 'Nullable(String)', value: { type: 'Simple', columnType: 'String', sourceType: 'String' } }, dimensions: 1, sourceType: 'Array(Nullable(String))' } ##### Source ClickHouse type: Map(Int32, DateTime64(9, 'UTC')) { type: 'Map', key: { type: 'Simple', columnType: 'Int32', sourceType: 'Int32' }, value: { type: 'DateTime64', timezone: 'UTC', precision: 9, sourceType: "DateTime64(9, 'UTC')" }, sourceType: "Map(Int32, DateTime64(9, 'UTC'))" }While the original intention was to use this function internally for
Native/RowBinaryWithNamesAndTypesdata formats headers parsing, it can be useful for other purposes as well (e.g., interfaces generation, or custom JSON serializers).NB: currently unsupported source types to parse:
- Geo
- (Simple)AggregateFunction
- Nested
- Old/new experimental JSON
- Dynamic
- Variant
- Added optional
real_time_microsecondsfield to theClickHouseSummaryinterface (see ClickHouse/ClickHouse#69032)
- Fixed unhandled exceptions produced when calling
ResultSet.jsonif the response data was not in fact a valid JSON. (#311)
- It is now possible to disable the automatic decompression of the response stream with the
execmethod. SeeExecParams.decompress_response_streamfor more details. (#298).
ClickHouseClientis now exported as a value from@clickhouse/clientand@clickhouse/client-webpackages, allowing for better integration in dependency injection frameworks that rely on IoC (e.g., Nest.js, tsyringe) (@mathieu-bour, #292).
- Fixed a potential socket hang up issue that could happen under 100% CPU load (#294).
- (Node.js only) The
execmethod now accepts an optionalvaluesparameter, which allows you to pass the request body as aStream.Readable. This can be useful in case of custom insert streaming with arbitrary ClickHouse data formats (which might not be explicitly supported and allowed by the client in theinsertmethod yet). NB: in this case, you are expected to serialize the data in the stream in the required input format yourself.
-
It is now possible to get the entire response headers object from the
query/insert/command/execmethods. Withquery, you can access theResultSet.response_headersproperty; other methods (insert/command/exec) return it as parts of their response objects as well. For example:const rs = await client.query({ query: "SELECT * FROM system.numbers LIMIT 1", format: "JSONEachRow", }); console.log(rs.response_headers["content-type"]);
This will print:
application/x-ndjson; charset=UTF-8. It can be used in a similar way with the other methods.
- Re-exported several constants from the
@clickhouse/client-commonpackage for convenience:SupportedJSONFormatsSupportedRawFormatsStreamableFormatsStreamableJSONFormatsSingleDocumentJSONFormatsRecordsJSONFormats
-
(Experimental) Added an option to provide a custom HTTP Agent in the client configuration via the
http_agentoption (#283, related: #278). The following conditions apply if a custom HTTP Agent is provided:- The
max_open_connectionsandtlsoptions will have no effect and will be ignored by the client, as it is a part of the underlying HTTP Agent configuration. keep_alive.enabledwill only regulate the default value of theConnectionheader (true->Connection: keep-alive,false->Connection: close).- While the idle socket management will still work, it is now possible to disable it completely by setting the
keep_alive.idle_socket_ttlvalue to0.
- The
-
(Experimental) Added a new client configuration option:
set_basic_auth_header, which disables theAuthorizationheader that is set by the client by default for every outgoing HTTP request. One of the possible scenarios when it is necessary to disable this header is when a custom HTTPS agent is used, and the server requires TLS authorization. For example:const agent = new https.Agent({ ca: fs.readFileSync("./ca.crt"), }); const client = createClient({ url: "https://server.clickhouseconnect.test:8443", http_agent: agent, // With a custom HTTPS agent, the client won't use the default HTTPS connection implementation; the headers should be provided manually http_headers: { "X-ClickHouse-User": "default", "X-ClickHouse-Key": "", }, // Authorization header conflicts with the TLS headers; disable it. set_basic_auth_header: false, });
NB: It is currently not possible to set the set_basic_auth_header option via the URL params.
If you have feedback on these experimental features, please let us know by creating an issue in the repository.
- Added an option to override the credentials for a particular
query/command/exec/insertrequest via theBaseQueryParams.authsetting; when set, the credentials will be taken from there instead of the username/password provided during the client instantiation (#278). - Added an option to override the
session_idfor a particularquery/command/exec/insertrequest via theBaseQueryParams.session_idsetting; when set, it will be used instead of the session id provided during the client instantiation (@holi0317, #271).
- Fixed the incorrect
ResponseJSON<T>.totalsTypeScript type. Now it correctly matches the shape of the data (T, default =unknown) instead of the formerRecord<string, number>definition (#274).
- The
commandmethod now drains the response stream properly, as the previous implementation could cause theKeep-Alivesocket to close after each request. - Removed an unnecessary error log in the
ResultSet.streammethod if the request was aborted or the result set was closed (#263).
ResultSet.streamlogs an error via theLoggerinstance, if the stream emits an error event instead of a simpleconsole.errorcall.- Minor adjustments to the
DefaultLoggerlog messages formatting. - Added missing
rows_before_limit_at_leastto the ResponseJSON type (@0237h, #267).
- Fixed the regression where the default HTTP/HTTPS port numbers (80/443) could not be used with the URL configuration (#258).
Formal stable release milestone with a lot of improvements and some breaking changes.
Major new features overview:
From now on, the client will follow the official semantic versioning guidelines.
The following configuration parameters are marked as deprecated:
hostconfiguration parameter is deprecated; useurlinstead.additional_headersconfiguration parameter is deprecated; usehttp_headersinstead.
The client will log a warning if any of these parameters are used. However, it is still allowed to use host instead of url and additional_headers instead of http_headers for now; this deprecation is not supposed to break the existing code.
These parameters will be removed in the next major release (2.0.0).
See "New features" section for more details.
compression.responseis now disabled by default in the client configuration options, as it cannot be used with readonly=1 users, and it was not clear from the ClickHouse error message what exact client option was causing the failing query in this case. If you'd like to continue using response compression, you should explicitly enable it in the client configuration.- As the client now supports parsing URL configuration, you should specify
pathnameas a separate configuration option (as it would be considered as thedatabaseotherwise). - (TypeScript only)
ResultSetandRoware now more strictly typed, according to the format used during thequerycall. See this section for more details. - (TypeScript only) Both Node.js and Web versions now uniformly export correct
ClickHouseClientandClickHouseClientConfigOptionstypes, specific to each implementation. ExportedClickHouseClientnow does not have aStreamtype parameter, as it was unintended to expose it there. NB: you should still usecreateClientfactory function provided in the package.
Client will now try its best to figure out the shape of the data based on the DataFormat literal specified to the query call, as well as which methods are allowed to be called on the ResultSet.
Live demo (see the full description below):
Screencast.from.2024-03-09.08-10-26.webm
Complete reference:
| Format | ResultSet.json<T>() |
ResultSet.stream<T>() |
Stream data | Row.json<T>() |
|---|---|---|---|---|
| JSON | ResponseJSON<T> | never | never | never |
| JSONObjectEachRow | Record<string, T> | never | never | never |
All other JSON*EachRow |
Array<T> | Stream<Array<Row<T>>> | Array<Row<T>> | T |
| CSV/TSV/CustomSeparated/Parquet | never | Stream<Array<Row<T>>> | Array<Row<T>> | never |
By default, T (which represents JSONType) is still unknown. However, considering JSONObjectsEachRow example: prior to 1.0.0, you had to specify the entire type hint, including the shape of the data, manually:
type Data = { foo: string };
const resultSet = await client.query({
query: "SELECT * FROM my_table",
format: "JSONObjectsEachRow",
});
// pre-1.0.0, `resultOld` has type Record<string, Data>
const resultOld = resultSet.json<Record<string, Data>>();
// const resultOld = resultSet.json<Data>() // incorrect! The type hint should've been `Record<string, Data>` here.
// 1.0.0, `resultNew` also has type Record<string, Data>; client inferred that it has to be a Record from the format literal.
const resultNew = resultSet.json<Data>();This is even more handy in case of streaming on the Node.js platform:
const resultSet = await client.query({
query: "SELECT * FROM my_table",
format: "JSONEachRow",
});
// pre-1.0.0
// `streamOld` was just a regular Node.js Stream.Readable
const streamOld = resultSet.stream();
// `rows` were `any`, needed an explicit type hint
streamNew.on("data", (rows: Row[]) => {
rows.forEach((row) => {
// without an explicit type hint to `rows`, calling `forEach` and other array methods resulted in TS compiler errors
const t = row.text;
const j = row.json<Data>(); // `j` needed a type hint here, otherwise, it's `unknown`
});
});
// 1.0.0
// `streamNew` is now StreamReadable<T> (Node.js Stream.Readable with a bit more type hints);
// type hint for the further `json` calls can be added here (and removed from the `json` calls)
const streamNew = resultSet.stream<Data>();
// `rows` are inferred as an Array<Row<Data, "JSONEachRow">> instead of `any`
streamNew.on("data", (rows) => {
// `row` is inferred as Row<Data, "JSONEachRow">
rows.forEach((row) => {
// no explicit type hints required, you can use `forEach` straight away and TS compiler will be happy
const t = row.text;
const j = row.json(); // `j` will be of type Data
});
});
// async iterator now also has type hints
// similarly to the `on(data)` example above, `rows` are inferred as Array<Row<Data, "JSONEachRow">>
for await (const rows of streamNew) {
// `row` is inferred as Row<Data, "JSONEachRow">
rows.forEach((row) => {
const t = row.text;
const j = row.json(); // `j` will be of type Data
});
}Calling ResultSet.stream is not allowed for certain data formats, such as JSON and JSONObjectsEachRow (unlike JSONEachRow and the rest of JSON*EachRow, these formats return a single object). In these cases, the client throws an error. However, it was previously not reflected on the type level; now, calling stream on these formats will result in a TS compiler error. For example:
const resultSet = await client.query("SELECT * FROM table", {
format: "JSON",
});
const stream = resultSet.stream(); // `stream` is `never`Calling ResultSet.json also does not make sense on CSV and similar "raw" formats, and the client throws. Again, now, it is typed properly:
const resultSet = await client.query("SELECT * FROM table", {
format: "CSV",
});
// `json` is `never`; same if you stream CSV, and call `Row.json` - it will be `never`, too.
const json = resultSet.json();Currently, there is one known limitation: as the general shape of the data and the methods allowed for calling are inferred from the format literal, there might be situations where it will fail to do so, for example:
// assuming that `queryParams` has `JSONObjectsEachRow` format inside
async function runQuery(
queryParams: QueryParams,
): Promise<Record<string, Data>> {
const resultSet = await client.query(queryParams);
// type hint here will provide a union of all known shapes instead of a specific one
// inferred shapes: Data[] | ResponseJSON<Data> | Record<string, Data>
return resultSet.json<Data>();
}In this case, as it is likely that you already know the desired format in advance (otherwise, returning a specific shape like Record<string, Data> would've been incorrect), consider helping the client a bit:
async function runQuery(
queryParams: QueryParams,
): Promise<Record<string, Data>> {
const resultSet = await client.query({
...queryParams,
format: "JSONObjectsEachRow",
});
// TS understands that it is a Record<string, Data> now
return resultSet.json<Data>();
}If you are interested in more details, see the related test (featuring a great ESLint plugin expect-types) in the client package.
- Added
urlconfiguration parameter. It is intended to replace the deprecatedhost, which was already supposed to be passed as a valid URL. - It is now possible to configure most of the client instance parameters with a URL. The URL format is
http[s]://[username:password@]hostname:port[/database][?param1=value1¶m2=value2]. In almost every case, the name of a particular parameter reflects its path in the config options interface, with a few exceptions. The following parameters are supported:
| Parameter | Type |
|---|---|
pathname |
an arbitrary string. |
application_id |
an arbitrary string. |
session_id |
an arbitrary string. |
request_timeout |
non-negative number. |
max_open_connections |
non-negative number, greater than zero. |
compression_request |
boolean. See below [1]. |
compression_response |
boolean. |
log_level |
allowed values: OFF, TRACE, DEBUG, INFO, WARN, ERROR. |
keep_alive_enabled |
boolean. |
clickhouse_setting_* or ch_* |
see below [2]. |
http_header_* |
see below [3]. |
(Node.js only) keep_alive_idle_socket_ttl |
non-negative number. |
[1] For booleans, valid values will be true/1 and false/0.
[2] Any parameter prefixed with clickhouse_setting_ or ch_ will have this prefix removed and the rest added to client's clickhouse_settings. For example, ?ch_async_insert=1&ch_wait_for_async_insert=1 will be the same as:
createClient({
clickhouse_settings: {
async_insert: 1,
wait_for_async_insert: 1,
},
});Note: boolean values for clickhouse_settings should be passed as 1/0 in the URL.
[3] Similar to [2], but for http_header configuration. For example, ?http_header_x-clickhouse-auth=foobar will be an equivalent of:
createClient({
http_headers: {
"x-clickhouse-auth": "foobar",
},
});Important: URL will always overwrite the hardcoded values and a warning will be logged in this case.
Currently not supported via URL:
log.LoggerClass- (Node.js only)
tls_ca_cert,tls_cert,tls_key.
See also: URL configuration example.
- (Node.js only) Improved performance when decoding the entire set of rows with streamable JSON formats (such as
JSONEachRoworJSONCompactEachRow) by calling theResultSet.json()method. NB: The actual streaming performance when consuming theResultSet.stream()hasn't changed. Only theResultSet.json()method used a suboptimal stream processing in some instances, and nowResultSet.json()just consumes the same stream transformer provided by theResultSet.stream()method (see #253 for more details).
- Added
http_headersconfiguration parameter as a direct replacement foradditional_headers. Functionally, it is the same, and the change is purely cosmetic, as we'd like to leave an option to implement TCP connection in the future open.
- Fixed an issue where query parameters containing tabs or newline characters were not encoded properly.
This release primarily focuses on improving the Keep-Alive mechanism's reliability on the client side.
- Idle sockets timeout rework; now, the client attaches internal timers to idling sockets, and forcefully removes them from the pool if it considers that a particular socket is idling for too long. The intention of this additional sockets housekeeping is to eliminate "Socket hang-up" errors that could previously still occur on certain configurations. Now, the client does not rely on KeepAlive agent when it comes to removing the idling sockets; in most cases, the server will not close the socket before the client does.
- There is a new
keep_alive.idle_socket_ttlconfiguration parameter. The default value is2500(milliseconds), which is considered to be safe, as ClickHouse versions prior to 23.11 hadkeep_alive_timeoutset to 3 seconds by default, andkeep_alive.idle_socket_ttlis supposed to be slightly less than that to allow the client to remove the sockets that are about to expire before the server does so. - Logging improvements: more internal logs on failing requests; all client methods except ping will log an error on failure now. A failed ping will log a warning, since the underlying error is returned as a part of its result. Client logging still needs to be enabled explicitly by specifying the desired
log.levelconfig option, as the log level isOFFby default. Currently, the client logs the following events, depending on the selectedlog.levelvalue:TRACE- low-level information about the Keep-Alive sockets lifecycle.DEBUG- response information (without authorization headers and host info).INFO- still mostly unused, will print the current log level when the client is initialized.WARN- non-fatal errors; failedpingrequest is logged as a warning, as the underlying error is included in the returned result.ERROR- fatal errors fromquery/insert/exec/commandmethods, such as a failed request.
keep_alive.retry_on_expired_socketandkeep_alive.socket_ttlconfiguration parameters are removed.- The
max_open_connectionsconfiguration parameter is now 10 by default, as we should not rely on the KeepAlive agent's defaults. - Fixed the default
request_timeoutconfiguration value (now it is correctly set to30_000, previously300_000(milliseconds)).
- Fixed a bug with Ping that could lead to an unhandled "Socket hang-up" propagation.
- Ensure proper
Connectionheader value considering Keep-Alive settings. If Keep-Alive is disabled, its value is now forced to "close".
See 0.3.0.
- If
InsertParams.valuesis an empty array, no request is sent to the server andClickHouseClient.insertshort-circuits itself. In this scenario, the newly addedInsertResult.executedflag will befalse, andInsertResult.query_idwill be an empty string.
- Client no longer produces
Code: 354. inflate failed: buffer errorexception if request compression is enabled andInsertParams.valuesis an empty array (see above).
- It is now possible to set additional HTTP headers for outgoing ClickHouse requests. This might be useful if, for example, you use a reverse proxy with authorization. (@teawithfruit, #224)
const client = createClient({
additional_headers: {
"X-ClickHouse-User": "clickhouse_user",
"X-ClickHouse-Key": "clickhouse_password",
},
});- (Web only) Allow to modify Keep-Alive setting (previously always disabled). Keep-Alive setting is now enabled by default for the Web version.
import { createClient } from "@clickhouse/client-web";
const client = createClient({ keep_alive: { enabled: true } });- (Node.js & Web) It is now possible to either specify a list of columns to insert the data into or a list of excluded columns:
// Generated query: INSERT INTO mytable (message) FORMAT JSONEachRow
await client.insert({
table: "mytable",
format: "JSONEachRow",
values: [{ message: "foo" }],
columns: ["message"],
});
// Generated query: INSERT INTO mytable (* EXCEPT (message)) FORMAT JSONEachRow
await client.insert({
table: "mytable",
format: "JSONEachRow",
values: [{ id: 42 }],
columns: { except: ["message"] },
});See also the new examples:
- Including specific columns or excluding certain ones instead
- Leveraging this feature when working with ephemeral columns (#217)
- (Node.js only)
X-ClickHouse-Summaryresponse header is now parsed when working withinsert/exec/commandmethods. See the related test for more details. NB: it is guaranteed to be correct only for non-streaming scenarios. Web version does not currently support this due to CORS limitations. (#210)
- Drain insert response stream in Web version - required to properly work with
async_insert, especially in the Cloudflare Workers context.
- Added Parquet format streaming support. See the new examples: insert from a file, select into a file.
pathnamesegment fromhostclient configuration parameter is now handled properly when making requests. See this comment for more details.
No changes in web/common modules.
- (Node.js only) Fixed an issue where streaming large datasets could provide corrupted results. See #171 (issue) and #204 (PR) for more details.
No changes in web/common modules.
- (Node.js only) Fixed an issue where the underlying socket was closed every time after using
insertwith akeep_aliveoption enabled, which led to performance limitations. See #202 for more details. (@varrocs)
- Added
default_formatsetting, which allows to performexeccalls withoutFORMATclause.
Date objects in query parameters are now serialized as time-zone-agnostic Unix timestamps (NNNNNNNNNN[.NNN], optionally with millisecond-precision) instead of datetime strings without time zones (YYYY-MM-DD HH:MM:SS[.MMM]). This means the server will receive the same absolute timestamp the client sent even if the client's time zone and the database server's time zone differ. Previously, if the server used one time zone and the client used another, Date objects would be encoded in the client's time zone and decoded in the server's time zone and create a mismatch.
For instance, if the server used UTC (GMT) and the client used PST (GMT-8), a Date object for "2023-01-01 13:00:00 PST" would be encoded as "2023-01-01 13:00:00.000" and decoded as "2023-01-01 13:00:00 UTC" (which is 2023-01-01 05:00:00 PST). Now, "2023-01-01 13:00:00 PST" is encoded as "1672606800000" and decoded as "2023-01-01 21:00:00 UTC", the same time the client sent.
Introduces web client (using native fetch and WebStream APIs) without Node.js modules in the common interfaces. No polyfills are required.
Web client is confirmed to work with Chrome/Firefox/CloudFlare workers.
It is now possible to implement new custom connections on top of @clickhouse/client-common.
The client was refactored into three packages:
@clickhouse/client-common: all possible platform-independent code, types and interfaces@clickhouse/client-web: new web (or non-Node.js env) connection, uses native fetch.@clickhouse/client: Node.js connection as it was before.
- Changed
pingmethod behavior: it will not throw now. Instead, either{ success: true }or{ success: false, error: Error }is returned. - Log level configuration parameter is now explicit instead of
CLICKHOUSE_LOG_LEVELenvironment variable. Default isOFF. queryreturn type signature changed to isBaseResultSet<Stream.Readable>(no functional changes)execreturn type signature changed toExecResult<Stream.Readable>(no functional changes)insert<T>params argument type changed toInsertParams<Stream, T>(no functional changes)- Experimental
schemamodule is removed
- Streaming for select queries works, but it is disabled for inserts (on the type level as well).
- KeepAlive is disabled and not configurable yet.
- Request compression is disabled and configuration is ignored. Response compression works.
- No logging support yet.
- Expired socket detection on the client side when using Keep-Alive. If a potentially expired socket is detected,
and retry is enabled in the configuration, both socket and request will be immediately destroyed (before sending the data),
and the client will recreate the request. See
ClickHouseClientConfigOptions.keep_alivefor more details. Disabled by default. - Allow disabling Keep-Alive feature entirely.
TRACElog level.
const client = createClient({
keep_alive: {
enabled: false,
},
});const client = createClient({
keep_alive: {
enabled: true,
// should be slightly less than the `keep_alive_timeout` setting in server's `config.xml`
// default is 3s there, so 2500 milliseconds seems to be a safe client value in this scenario
// another example: if your configuration has `keep_alive_timeout` set to 60s, you could put 59_000 here
socket_ttl: 2500,
retry_on_expired_socket: true,
},
});connect_timeoutclient setting is removed, as it was unused in the code.
commandmethod is introduced as an alternative toexec.commanddoes not expect user to consume the response stream, and it is destroyed immediately. Essentially, this is a shortcut toexecthat destroys the stream under the hood. Consider usingcommandinstead ofexecfor DDLs and other custom commands which do not provide any valuable output.
Example:
// incorrect: stream is not consumed and not destroyed, request will be timed out eventually
await client.exec("CREATE TABLE foo (id String) ENGINE Memory");
// correct: stream does not contain any information and just destroyed
const { stream } = await client.exec(
"CREATE TABLE foo (id String) ENGINE Memory",
);
stream.destroy();
// correct: same as exec + stream.destroy()
await client.command("CREATE TABLE foo (id String) ENGINE Memory");- Fixed delays on subsequent requests after calling
insertthat happened due to unclosed stream instance when using low number ofmax_open_connections. See #161 for more details. - Request timeouts internal logic rework (see #168)
- Fix NULL parameter binding.
As HTTP interface expects
\Ninstead of'NULL'string, it is now correctly handled for bothnulland explicitlyundefinedparameters. See the test scenarios for more details.
- Fix Node.JS 19.x/20.x timeout error (@olexiyb)
- Added support for
JSONStrings,JSONCompact,JSONCompactStrings,JSONColumnsWithMetadataformats (@andrewzolotukhin).
query_idcan be now overridden for all main client's methods:query,exec,insert.
ResultSet.query_idcontains a unique query identifier that might be useful for retrieving query metrics fromsystem.query_logUser-AgentHTTP header is set according to the language client spec. For example, for client version 0.0.12 and Node.js runtime v19.0.4 on Linux platform, it will beclickhouse-js/0.0.12 (lv:nodejs/19.0.4; os:linux). IfClickHouseClientConfigOptions.applicationis set, it will be prepended to the generatedUser-Agent.
client.insertnow returns{ query_id: string }instead ofvoidclient.execnow returns{ stream: Stream.Readable, query_id: string }instead of justStream.Readable
log.enabledflag was removed from the client configuration.- Use
CLICKHOUSE_LOG_LEVELenvironment variable instead. Possible values:OFF,TRACE,DEBUG,INFO,WARN,ERROR. Currently, there are only debug messages, but we will log more in the future.
For more details, see PR #110
- Remove request listeners synchronously. #123
- Added ClickHouse session_id support. #121
- Added SSL/TLS support (basic and mutual). #52
- Allow semicolons in select clause. #116
- Add JSONObjectEachRow input/output and JSON input formats. #113
- Rows abstraction was renamed to ResultSet.
- now, every iteration over
ResultSet.stream()yieldsRow[]instead of a singleRow. Please check out an example and this PR for more details. These changes allowed us to significantly reduce overhead on select result set streaming.
- split2 is no longer a package dependency.