transaction.go 727 B

12345678910111213141516171819202122232425262728293031
  1. // Go MySQL Driver - A MySQL-Driver for Go's database/sql package
  2. //
  3. // Copyright 2012 The Go-MySQL-Driver Authors. All rights reserved.
  4. //
  5. // This Source Code Form is subject to the terms of the Mozilla Public
  6. // License, v. 2.0. If a copy of the MPL was not distributed with this file,
  7. // You can obtain one at http://mozilla.org/MPL/2.0/.
  8. package mysql
  9. type mysqlTx struct {
  10. mc *mysqlConn
  11. }
  12. func (tx *mysqlTx) Commit() (err error) {
  13. if tx.mc == nil || tx.mc.closed.Load() {
  14. return ErrInvalidConn
  15. }
  16. err = tx.mc.exec("COMMIT")
  17. tx.mc = nil
  18. return
  19. }
  20. func (tx *mysqlTx) Rollback() (err error) {
  21. if tx.mc == nil || tx.mc.closed.Load() {
  22. return ErrInvalidConn
  23. }
  24. err = tx.mc.exec("ROLLBACK")
  25. tx.mc = nil
  26. return
  27. }