|
|
@@ -193,6 +193,25 @@ func (m *MongodbSim) UpSertBulk(c string, doc ...[]map[string]interface{}) bool
|
|
|
return true
|
|
|
}
|
|
|
|
|
|
+//批量插入
|
|
|
+func (m *MongodbSim) SaveBulk(c string, doc ...map[string]interface{}) bool {
|
|
|
+ m.Open()
|
|
|
+ defer m.Close()
|
|
|
+ coll := m.C.Database(m.DbName).Collection(c)
|
|
|
+ var writes []mongo.WriteModel
|
|
|
+ for _, d := range doc {
|
|
|
+ write := mongo.NewInsertOneModel()
|
|
|
+ write.SetDocument(d)
|
|
|
+ writes = append(writes, write)
|
|
|
+ }
|
|
|
+ _, e := coll.BulkWrite(m.Ctx, writes)
|
|
|
+ if e != nil {
|
|
|
+ log.Println("mgo savebulk error:", e.Error())
|
|
|
+ return false
|
|
|
+ }
|
|
|
+ return true
|
|
|
+}
|
|
|
+
|
|
|
//保存
|
|
|
func (m *MongodbSim) Save(c string, doc map[string]interface{}) interface{} {
|
|
|
m.Open()
|
