From 865937d3b317ef5434d08d5398fb787cce9db9fb Mon Sep 17 00:00:00 2001 From: suxb201 Date: Tue, 28 Feb 2023 13:41:49 +0800 Subject: [PATCH] do not send "select" in cluster mode --- internal/reader/scan_reader.go | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/internal/reader/scan_reader.go b/internal/reader/scan_reader.go index bb11e31..b43d029 100644 --- a/internal/reader/scan_reader.go +++ b/internal/reader/scan_reader.go @@ -68,16 +68,17 @@ func (r *scanReader) scan() { scanDbIdUpper = 0 } for dbId := 0; dbId <= scanDbIdUpper; dbId++ { - var cursor uint64 = 0 + if !r.isCluster { + reply := r.clientScan.DoWithStringReply("SELECT", strconv.Itoa(dbId)) + if reply != "OK" { + log.Panicf("scanReader select db failed. db=[%d]", dbId) + } - reply := r.clientScan.DoWithStringReply("SELECT", strconv.Itoa(dbId)) - if reply != "OK" { - log.Panicf("scanReader select db failed. db=[%d]", dbId) + r.clientDump.Send("SELECT", strconv.Itoa(dbId)) + r.innerChannel <- &dbKey{dbId, "", true} } - r.clientDump.Send("SELECT", strconv.Itoa(dbId)) - r.innerChannel <- &dbKey{dbId, "", true} - + var cursor uint64 = 0 for { var keys []string cursor, keys = r.clientScan.Scan(cursor)