replace mongo driver

pull/148/head
wenxu12345 3 years ago
parent bf948789ea
commit 53a4b90d96

@ -61,6 +61,10 @@ func init() {
log.NewError(" mongo.Connect failed, try ", err.Error(), uri) log.NewError(" mongo.Connect failed, try ", err.Error(), uri)
time.Sleep(time.Duration(30) * time.Second) time.Sleep(time.Duration(30) * time.Second)
mongoClient, err1 = mongo.Connect(context.TODO(), options.Client().ApplyURI(uri)) mongoClient, err1 = mongo.Connect(context.TODO(), options.Client().ApplyURI(uri))
if err1 != nil {
log.NewError(" mongo.Connect failed, panic", err.Error(), uri)
panic(err1.Error())
}
mgoSession, err1 = mgo.DialWithInfo(mgoDailInfo) mgoSession, err1 = mgo.DialWithInfo(mgoDailInfo)
if err1 != nil { if err1 != nil {
log.NewError(" mongo.Connect failed, panic", err.Error(), uri) log.NewError(" mongo.Connect failed, panic", err.Error(), uri)

Loading…
Cancel
Save