wangchuanjin 5 жил өмнө
parent
commit
7e31510e0a

+ 3 - 0
src/qfw/util/mongodb/mongodb.go

@@ -74,6 +74,9 @@ func (ms *MgoSess) C(name string) *MgoSess {
 }
 }
 
 
 func (ms *MgoSess) Find(q interface{}) *MgoSess {
 func (ms *MgoSess) Find(q interface{}) *MgoSess {
+	if q == nil {
+		q = map[string]interface{}{}
+	}
 	ms.query = q
 	ms.query = q
 	return ms
 	return ms
 }
 }

+ 13 - 0
src/qfw/util/mongodb/mongodb_test.go

@@ -95,3 +95,16 @@ func Test_del(t *testing.T) {
 	one := m.Del("test", nil)
 	one := m.Del("test", nil)
 	log.Println(one)
 	log.Println(one)
 }
 }
+func Test_itor(t *testing.T) {
+	m := &MongodbSim{
+		MongodbAddr: "192.168.3.128:27080",
+		Size:        5,
+		DbName:      "wcj",
+	}
+	m.InitPool()
+	sess := m.GetMgoConn()
+	it := sess.DB("wcj").C("test").Find(nil).Iter()
+	for m := make(map[string]interface{}); it.Next(&m); {
+		log.Println(m)
+	}
+}