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

model

Browse Source
This commit is contained in:
wangchuxiao 2023-01-17 17:08:52 +08:00
parent 727bf623b3
commit 3e0c6f94ed
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/common/db/mongoDB/init_mongo.go
View File

@ -58,6 +58,10 @@ func initMongo() *mongo.Client {
panic(err.Error() + " mongo.Connect failed " + uri) panic(err.Error() + " mongo.Connect failed " + uri)
} }
} }
return mongoClient
}
func CreateAllIndex(mongoClient *mongo.Client) {
// mongodb create index // mongodb create index
if err := createMongoIndex(mongoClient, cSendLog, false, "send_id", "-send_time"); err != nil { if err := createMongoIndex(mongoClient, cSendLog, false, "send_id", "-send_time"); err != nil {
panic(err.Error() + " index create failed " + cSendLog + " send_id, -send_time") panic(err.Error() + " index create failed " + cSendLog + " send_id, -send_time")
@ -80,7 +84,6 @@ func initMongo() *mongo.Client {
if err := createMongoIndex(mongoClient, cTag, true, "tag_id"); err != nil { if err := createMongoIndex(mongoClient, cTag, true, "tag_id"); err != nil {
panic(err.Error() + "index create failed " + cTag + " tag_id") panic(err.Error() + "index create failed " + cTag + " tag_id")
} }
return mongoClient
} }
func createMongoIndex(client *mongo.Client, collection string, isUnique bool, keys ...string) error { func createMongoIndex(client *mongo.Client, collection string, isUnique bool, keys ...string) error {