|
|
@@ -377,6 +377,21 @@ func (m *MongodbSim) Close() {
|
|
|
<-m.pool
|
|
|
}
|
|
|
|
|
|
+//新建表并生成索引
|
|
|
+func (m *MongodbSim) CreateIndex(c string, models []mongo.IndexModel) bool {
|
|
|
+ defer catch()
|
|
|
+ m.Open()
|
|
|
+ defer m.Close()
|
|
|
+ coll := m.C.Database(m.DbName).Collection(c)
|
|
|
+ names, err := coll.Indexes().CreateMany(m.Ctx, models)
|
|
|
+ if err == nil && len(names) > 0 {
|
|
|
+ return true
|
|
|
+ } else {
|
|
|
+ log.Println("CreateIndex Error:", err)
|
|
|
+ return false
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
func (m *MongodbSim) Save(c string, doc interface{}) string {
|
|
|
defer catch()
|
|
|
m.Open()
|
