transactions: check if the netConn ist valid

julienschmidt · julienschmidt · commit 36cccb24339c · 2013-09-15T15:11:23.000+02:00
diff --git a/transaction.go b/transaction.go
@@ -14,7 +14,7 @@ type mysqlTx struct {
 }
 
 func (tx *mysqlTx) Commit() (err error) {
-	if tx.mc == nil {
+	if tx.mc == nil || tx.mc.netConn == nil {
 		return errInvalidConn
 	}
 	err = tx.mc.exec("COMMIT")
@@ -23,7 +23,7 @@ func (tx *mysqlTx) Commit() (err error) {
 }
 
 func (tx *mysqlTx) Rollback() (err error) {
-	if tx.mc == nil {
+	if tx.mc == nil || tx.mc.netConn == nil {
 		return errInvalidConn
 	}
 	err = tx.mc.exec("ROLLBACK")

Original file line number	Diff line number	Diff line change
`@@ -14,7 +14,7 @@ type mysqlTx struct {`
`14`	`14`	`}`
`15`	`15`
`16`	`16`	`func (tx *mysqlTx) Commit() (err error) {`
`17`		`- if tx.mc == nil {`
	`17`	`+ if tx.mc == nil \|\| tx.mc.netConn == nil {`
`18`	`18`	`return errInvalidConn`
`19`	`19`	`}`
`20`	`20`	`err = tx.mc.exec("COMMIT")`
`@@ -23,7 +23,7 @@ func (tx *mysqlTx) Commit() (err error) {`
`23`	`23`	`}`
`24`	`24`
`25`	`25`	`func (tx *mysqlTx) Rollback() (err error) {`
`26`		`- if tx.mc == nil {`
	`26`	`+ if tx.mc == nil \|\| tx.mc.netConn == nil {`
`27`	`27`	`return errInvalidConn`
`28`	`28`	`}`
`29`	`29`	`err = tx.mc.exec("ROLLBACK")`