Commit e2688d48 by dliangx

删除不用事务

parent a2914e33
...@@ -227,17 +227,11 @@ func DeleteRoute(id int, opt_type int) (bool, error) { ...@@ -227,17 +227,11 @@ func DeleteRoute(id int, opt_type int) (bool, error) {
} }
defer db.Close() defer db.Close()
tx, err := db.Begin()
if err != nil {
return false, fmt.Errorf("begin transaction failed: %w", err)
}
defer tx.Rollback()
var result sql.Result var result sql.Result
if opt_type == 1 { if opt_type == 1 {
result, err = tx.Exec(`DELETE FROM opt_routes WHERE id = $1`, id) result, err = db.Exec(`DELETE FROM opt_routes WHERE id = $1`, id)
} else if opt_type == 2 { } else if opt_type == 2 {
result, err = tx.Exec(`DELETE FROM opt_fly_routes WHERE id = $1`, id) result, err = db.Exec(`DELETE FROM opt_fly_routes WHERE id = $1`, id)
} }
if err != nil { if err != nil {
...@@ -249,10 +243,6 @@ func DeleteRoute(id int, opt_type int) (bool, error) { ...@@ -249,10 +243,6 @@ func DeleteRoute(id int, opt_type int) (bool, error) {
return false, fmt.Errorf("get affected rows failed: %w", err) return false, fmt.Errorf("get affected rows failed: %w", err)
} }
if err = tx.Commit(); err != nil {
return false, fmt.Errorf("commit transaction failed: %w", err)
}
return rowsAffected > 0, nil return rowsAffected > 0, nil
} }
...@@ -263,14 +253,8 @@ func DeleteOptArea(id int, opt_type int) (bool, error) { ...@@ -263,14 +253,8 @@ func DeleteOptArea(id int, opt_type int) (bool, error) {
} }
defer db.Close() defer db.Close()
tx, err := db.Begin()
if err != nil {
return false, fmt.Errorf("begin transaction failed: %w", err)
}
defer tx.Rollback()
var result sql.Result var result sql.Result
result, err = tx.Exec(`DELETE FROM opt_area WHERE id = $1`, id) result, err = db.Exec(`DELETE FROM opt_area WHERE id = $1`, id)
if err != nil { if err != nil {
return false, fmt.Errorf("delete route failed: %w", err) return false, fmt.Errorf("delete route failed: %w", err)
...@@ -281,10 +265,6 @@ func DeleteOptArea(id int, opt_type int) (bool, error) { ...@@ -281,10 +265,6 @@ func DeleteOptArea(id int, opt_type int) (bool, error) {
return false, fmt.Errorf("get affected rows failed: %w", err) return false, fmt.Errorf("get affected rows failed: %w", err)
} }
if err = tx.Commit(); err != nil {
return false, fmt.Errorf("commit transaction failed: %w", err)
}
return rowsAffected > 0, nil return rowsAffected > 0, nil
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment