Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-03-03 04:07:39 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化mongo模块

Browse Source
This commit is contained in:
orgin
2022-04-01 14:06:24 +08:00
parent ca48c443cd
commit 4d5d45d555
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
sysmodule/mongodbmodule/mongodbmodule.go
View File

@@ -70,18 +70,17 @@ func (s *Session) NextSeq(db string, collection string, id interface{}) (int, er
} }
//indexKeys[索引][每个索引key字段] //indexKeys[索引][每个索引key字段]
func (s *Session) EnsureIndex(db string, collection string, indexKeys [][]string, bBackground bool) error { func (s *Session) EnsureIndex(db string, collection string, indexKeys [][]string, bBackground bool,sparse bool) error {
return s.ensureIndex(db, collection, indexKeys, bBackground, false) return s.ensureIndex(db, collection, indexKeys, bBackground, false,sparse)
} }
//indexKeys[索引][每个索引key字段] //indexKeys[索引][每个索引key字段]
func (s *Session) EnsureUniqueIndex(db string, collection string, indexKeys [][]string, bBackground bool) error { func (s *Session) EnsureUniqueIndex(db string, collection string, indexKeys [][]string, bBackground bool,sparse bool) error {
return s.ensureIndex(db, collection, indexKeys, bBackground, true) return s.ensureIndex(db, collection, indexKeys, bBackground, true,sparse)
} }
//keys[索引][每个索引key字段] //keys[索引][每个索引key字段]
func (s *Session) ensureIndex(db string, collection string, indexKeys [][]string, bBackground bool, unique bool) error { func (s *Session) ensureIndex(db string, collection string, indexKeys [][]string, bBackground bool, unique bool,sparse bool) error {
var indexes []mongo.IndexModel var indexes []mongo.IndexModel
for _, keys := range indexKeys { for _, keys := range indexKeys {
keysDoc := bsonx.Doc{} keysDoc := bsonx.Doc{}
@@ -89,10 +88,11 @@ func (s *Session) ensureIndex(db string, collection string, indexKeys [][]string
keysDoc = keysDoc.Append(key, bsonx.Int32(1)) keysDoc = keysDoc.Append(key, bsonx.Int32(1))
} }
indexes = append(indexes, mongo.IndexModel{ options:= options.Index().SetUnique(unique).SetBackground(bBackground)
Keys: keysDoc, if sparse == true {
Options: options.Index().SetUnique(unique).SetBackground(bBackground), options.SetSparse(true)
}) }
indexes = append(indexes, mongo.IndexModel{Keys: keysDoc, Options:options })
} }
ctxTimeout, cancel := context.WithTimeout(context.Background(), s.maxOperatorTimeOut) ctxTimeout, cancel := context.WithTimeout(context.Background(), s.maxOperatorTimeOut)