x

chenquan · Jun 6, 2024 · 4c4223c · 4c4223c
1 parent 9a5573d
commit 4c4223c
Showing 1 changed file with 5 additions and 8 deletions.
diff --git a/multiple.go b/multiple.go
@@ -87,14 +87,11 @@ func NewMultipleSqlConn(driverName string, conf DBConf, opts ...SqlOption) sqlx.
 			return
 		}
 
-		for {
-			select {
-			case follow := <-sqlOpt.watcher:
-				if follow.Added {
-					p2cPickerObj.add(follow.Name, follow.Datasource)
-				} else {
-					p2cPickerObj.del(follow.Datasource)
-				}
+		for follow := range sqlOpt.watcher {
+			if follow.Added {
+				p2cPickerObj.add(follow.Name, follow.Datasource)
+			} else {
+				p2cPickerObj.del(follow.Datasource)
 			}
 		}
 	}()