Просмотр исходного кода

Merge branch 'dev2.6' of ssh://192.168.3.207:10022/qmx/qfw into dev2.6

wcj 6 лет назад
Родитель
Сommit
f9b30795d1
1 измененных файлов с 23 добавлено и 0 удалено
  1. 23 0
      common/src/qfw/util/mongodb/mongodbSim.go

+ 23 - 0
common/src/qfw/util/mongodb/mongodbSim.go

@@ -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()