|
@@ -94,7 +94,7 @@ func (m *MongodbSim) Update(c string, query interface{}, set interface{}, upsert
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
if nil != err {
|
|
if nil != err {
|
|
|
- log.Println("CountError", err)
|
|
|
|
|
|
|
+ log.Println("UpdateError", err)
|
|
|
b = false
|
|
b = false
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -130,7 +130,7 @@ func (m *MongodbSim) Save(c string, doc interface{}) string {
|
|
|
sess := m.GetMgoConn()
|
|
sess := m.GetMgoConn()
|
|
|
if sess != nil {
|
|
if sess != nil {
|
|
|
defer m.DestoryMongoConn(sess)
|
|
defer m.DestoryMongoConn(sess)
|
|
|
- coll := sess.DB(DB).C(c)
|
|
|
|
|
|
|
+ coll := sess.DB(m.DbName).C(c)
|
|
|
obj := ObjToM(doc)
|
|
obj := ObjToM(doc)
|
|
|
id := NewObjectId()
|
|
id := NewObjectId()
|
|
|
(*obj)["_id"] = id
|
|
(*obj)["_id"] = id
|
|
@@ -168,7 +168,7 @@ func (m *MongodbSim) FindById(c string, query string, fields interface{}) *map[s
|
|
|
if sess != nil {
|
|
if sess != nil {
|
|
|
defer m.DestoryMongoConn(sess)
|
|
defer m.DestoryMongoConn(sess)
|
|
|
res = make(map[string]interface{})
|
|
res = make(map[string]interface{})
|
|
|
- coll := sess.DB(DB).C(c)
|
|
|
|
|
|
|
+ coll := sess.DB(m.DbName).C(c)
|
|
|
var err error
|
|
var err error
|
|
|
err = coll.FindId(ObjectIdHex(query)).Select(ObjToOth(fields)).One(&res)
|
|
err = coll.FindId(ObjectIdHex(query)).Select(ObjToOth(fields)).One(&res)
|
|
|
if nil != err {
|
|
if nil != err {
|
|
@@ -186,7 +186,7 @@ func (m *MongodbSim) Find(c string, query interface{}, order interface{}, fields
|
|
|
if sess != nil {
|
|
if sess != nil {
|
|
|
defer m.DestoryMongoConn(sess)
|
|
defer m.DestoryMongoConn(sess)
|
|
|
res = make([]map[string]interface{}, 1)
|
|
res = make([]map[string]interface{}, 1)
|
|
|
- coll := sess.DB(DB).C(c)
|
|
|
|
|
|
|
+ coll := sess.DB(m.DbName).C(c)
|
|
|
var err error
|
|
var err error
|
|
|
if single {
|
|
if single {
|
|
|
err = coll.Find(ObjToM(query)).Select(ObjToOth(fields)).One(&res[0])
|
|
err = coll.Find(ObjToM(query)).Select(ObjToOth(fields)).One(&res[0])
|
