From b0213cfa073c2aa0a116c57daefa4b3c5c74eee0 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=A3=9E=E5=93=A5=28fizzday=29?= <fizzday@yeah.net>
Date: Tue, 2 Jun 2020 15:58:16 +0800
Subject: [PATCH] Update session.go
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

事务中使用 s.tx
---
 session.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/session.go b/session.go
index b8e64af..018ed2c 100644
--- 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 {