|
@@ -278,10 +278,10 @@ func (m *MongodbSim) InitPool() {
|
|
|
}
|
|
|
opts.SetAuth(cre)
|
|
|
}
|
|
|
- ms := strings.Split(m.MongodbAddr, ",")
|
|
|
+ /*ms := strings.Split(m.MongodbAddr, ",")
|
|
|
if m.ReplSet == "" && len(ms) > 1 {
|
|
|
- //m.ReplSet = "qfws"
|
|
|
- }
|
|
|
+ m.ReplSet = "qfws"
|
|
|
+ }*/
|
|
|
if m.ReplSet != "" {
|
|
|
opts.SetReplicaSet(m.ReplSet)
|
|
|
opts.SetDirect(false)
|