Update table import in table-initialization.ts

src/clickhouse/table-initialization.ts

@@ -2,7 +2,7 @@ import { logger } from "../logger.js";
 import { Err, Ok, Result } from "../result.js";
 import client from "./createClient.js";
 import { augmentCreateTableStatement, getTableName, isCreateTableStatement } from "./table-utils.js";
-import tables from "./tables/index.js";
+import tables from "./tables/tables.js";
 
 export async function initializeDefaultTables(): Promise<Result> {
   const promiseResults = await Promise.allSettled(

src/clickhouse/tables/blocks.sql

@@ -1,3 +1,4 @@
+-- blocks --
 CREATE TABLE IF NOT EXISTS blocks (
   block_id      FixedString(64),
   block_number  UInt32(),
@@ -6,4 +7,4 @@ CREATE TABLE IF NOT EXISTS blocks (
 )
 ENGINE = ReplacingMergeTree
 PRIMARY KEY (block_id)
-ORDER BY (block_id, chain, block_number, timestamp);
+ORDER BY (block_id, chain, block_number, timestamp);

src/clickhouse/tables/blocks_mv.sql

@@ -0,0 +1,22 @@
+-- view --
+CREATE MATERIALIZED VIEW IF NOT EXISTS blocks_mv
+ENGINE = MergeTree
+ORDER BY (chain, timestamp, block_number)
+AS SELECT
+    block_id,
+    block_number,
+    chain,
+    timestamp
+FROM blocks;
+
+-- DROP TABLE IF EXISTS blocks_mv;
+
+-- OPTIMIZE TABLE blocks_mv FINAL;
+
+-- -- insert --
+-- INSERT INTO blocks_mv SELECT
+--     block_id,
+--     block_number,
+--     chain,
+--     timestamp
+-- FROM blocks;

src/clickhouse/tables/tables.ts

@@ -0,0 +1,14 @@
+import { join } from "path";
+
+function file(path: string) {
+  return Bun.file(join(import.meta.dirname, path)).text();
+}
+
+const glob = new Bun.Glob("**/*.sql");
+const tables: [string, string][] = [];
+
+for (const path of glob.scanSync(import.meta.dirname)) {
+  tables.push([path.replace(".sql", ""), await file(path)])
+}
+
+export default tables;