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) } }