-
Added support for JWT authentication (ClickHouse Cloud feature) in both Node.js and Web API packages. JWT token can be set via
access_token
client 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.auth
for 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_sequence
to theClickhouseSettings
type. (#355, @emmanuel-bonin) - The client now exports
TupleParam
wrapper 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 - 24
bytes. (#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
JSONEachRowWithProgress
format support,ProgressRow
interface, andisProgressRow
type guard. See this Node.js example for more details. It should work similarly with the Web version. -
(Experimental) Exposed the
parseColumnType
function 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
/RowBinaryWithNamesAndTypes
data 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_microseconds
field to theClickHouseSummary
interface (see ClickHouse/ClickHouse#69032)
- Fixed unhandled exceptions produced when calling
ResultSet.json
if 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
exec
method. SeeExecParams.decompress_response_stream
for more details. (#298).
ClickHouseClient
is now exported as a value from@clickhouse/client
and@clickhouse/client-web
packages, 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
exec
method now accepts an optionalvalues
parameter, 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 theinsert
method 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
/exec
methods. Withquery
, you can access theResultSet.response_headers
property; 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-common
package for convenience:SupportedJSONFormats
SupportedRawFormats
StreamableFormats
StreamableJSONFormats
SingleDocumentJSONFormats
RecordsJSONFormats
-
(Experimental) Added an option to provide a custom HTTP Agent in the client configuration via the
http_agent
option (#283, related: #278). The following conditions apply if a custom HTTP Agent is provided:- The
max_open_connections
andtls
options will have no effect and will be ignored by the client, as it is a part of the underlying HTTP Agent configuration. keep_alive.enabled
will only regulate the default value of theConnection
header (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_ttl
value to0
.
- The
-
(Experimental) Added a new client configuration option:
set_basic_auth_header
, which disables theAuthorization
header 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
/insert
request via theBaseQueryParams.auth
setting; 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_id
for a particularquery
/command
/exec
/insert
request via theBaseQueryParams.session_id
setting; when set, it will be used instead of the session id provided during the client instantiation (@holi0317, #271).
- Fixed the incorrect
ResponseJSON<T>.totals
TypeScript type. Now it correctly matches the shape of the data (T
, default =unknown
) instead of the formerRecord<string, number>
definition (#274).
- The
command
method now drains the response stream properly, as the previous implementation could cause theKeep-Alive
socket to close after each request. - Removed an unnecessary error log in the
ResultSet.stream
method if the request was aborted or the result set was closed (#263).
ResultSet.stream
logs an error via theLogger
instance, if the stream emits an error event instead of a simpleconsole.error
call.- Minor adjustments to the
DefaultLogger
log messages formatting. - Added missing
rows_before_limit_at_least
to 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:
host
configuration parameter is deprecated; useurl
instead.additional_headers
configuration parameter is deprecated; usehttp_headers
instead.
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.response
is 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
pathname
as a separate configuration option (as it would be considered as thedatabase
otherwise). - (TypeScript only)
ResultSet
andRow
are now more strictly typed, according to the format used during thequery
call. See this section for more details. - (TypeScript only) Both Node.js and Web versions now uniformly export correct
ClickHouseClient
andClickHouseClientConfigOptions
types, specific to each implementation. ExportedClickHouseClient
now does not have aStream
type parameter, as it was unintended to expose it there. NB: you should still usecreateClient
factory 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
url
configuration 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
JSONEachRow
orJSONCompactEachRow
) 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_headers
configuration 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_ttl
configuration parameter. The default value is2500
(milliseconds), which is considered to be safe, as ClickHouse versions prior to 23.11 hadkeep_alive_timeout
set to 3 seconds by default, andkeep_alive.idle_socket_ttl
is 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.level
config option, as the log level isOFF
by default. Currently, the client logs the following events, depending on the selectedlog.level
value: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; failedping
request is logged as a warning, as the underlying error is included in the returned result.ERROR
- fatal errors fromquery
/insert
/exec
/command
methods, such as a failed request.
keep_alive.retry_on_expired_socket
andkeep_alive.socket_ttl
configuration parameters are removed.- The
max_open_connections
configuration parameter is now 10 by default, as we should not rely on the KeepAlive agent's defaults. - Fixed the default
request_timeout
configuration 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
Connection
header value considering Keep-Alive settings. If Keep-Alive is disabled, its value is now forced to "close".
See 0.3.0.
- If
InsertParams.values
is an empty array, no request is sent to the server andClickHouseClient.insert
short-circuits itself. In this scenario, the newly addedInsertResult.executed
flag will befalse
, andInsertResult.query_id
will be an empty string.
- Client no longer produces
Code: 354. inflate failed: buffer error
exception if request compression is enabled andInsertParams.values
is 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-Summary
response header is now parsed when working withinsert
/exec
/command
methods. 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.
pathname
segment fromhost
client 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
insert
with akeep_alive
option enabled, which led to performance limitations. See #202 for more details. (@varrocs)
- Added
default_format
setting, which allows to performexec
calls withoutFORMAT
clause.
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
ping
method 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_LEVEL
environment variable. Default isOFF
. query
return type signature changed to isBaseResultSet<Stream.Readable>
(no functional changes)exec
return type signature changed toExecResult<Stream.Readable>
(no functional changes)insert<T>
params argument type changed toInsertParams<Stream, T>
(no functional changes)- Experimental
schema
module 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_alive
for more details. Disabled by default. - Allow disabling Keep-Alive feature entirely.
TRACE
log 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_timeout
client setting is removed, as it was unused in the code.
command
method is introduced as an alternative toexec
.command
does not expect user to consume the response stream, and it is destroyed immediately. Essentially, this is a shortcut toexec
that destroys the stream under the hood. Consider usingcommand
instead ofexec
for 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
insert
that 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
\N
instead of'NULL'
string, it is now correctly handled for bothnull
and explicitlyundefined
parameters. See the test scenarios for more details.
- Fix Node.JS 19.x/20.x timeout error (@olexiyb)
- Added support for
JSONStrings
,JSONCompact
,JSONCompactStrings
,JSONColumnsWithMetadata
formats (@andrewzolotukhin).
query_id
can be now overridden for all main client's methods:query
,exec
,insert
.
ResultSet.query_id
contains a unique query identifier that might be useful for retrieving query metrics fromsystem.query_log
User-Agent
HTTP 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.application
is set, it will be prepended to the generatedUser-Agent
.
client.insert
now returns{ query_id: string }
instead ofvoid
client.exec
now returns{ stream: Stream.Readable, query_id: string }
instead of justStream.Readable
log.enabled
flag was removed from the client configuration.- Use
CLICKHOUSE_LOG_LEVEL
environment 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.