From 31f7facac76da9b481af0a4607f8b29ec7f49cc4 Mon Sep 17 00:00:00 2001 From: bel Date: Sun, 4 May 2025 10:56:57 -0600 Subject: [PATCH] schema out of xaction --- src/db/schema.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/db/schema.go b/src/db/schema.go index a55d77d..23719df 100644 --- a/src/db/schema.go +++ b/src/db/schema.go @@ -3,7 +3,6 @@ package db import ( "context" "fmt" - "strings" "time" ) @@ -28,11 +27,10 @@ func InitializeSchema(ctx context.Context, k string, mods []string) error { mods = append([]string{""}, mods...) for i := v.V + 1; i < len(mods); i++ { q := mods[i] - q = strings.TrimSpace(q) - q = strings.TrimSuffix(q, ";") - q = fmt.Sprintf(`BEGIN; %s; INSERT INTO "database_version.%s" (v, t) VALUES (?, ?); COMMIT;`, q, k) if err := Exec(ctx, q, i, time.Now()); err != nil { return fmt.Errorf("[%s][%d] failed mod %s: %w", k, i, mods[i], err) + } else if err := Exec(ctx, fmt.Sprintf(`INSERT INTO "database_version.%s" (v, t) VALUES (?, ?)`, k), i, time.Now()); err != nil { + return fmt.Errorf("[%s][%d] failed ack mod %s: %w", k, i, mods[i], err) } }