23-polls-awnsers.ts

import { sql, type Kysely } from "kysely";

export async function up(db: Kysely<any>) {
    await db.schema
        .createTable("pollAnswers")
        .addColumn("id", "integer", c => c.primaryKey().autoIncrement())
        .addColumn("optionId", "integer", c =>
            c.references("pollOptions.id").notNull().onDelete("cascade"),
        )
        .addColumn("userId", "text", c => c.notNull())
        .addColumn("createdAt", "timestamp", c => c.notNull().defaultTo(sql`current_timestamp`))
        .addColumn("updatedAt", "timestamp", c => c.notNull().defaultTo(sql`current_timestamp`))
        .execute();

    await db.schema
        .createIndex("pollAnswers_optionId_userId_index")
        .on("pollAnswers")
        .columns(["optionId", "userId"])
        .unique()
        .execute();

    await createUpdatedAtTrigger(db, "pollAnswers");
}

function createUpdatedAtTrigger(db: Kysely<any>, tableName: string) {
    return sql
        .raw(`
    create trigger ${tableName}_updatedAt
    after update on ${tableName} for each row
    begin
        update ${tableName}
        set updatedAt = current_timestamp
        where id = old.id;
    end;
    `)
        .execute(db);
}

export async function down(_db: Kysely<any>) {
    throw new Error("Not supported lol");
}