You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
114 lines
3.3 KiB
114 lines
3.3 KiB
package unrelation
|
|
|
|
import (
|
|
"OpenIM/pkg/common/config"
|
|
"OpenIM/pkg/common/db/table/unrelation"
|
|
"OpenIM/pkg/common/mw/specialerror"
|
|
"OpenIM/pkg/errs"
|
|
"OpenIM/pkg/utils"
|
|
"context"
|
|
"fmt"
|
|
"go.mongodb.org/mongo-driver/mongo"
|
|
"go.mongodb.org/mongo-driver/mongo/options"
|
|
"go.mongodb.org/mongo-driver/x/bsonx"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
type Mongo struct {
|
|
db *mongo.Client
|
|
}
|
|
|
|
func NewMongo() (*Mongo, error) {
|
|
specialerror.AddReplace(mongo.ErrNoDocuments, errs.ErrRecordNotFound)
|
|
uri := "mongodb://sample.host:27017/?maxPoolSize=20&w=majority"
|
|
if config.Config.Mongo.DBUri != "" {
|
|
// example: mongodb://$user:$password@mongo1.mongo:27017,mongo2.mongo:27017,mongo3.mongo:27017/$DBDatabase/?replicaSet=rs0&readPreference=secondary&authSource=admin&maxPoolSize=$DBMaxPoolSize
|
|
uri = config.Config.Mongo.DBUri
|
|
} else {
|
|
//mongodb://mongodb1.example.com:27317,mongodb2.example.com:27017/?replicaSet=mySet&authSource=authDB
|
|
mongodbHosts := ""
|
|
for i, v := range config.Config.Mongo.DBAddress {
|
|
if i == len(config.Config.Mongo.DBAddress)-1 {
|
|
mongodbHosts += v
|
|
} else {
|
|
mongodbHosts += v + ","
|
|
}
|
|
}
|
|
if config.Config.Mongo.DBPassword != "" && config.Config.Mongo.DBUserName != "" {
|
|
uri = fmt.Sprintf("mongodb://%s:%s@%s/%s?maxPoolSize=%d&authSource=admin",
|
|
config.Config.Mongo.DBUserName, config.Config.Mongo.DBPassword, mongodbHosts,
|
|
config.Config.Mongo.DBDatabase, config.Config.Mongo.DBMaxPoolSize)
|
|
} else {
|
|
uri = fmt.Sprintf("mongodb://%s/%s/?maxPoolSize=%d&authSource=admin",
|
|
mongodbHosts, config.Config.Mongo.DBDatabase,
|
|
config.Config.Mongo.DBMaxPoolSize)
|
|
}
|
|
}
|
|
fmt.Println("mongo:", uri)
|
|
ctx, cancel := context.WithTimeout(context.Background(), time.Second*60)
|
|
defer cancel()
|
|
mongoClient, err := mongo.Connect(ctx, options.Client().ApplyURI(uri))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return &Mongo{db: mongoClient}, nil
|
|
}
|
|
|
|
func (m *Mongo) GetClient() *mongo.Client {
|
|
return m.db
|
|
}
|
|
|
|
func (m *Mongo) GetDatabase() *mongo.Database {
|
|
return m.db.Database(config.Config.Mongo.DBDatabase)
|
|
}
|
|
|
|
func (m *Mongo) CreateMsgIndex() error {
|
|
return m.createMongoIndex(unrelation.Msg, false, "uid")
|
|
}
|
|
|
|
func (m *Mongo) CreateSuperGroupIndex() error {
|
|
if err := m.createMongoIndex(unrelation.CSuperGroup, true, "group_id"); err != nil {
|
|
return err
|
|
}
|
|
if err := m.createMongoIndex(unrelation.CUserToSuperGroup, true, "user_id"); err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *Mongo) CreateExtendMsgSetIndex() error {
|
|
return m.createMongoIndex(unrelation.CExtendMsgSet, true, "-create_time", "work_moment_id")
|
|
}
|
|
|
|
func (m *Mongo) createMongoIndex(collection string, isUnique bool, keys ...string) error {
|
|
db := m.db.Database(config.Config.Mongo.DBDatabase).Collection(collection)
|
|
opts := options.CreateIndexes().SetMaxTime(10 * time.Second)
|
|
indexView := db.Indexes()
|
|
keysDoc := bsonx.Doc{}
|
|
// create composite indexes
|
|
for _, key := range keys {
|
|
if strings.HasPrefix(key, "-") {
|
|
keysDoc = keysDoc.Append(strings.TrimLeft(key, "-"), bsonx.Int32(-1))
|
|
} else {
|
|
keysDoc = keysDoc.Append(key, bsonx.Int32(1))
|
|
}
|
|
}
|
|
// create index
|
|
index := mongo.IndexModel{
|
|
Keys: keysDoc,
|
|
}
|
|
if isUnique == true {
|
|
index.Options = options.Index().SetUnique(true)
|
|
}
|
|
result, err := indexView.CreateOne(
|
|
context.Background(),
|
|
index,
|
|
opts,
|
|
)
|
|
if err != nil {
|
|
return utils.Wrap(err, result)
|
|
}
|
|
return nil
|
|
}
|