mirror of
https://github.com/openimsdk/open-im-server.git
synced 2026-04-29 18:34:04 +08:00
Merge 6f15f072d09c89815f24f7103918091d16fa8105 into 5211d43d9d86772a45b451e49d526400a4e0448e
This commit is contained in:
commit
e6894e60ed
@ -20,7 +20,6 @@ import (
|
|||||||
|
|
||||||
"github.com/openimsdk/open-im-server/v3/pkg/common/storage/database"
|
"github.com/openimsdk/open-im-server/v3/pkg/common/storage/database"
|
||||||
"github.com/openimsdk/open-im-server/v3/pkg/common/storage/model"
|
"github.com/openimsdk/open-im-server/v3/pkg/common/storage/model"
|
||||||
|
|
||||||
"github.com/openimsdk/tools/db/mongoutil"
|
"github.com/openimsdk/tools/db/mongoutil"
|
||||||
"github.com/openimsdk/tools/errs"
|
"github.com/openimsdk/tools/errs"
|
||||||
"go.mongodb.org/mongo-driver/bson"
|
"go.mongodb.org/mongo-driver/bson"
|
||||||
@ -31,10 +30,11 @@ import (
|
|||||||
func NewS3Mongo(db *mongo.Database) (database.ObjectInfo, error) {
|
func NewS3Mongo(db *mongo.Database) (database.ObjectInfo, error) {
|
||||||
coll := db.Collection(database.ObjectName)
|
coll := db.Collection(database.ObjectName)
|
||||||
|
|
||||||
// Create index for name
|
// Create new unique index for name + engine
|
||||||
_, err := coll.Indexes().CreateOne(context.Background(), mongo.IndexModel{
|
_, err := coll.Indexes().CreateOne(context.Background(), mongo.IndexModel{
|
||||||
Keys: bson.D{
|
Keys: bson.D{
|
||||||
{Key: "name", Value: 1},
|
{Key: "name", Value: 1},
|
||||||
|
{Key: "engine", Value: 1},
|
||||||
},
|
},
|
||||||
Options: options.Index().SetUnique(true),
|
Options: options.Index().SetUnique(true),
|
||||||
})
|
})
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user