fix insert version txn

db.go

@@ -392,6 +392,8 @@ func sliceContains(a []string, b string) bool {
 }
 
 func rollbackAndLogErr(originErr error, txn *sql.Tx, msg string, args ...any) error {
+	log.WithError(originErr).Errorf("unable to execute SQL, rolling back...")
+
 	if err := txn.Rollback(); err != nil {
 		log.WithError(err).Errorf("unable to rollback transaction")
 		if len(msg) > 0 {

migration.go

@@ -83,7 +83,7 @@ func withTransaction(ctx context.Context, db *sql.DB, callbacks ...TransactionHa
 
 	for _, cb := range callbacks {
 		if err2 := cb(ctx, tx); err2 != nil {
-			return rollbackAndLogErr(err, tx, "")
+			return rollbackAndLogErr(err2, tx, "")
 		}
 	}
 
@@ -102,7 +102,7 @@ func (m *Migration) runUp(ctx context.Context, db *DB) error {
 		return executeStatements(ctx, exec, m.UpStatements)
 	})
 	finalizer := func(ctx context.Context, exec SQLExecutor) error {
-		return db.insertVersion(ctx, db.DB, m.Package, m.Source, m.Version, true)
+		return db.insertVersion(ctx, exec, m.Package, m.Source, m.Version, true)
 	}
 
 	var executor = m.getStmtExecutor()
@@ -114,7 +114,7 @@ func (m *Migration) runDown(ctx context.Context, db *DB) error {
 		return executeStatements(ctx, exec, m.DownStatements)
 	})
 	finalizer := func(ctx context.Context, exec SQLExecutor) error {
-		return db.deleteVersion(ctx, db.DB, m.Package, m.Version)
+		return db.deleteVersion(ctx, exec, m.Package, m.Version)
 	}
 
 	var executor = m.getStmtExecutor()

parser.go

@@ -112,6 +112,7 @@ func (p *MigrationParser) Parse(r io.Reader) (*MigrationScriptChunk, error) {
 				}
 
 				chunk.Package = packageName
+				continue
 			}
 
 			switch cmd {

up.go

@@ -6,6 +6,8 @@ import (
 
 func UpBySteps(ctx context.Context, db *DB, m *Migration, steps int, callbacks ...func(m *Migration)) error {
 	for ; steps > 0 && m != nil; m = m.Next {
+		descMigration("upgrading", m)
+
 		if err := m.Up(ctx, db); err != nil {
 			return err
 		}