fix: fix delete, insert, update tx statement

lqs · Feb 7, 2024 · 8cb8992 · 8cb8992
1 parent 9a36179
commit 8cb8992
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 0 deletions.
diff --git a/delete.go b/delete.go
@@ -91,5 +91,8 @@ func (s deleteStatus) Execute() (sql.Result, error) {
 	if err != nil {
 		return nil, err
 	}
+	if s.scope.Transaction != nil {
+		return s.scope.Transaction.Execute(sqlString)
+	}
 	return s.scope.Database.Execute(sqlString)
 }
diff --git a/insert.go b/insert.go
@@ -187,5 +187,8 @@ func (s insertStatus) Execute() (result sql.Result, err error) {
 	if err != nil {
 		return nil, err
 	}
+	if s.scope.Transaction != nil {
+		return s.scope.Transaction.Execute(sqlString)
+	}
 	return s.scope.Database.Execute(sqlString)
 }
diff --git a/update.go b/update.go
@@ -125,5 +125,8 @@ func (s updateStatus) Execute() (sql.Result, error) {
 	if err != nil {
 		return nil, err
 	}
+	if s.scope.Transaction != nil {
+		return s.scope.Transaction.Execute(sqlString)
+	}
 	return s.scope.Database.Execute(sqlString)
 }