From efb324070827bd1fe713b93f80c601551d246579 Mon Sep 17 00:00:00 2001
From: xengineering <me@xengineering.eu>
Date: Sun, 31 May 2026 21:20:48 +0200
Subject: Add migration execution

This adds the execution of the embedded migrations and adds a suitable
unit test.
---
 database.go | 23 +++++++++++++++++++++++
 1 file changed, 23 insertions(+)

(limited to 'database.go')

diff --git a/database.go b/database.go
index c2d69c1..c71ff78 100644
--- a/database.go
+++ b/database.go
@@ -1,6 +1,7 @@
 package main
 
 import (
+	"database/sql"
 	"embed"
 	"fmt"
 	"io/fs"
@@ -43,3 +44,25 @@ func readMigrations() {
 		return nil
 	})
 }
+
+func Transaction(db *sql.DB, f func(*sql.Tx) error) error {
+	tx, err := db.Begin()
+	if err != nil {
+		return err
+	}
+	defer tx.Rollback()
+
+	err = f(tx)
+	if err != nil {
+		return err
+	}
+
+	return tx.Commit()
+}
+
+func Migrate(db *sql.DB, index int) error {
+	return Transaction(db, func(tx *sql.Tx) error {
+		_, err := tx.Exec(migrations[index])
+		return err
+	})
+}
-- 
cgit v1.3.1