111 lines
3.4 KiB
Go
111 lines
3.4 KiB
Go
package infra
|
|
|
|
import (
|
|
"testing"
|
|
)
|
|
|
|
func TestMigrationStatus(t *testing.T) {
|
|
t.Run("migraciones en disco pero no en BD aparecen como pending", func(t *testing.T) {
|
|
db := openMigrationTestDB(t)
|
|
dir := t.TempDir()
|
|
|
|
writeMigrationFile(t, dir, "001_create_users.sql",
|
|
"-- +up\nCREATE TABLE users (id TEXT PRIMARY KEY);\n-- +down\nDROP TABLE IF EXISTS users;\n")
|
|
writeMigrationFile(t, dir, "002_create_roles.sql",
|
|
"-- +up\nCREATE TABLE roles (id TEXT PRIMARY KEY);\n-- +down\nDROP TABLE IF EXISTS roles;\n")
|
|
|
|
statuses, err := MigrationGetStatus(db, dir)
|
|
if err != nil {
|
|
t.Fatalf("unexpected error: %v", err)
|
|
}
|
|
if len(statuses) != 2 {
|
|
t.Fatalf("expected 2 statuses, got %d", len(statuses))
|
|
}
|
|
for _, s := range statuses {
|
|
if s.Applied {
|
|
t.Errorf("version %d should be pending, got applied", s.Version)
|
|
}
|
|
}
|
|
})
|
|
|
|
t.Run("migraciones aplicadas aparecen con Applied=true y AppliedAt", func(t *testing.T) {
|
|
db := openMigrationTestDB(t)
|
|
dir := t.TempDir()
|
|
|
|
writeMigrationFile(t, dir, "001_create_users.sql",
|
|
"-- +up\nCREATE TABLE users (id TEXT PRIMARY KEY);\n-- +down\nDROP TABLE IF EXISTS users;\n")
|
|
writeMigrationFile(t, dir, "002_create_roles.sql",
|
|
"-- +up\nCREATE TABLE roles (id TEXT PRIMARY KEY);\n-- +down\nDROP TABLE IF EXISTS roles;\n")
|
|
|
|
if _, err := MigrationUp(db, dir); err != nil {
|
|
t.Fatalf("up failed: %v", err)
|
|
}
|
|
|
|
statuses, err := MigrationGetStatus(db, dir)
|
|
if err != nil {
|
|
t.Fatalf("unexpected error: %v", err)
|
|
}
|
|
if len(statuses) != 2 {
|
|
t.Fatalf("expected 2 statuses, got %d", len(statuses))
|
|
}
|
|
for _, s := range statuses {
|
|
if !s.Applied {
|
|
t.Errorf("version %d should be applied, got pending", s.Version)
|
|
}
|
|
if s.AppliedAt.IsZero() {
|
|
t.Errorf("version %d AppliedAt should not be zero", s.Version)
|
|
}
|
|
}
|
|
})
|
|
|
|
t.Run("migraciones aplicadas sin archivo en disco aparecen como orphaned", func(t *testing.T) {
|
|
db := openMigrationTestDB(t)
|
|
dir := t.TempDir()
|
|
|
|
writeMigrationFile(t, dir, "001_create_users.sql",
|
|
"-- +up\nCREATE TABLE users (id TEXT PRIMARY KEY);\n-- +down\nDROP TABLE IF EXISTS users;\n")
|
|
|
|
if _, err := MigrationUp(db, dir); err != nil {
|
|
t.Fatalf("up failed: %v", err)
|
|
}
|
|
|
|
// Remove file from disk but migration is applied in DB
|
|
// Now check status with an empty dir
|
|
emptyDir := t.TempDir()
|
|
statuses, err := MigrationGetStatus(db, emptyDir)
|
|
if err != nil {
|
|
t.Fatalf("unexpected error: %v", err)
|
|
}
|
|
if len(statuses) != 1 {
|
|
t.Fatalf("expected 1 status (orphaned), got %d", len(statuses))
|
|
}
|
|
s := statuses[0]
|
|
if !s.Applied {
|
|
t.Errorf("orphaned migration should have Applied=true")
|
|
}
|
|
if !containsStr(s.Name, "orphaned") {
|
|
t.Errorf("orphaned migration name should contain 'orphaned', got %q", s.Name)
|
|
}
|
|
})
|
|
|
|
t.Run("base de datos sin tabla _migrations retorna todas como pending", func(t *testing.T) {
|
|
db := openMigrationTestDB(t)
|
|
dir := t.TempDir()
|
|
|
|
writeMigrationFile(t, dir, "001_create_users.sql",
|
|
"-- +up\nCREATE TABLE users (id TEXT PRIMARY KEY);\n-- +down\nDROP TABLE IF EXISTS users;\n")
|
|
|
|
// Do NOT call MigrationUp — _migrations table doesn't exist
|
|
statuses, err := MigrationGetStatus(db, dir)
|
|
if err != nil {
|
|
t.Fatalf("unexpected error: %v", err)
|
|
}
|
|
if len(statuses) != 1 {
|
|
t.Fatalf("expected 1 status, got %d", len(statuses))
|
|
}
|
|
if statuses[0].Applied {
|
|
t.Errorf("migration should be pending when _migrations does not exist")
|
|
}
|
|
})
|
|
}
|