import * as Effect from "effect/Effect";import * as SqlClient from "effect/unstable/sql/SqlClient"; export default Effect.gen(function* () { const sql = yield* SqlClient.SqlClient; const columns = yield* sql<{ readonly name: string }>` PRAGMA table_info(projection_threads) `; if (!columns.some((column) => column.name === "pin_order_key")) { yield* sql` ALTER TABLE projection_threads ADD COLUMN pin_order_key TEXT `; }});
import * as Effect from "effect/Effect";
import * as SqlClient from "effect/unstable/sql/SqlClient";
export default Effect.gen(function* () {
const sql = yield* SqlClient.SqlClient;
const columns = yield* sql<{ readonly name: string }>`
PRAGMA table_info(projection_threads)
`;
if (!columns.some((column) => column.name === "pin_order_key")) {
yield* sql`
ALTER TABLE projection_threads
ADD COLUMN pin_order_key TEXT
`;
}
});