From 781bccad3bd84476babba8836aa6bcdc076b592a Mon Sep 17 00:00:00 2001
From: Garet Halliday <ghalliday@gfxlabs.io>
Date: Thu, 29 Sep 2022 16:32:28 -0500
Subject: [PATCH] typo
---
lib/gat/database/query_router/query_router.go | 3 ++-
lib/gat/pool/transaction/worker.go | 4 ++--
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/lib/gat/database/query_router/query_router.go b/lib/gat/database/query_router/query_router.go
index 722ca318..760eeb3c 100644
--- a/lib/gat/database/query_router/query_router.go
+++ b/lib/gat/database/query_router/query_router.go
@@ -98,7 +98,8 @@ func (r *QueryRouter) InferRole(query string) (config.ServerRole, error) {
lex.KeywordTruncate,
lex.KeywordVacuum,
lex.KeywordAnalyze,
- lex.KeywordAlter:
+ lex.KeywordAlter,
+ lex.KeywordGrant:
return config.SERVERROLE_PRIMARY, nil
case lex.KeywordBegin:
depth += 1
diff --git a/lib/gat/pool/transaction/worker.go b/lib/gat/pool/transaction/worker.go
index 30d08436..94a3083a 100644
--- a/lib/gat/pool/transaction/worker.go
+++ b/lib/gat/pool/transaction/worker.go
@@ -103,7 +103,7 @@ func (w *worker) GetServerInfo(client gat.Client) []*protocol.ParameterStatus {
func (w *worker) HandleDescribe(ctx context.Context, c gat.Client, d *protocol.Describe) error {
defer w.ret()
- if w.w.user.StatementTimeout == 0 {
+ if w.w.user.StatementTimeout != 0 {
ctx, _ = context.WithTimeout(ctx, time.Duration(w.w.user.StatementTimeout)*time.Millisecond)
}
@@ -127,7 +127,7 @@ func (w *worker) HandleDescribe(ctx context.Context, c gat.Client, d *protocol.D
func (w *worker) HandleExecute(ctx context.Context, c gat.Client, e *protocol.Execute) error {
defer w.ret()
- if w.w.user.StatementTimeout == 0 {
+ if w.w.user.StatementTimeout != 0 {
ctx, _ = context.WithTimeout(ctx, time.Duration(w.w.user.StatementTimeout)*time.Millisecond)
}
--
GitLab