test: Ensure migration will be executed even with past timestamp

app/pkg/dbx/migrate_test.go

@@ -39,6 +39,27 @@ func TestMigrate_Success(t *testing.T) {
 	trx.MustRollback()
 }
 
+func TestMigrate_SuccessWithPastMigration(t *testing.T) {
+	setupMigrationTest(t)
+	ctx := context.Background()
+
+	err := dbx.Migrate(ctx, "/app/pkg/dbx/testdata/migration_success")
+	Expect(err).IsNil()
+
+	err = dbx.Migrate(ctx, "/app/pkg/dbx/testdata/migration_success_with_new_migrations")
+	Expect(err).IsNil()
+
+	trx, _ := dbx.BeginTx(ctx)
+	var version string
+	err = trx.Scalar(&version, "SELECT version FROM migrations_history WHERE version = '209901010000' LIMIT 1")
+	Expect(version).Equals("209901010000")
+	var count int
+	err = trx.Scalar(&count, "SELECT COUNT(*) FROM migrations_history where VERSION IN (209901010000,210001010002)")
+	Expect(err).IsNil()
+	Expect(count).Equals(2)
+	trx.MustRollback()
+}
+
 func TestMigrate_Failure(t *testing.T) {
 	setupMigrationTest(t)
 	ctx := context.Background()

app/pkg/dbx/testdata/migration_success_with_new_migrations/209901010000_create.sql

@@ -0,0 +1 @@
+insert into dummy (id, description) values (400, 'Description 400A');

app/pkg/dbx/testdata/migration_success_with_new_migrations/210001010002_delete.sql

@@ -0,0 +1 @@
+DELETE FROM dummy WHERE id = 400;