do not send "select" in cluster mode

tair-opensource · Feb 28, 2023 · 865937d · 865937d
1 parent 2937df8
commit 865937d
Showing 1 changed file with 8 additions and 7 deletions.
diff --git 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)