blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-11-04 11:22:10 +08:00
Code Issues Packages Projects Releases Wiki Activity

replace mongo driver

Browse Source
This commit is contained in:
wenxu12345 2022-02-21 15:20:39 +08:00 committed by Pi
parent d934ec6a23
commit 500de1fd73
1 changed files with 15 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
pkg/common/db/model.go
View File

@ -37,21 +37,21 @@ func init() {
// mongo init // mongo init
// "mongodb://sysop:moon@localhost/records" // "mongodb://sysop:moon@localhost/records"
// uri := "mongodb://user:pass@sample.host:27017/?maxPoolSize=20&w=majority" // uri := "mongodb://user:pass@sample.host:27017/?maxPoolSize=20&w=majority"
uri := fmt.Sprintf("mongodb://%s:%s@%s/%s/?maxPoolSize=%d", //uri := fmt.Sprintf("mongodb://%s:%s@%s/%s/?maxPoolSize=%d",
config.Config.Mongo.DBUserName, config.Config.Mongo.DBPassword, // config.Config.Mongo.DBUserName, config.Config.Mongo.DBPassword,
config.Config.Mongo.DBAddress[0],config.Config.Mongo.DBDatabase, // config.Config.Mongo.DBAddress[0],config.Config.Mongo.DBDatabase,
config.Config.Mongo.DBMaxPoolSize) // config.Config.Mongo.DBMaxPoolSize)
//
mongoClient, err := mongo.Connect(context.TODO(), options.Client().ApplyURI(uri)) //mongoClient, err := mongo.Connect(context.TODO(), options.Client().ApplyURI(uri))
if err != nil{ //if err != nil{
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 { // if err1 != nil {
log.NewError(" mongo.Connect failed, panic", err.Error(), uri) // log.NewError(" mongo.Connect failed, panic", err.Error(), uri)
panic(err1.Error()) // panic(err1.Error())
} // }
} //}