Function chQueryWithMeta

packages/db/src/clickhouse/client.ts:322–366

(
  query: string,
  clickhouseSettings?: ClickHouseSettings
)

}) as ClickHouseClient;

export async function chQueryWithMeta<T extends Record<string, any>>(
  query: string,
  clickhouseSettings?: ClickHouseSettings
): Promise<ResponseJSON<T>> {
  const start = Date.now();
  let host: string | undefined;
  const res = await withRetry((client, ctx) => {
    host = urlHostname(ctx.url);
    return client.query({
      query,
      clickhouse_settings: clickhouseSettings,
    });
  });
  const json = await res.json<T>();
  const keys = Object.keys(json.data[0] || {});
  const response = {
    ...json,
    data: json.data.map((item) => {
      return keys.reduce((acc, key) => {
        const meta = json.meta?.find((m) => m.name === key);
        return {
          ...acc,
          [key]:
            item[key] && meta?.type.includes('Int')
              ? Number.parseFloat(item[key] as string)
              : item[key],
        };
      }, {} as T);
    }),
  };

  logger.info(
    {
      host,
      query: cleanQuery(query),
      rows: json.rows,
      stats: response.statistics,
      elapsed: Date.now() - start,
      clickhouseSettings,
    },
    'query info'
  );

  return response;
}

export async function chQuery<T extends Record<string, any>>(
  query: string,