Update session.go

事务中使用 s.tx
gohouse · Jun 2, 2020 · b0213cf · b0213cf
1 parent ad00c7a
commit b0213cf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/session.go b/session.go
@@ -156,7 +156,7 @@ func (s *Session) Query(sqlstring string, args ...interface{}) (result []Data, e
 	if s.tx == nil {
 		stmt, err = s.slave.Prepare(sqlstring)
 	} else {
-		stmt, err = s.master.Prepare(sqlstring)
+		stmt, err = s.tx.Prepare(sqlstring)
 	}
 
 	if err != nil {