|
|
@@ -256,6 +256,29 @@ func (m *MongodbSim) SaveBulk(c string, doc ...map[string]interface{}) bool {
|
|
|
return b
|
|
|
}
|
|
|
|
|
|
+//批量插入
|
|
|
+func (m *MongodbSim) SaveBulkInterface(c string, doc ...interface{}) bool {
|
|
|
+ defer util.Catch()
|
|
|
+ sess := m.GetMgoConn()
|
|
|
+ b := true
|
|
|
+ if sess != nil {
|
|
|
+ defer m.DestoryMongoConn(sess)
|
|
|
+ coll := sess.DB(m.DbName).C(c)
|
|
|
+ bulk := coll.Bulk()
|
|
|
+ for _, v := range doc {
|
|
|
+ bulk.Insert(v)
|
|
|
+ }
|
|
|
+ _, err := bulk.Run()
|
|
|
+ if nil != err {
|
|
|
+ log.Println("BulkError", err)
|
|
|
+ b = false
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ b = false
|
|
|
+ }
|
|
|
+ return b
|
|
|
+}
|
|
|
+
|
|
|
func (m *MongodbSim) Save(c string, doc interface{}) string {
|
|
|
defer util.Catch()
|
|
|
sess := m.GetMgoConn()
|
