Clickhouse

1/**
2 * The one shared test helper: run SQL against a live ClickHouse server over
3 * HTTP and return the raw response bytes.
4 *
5 * Unit tests query ClickHouse directly (no static fixtures) so the bytes under
6 * test are always exactly what the server produces. Pass a complete statement
7 * including the format, e.g. `SELECT toUInt8(255) FORMAT RowBinary`.
8 *
9 * Assumes a ClickHouse server is already running. Override the connection with
10 * env vars:
11 *   CLICKHOUSE_URL       (default http://localhost:8123)
12 *   CLICKHOUSE_USER      (default default)
13 *   CLICKHOUSE_PASSWORD  (default empty)
14 *
15 * Note: the suite hard-depends on a reachable server — with none running, every
16 * test errors rather than skips. Intentional for now; if a friendlier
17 * "no server -> skip with a clear message" behavior is wanted later, add it here.
18 */
19const URL_BASE = process.env.CLICKHOUSE_URL ?? "http://localhost:8123";
20const USER = process.env.CLICKHOUSE_USER ?? "default";
21const PASSWORD = process.env.CLICKHOUSE_PASSWORD ?? "";
22
23export async function query(sql: string): Promise<Buffer> {
24  const res = await fetch(URL_BASE, {
25    method: "POST",
26    headers: {
27      "X-ClickHouse-User": USER,
28      "X-ClickHouse-Key": PASSWORD,
29    },
30    body: sql,
31  });
32  if (!res.ok) {
33    throw new Error(
34      `ClickHouse ${res.status} for query: ${sql}\n${await res.text()}`,
35    );
36  }
37  // Buffer.from(ArrayBuffer) is a no-copy view over the response bytes.
38  return Buffer.from(await res.arrayBuffer());
39}