From 885f582677dd3f3bbd127924b05763e730573300 Mon Sep 17 00:00:00 2001
From: RenKanai <rennnosuke@noreply.gitea.io>
Date: Wed, 24 Nov 2021 10:29:39 +0800
Subject: [PATCH] Fix to add session.statement.IsForUpdate check in
 Session.queryRows() (#2064)

# Issue
The 'for-update' query is executed to slave DB node.

# Example

```go
s := engineGroup.NewSession(); // create session from EngineGroup.
...

s.ForUpdate();

type User struct { ... };
var user User;
has, err := s.Get(&user); // executed to slave DB node.
...
```

Co-authored-by: rennnosuke <rennnosuke@noreply.gitea.io>
Co-authored-by: RenKanai <turutekab@gmail.com>
Co-authored-by: Lunny Xiao <xiaolunwen@gmail.com>
Reviewed-on: https://gitea.com/xorm/xorm/pulls/2064
Reviewed-by: Lunny Xiao <xiaolunwen@gmail.com>
Co-authored-by: RenKanai <rennnosuke@noreply.gitea.io>
Co-committed-by: RenKanai <rennnosuke@noreply.gitea.io>
---
 session_raw.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/session_raw.go b/session_raw.go
index 0d20dd60..add584d0 100644
--- a/session_raw.go
+++ b/session_raw.go
@@ -33,7 +33,7 @@ func (session *Session) queryRows(sqlStr string, args ...interface{}) (*core.Row
 
 	if session.isAutoCommit {
 		var db *core.DB
-		if session.sessionType == groupSession && strings.EqualFold(strings.TrimSpace(sqlStr)[:6], "select") {
+		if session.sessionType == groupSession && strings.EqualFold(strings.TrimSpace(sqlStr)[:6], "select") && !session.statement.IsForUpdate {
 			db = session.engine.engineGroup.Slave().DB()
 		} else {
 			db = session.DB()