fix: port read_after_write fix to 0.1.x

wesql · Mar 26, 2024 · b8637a7 · b8637a7
1 parent 5f628f7
commit b8637a7
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/go/vt/vttablet/tabletserver/query_executor.go b/go/vt/vttablet/tabletserver/query_executor.go
@@ -998,14 +998,14 @@ func (qre *QueryExecutor) txFetch(conn *StatefulConnection, record bool) (*sqlty
 	if err != nil {
 		return nil, err
 	}
-	qr, err := qre.execStatefulConn(conn, sql, true)
-	if err != nil {
-		return nil, err
-	}
 	waitGtidPrefixAdded := false
 	if qre.plan.PlanID == p.PlanSelect {
 		sql, waitGtidPrefixAdded = qre.addPrefixWaitGtid(sql)
 	}
+	qr, err := qre.execStatefulConn(conn, sql, true)
+	if err != nil {
+		return nil, err
+	}
 	// Only record successful queries.
 	if record {
 		conn.TxProperties().RecordQuery(sql)