Compare commits

..

2 Commits

Author SHA1 Message Date
sk a3b95947b0 添加注释 2024-04-22 14:19:16 +08:00
sk ac7492c2db no message 2024-04-22 11:06:22 +08:00
1 changed files with 3 additions and 1 deletions

View File

@ -143,8 +143,10 @@ func newMgoSession(user, password, host string, port int32, options string) (s *
// [mongodb://][user:pass@]host1[:port1][,host2[:port2],...][/database][?options]
url := fmt.Sprintf("mongodb://%s%s:%d/admin%s", login, host, port, options)
//fmt.Println(url)
logger.Logger.Tracef("newMgoSession url:%s", url)
session, err := mgo.Dial(url)
if err != nil {
logger.Logger.Errorf("newMgoSession err:%v", err)
return nil, err
}
session.SetSafe(&mgo.Safe{})
@ -240,7 +242,7 @@ func (msm *MgoSessionMgr) GetPltMgoSession(plt, key string) *Session {
if c, ok := msm.GetCfg(plt, key); ok {
s, err := newMgoSession(c.Username, c.Password, c.HostName, c.HostPort, c.Options)
if s == nil || err != nil {
logger.Logger.Error("GetPltMgoSession(%s,%s) err:%v", plt, key, err)
logger.Logger.Errorf("GetPltMgoSession(%s,%s) err:%v config:%+v", plt, key, err, *c)
return nil
}
ss := &Session{Session: s, cfg: c}