Try rollback only if mysql.Error

ziutek · Sep 26, 2012 · 0e05c70 · 0e05c70
1 parent a50040b
commit 0e05c70
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/autorc/autorecon.go b/autorc/autorecon.go
@@ -214,7 +214,7 @@ func (c *Conn) Begin(f func(mysql.Transaction, ...interface{}) error, args ...in
 			}
 		}
 		if c.reconnectIfNetErr(&nn, &err); err != nil {
-			if tr.IsValid() {
+			if _, ok := err.(*mysql.Error); ok && tr.IsValid() {
 				tr.Rollback()
 			}
 			return err