db

Documentation

Index

• Variables
• func CheckMongoSessionLost()
• func Count(collection *mgo.Collection, q interface{}) int
• func Delete(collection *mgo.Collection, q interface{}) bool
• func DeleteAll(collection *mgo.Collection, q interface{}) bool
• func DeleteAllByIdAndUserId(collection *mgo.Collection, id, userId string) bool
• func DeleteAllByIdAndUserId2(collection *mgo.Collection, id, userId bson.ObjectId) bool
• func DeleteByIdAndUserId(collection *mgo.Collection, id, userId string) bool
• func DeleteByIdAndUserId2(collection *mgo.Collection, id, userId bson.ObjectId) bool
• func Distinct(collection *mgo.Collection, q bson.M, field string, i interface{})
• func Err(err error) bool
• func Get(collection *mgo.Collection, id string, i interface{})
• func Get2(collection *mgo.Collection, id bson.ObjectId, i interface{})
• func GetByIdAndUserId(collection *mgo.Collection, id, userId string, i interface{})
• func GetByIdAndUserId2(collection *mgo.Collection, id, userId bson.ObjectId, i interface{})
• func GetByQ(collection *mgo.Collection, q interface{}, i interface{})
• func GetByQWithFields(collection *mgo.Collection, q bson.M, fields []string, i interface{})
• func GetIdAndUserIdBsonQ(id, userId bson.ObjectId) bson.M
• func GetIdAndUserIdQ(id, userId string) bson.M
• func Has(collection *mgo.Collection, q interface{}) bool
• func Init(url, dbname string)
• func Insert(collection *mgo.Collection, i interface{}) bool
• func ListByQ(collection *mgo.Collection, q interface{}, i interface{})
• func ListByQLimit(collection *mgo.Collection, q interface{}, i interface{}, limit int)
• func ListByQWithFields(collection *mgo.Collection, q bson.M, fields []string, i interface{})
• func Update(collection *mgo.Collection, query interface{}, i interface{}) bool
• func UpdateAll(collection *mgo.Collection, query interface{}, i interface{}) bool
• func UpdateByIdAndUserId(collection *mgo.Collection, id, userId string, i interface{}) bool
• func UpdateByIdAndUserId2(collection *mgo.Collection, id, userId bson.ObjectId, i interface{}) bool
• func UpdateByIdAndUserIdField(collection *mgo.Collection, id, userId, field string, value interface{}) bool
• func UpdateByIdAndUserIdField2(collection *mgo.Collection, id, userId bson.ObjectId, field string, ...) bool
• func UpdateByIdAndUserIdMap(collection *mgo.Collection, id, userId string, v bson.M) bool
• func UpdateByIdAndUserIdMap2(collection *mgo.Collection, id, userId bson.ObjectId, v bson.M) bool
• func UpdateByQField(collection *mgo.Collection, q interface{}, field string, value interface{}) bool
• func UpdateByQI(collection *mgo.Collection, q interface{}, v interface{}) bool
• func UpdateByQMap(collection *mgo.Collection, q interface{}, v interface{}) bool
• func Upsert(collection *mgo.Collection, query interface{}, i interface{}) bool

Variables

var Albums *mgo.Collection

Album & file(image)

var Attachs *mgo.Collection

var BlogComments *mgo.Collection

var BlogLikes *mgo.Collection

blog

var BlogSingles *mgo.Collection

var Blogs *mgo.Collection

var Configs *mgo.Collection

var EmailLogs *mgo.Collection

var Files *mgo.Collection

var GroupUsers *mgo.Collection

var Groups *mgo.Collection

var HasShareNotes *mgo.Collection

var NoteContentHistories *mgo.Collection

var NoteContents *mgo.Collection

var NoteImages *mgo.Collection

var NoteTags *mgo.Collection

var Notebooks *mgo.Collection

各个表的Collection对象

var Notes *mgo.Collection

var Reports *mgo.Collection

var Session *mgo.Session

数据连接

var Sessions *mgo.Collection

session

var ShareNotebooks *mgo.Collection

var ShareNotes *mgo.Collection

var Suggestions *mgo.Collection

var TagCounts *mgo.Collection

var Tags *mgo.Collection

var Themes *mgo.Collection

var Tokens *mgo.Collection

var UserBlogs *mgo.Collection

var Users *mgo.Collection

Functions

func CheckMongoSessionLost

func CheckMongoSessionLost()

检查mognodb是否lost connection 每个请求之前都要检查!!

func Count

func Count(collection *mgo.Collection, q interface{}) int

func Delete

func Delete(collection *mgo.Collection, q interface{}) bool

删除一条

func DeleteAll

func DeleteAll(collection *mgo.Collection, q interface{}) bool

func DeleteAllByIdAndUserId

func DeleteAllByIdAndUserId(collection *mgo.Collection, id, userId string) bool

删除所有

func DeleteAllByIdAndUserId2

func DeleteAllByIdAndUserId2(collection *mgo.Collection, id, userId bson.ObjectId) bool

func DeleteByIdAndUserId

func DeleteByIdAndUserId(collection *mgo.Collection, id, userId string) bool

func DeleteByIdAndUserId2

func DeleteByIdAndUserId2(collection *mgo.Collection, id, userId bson.ObjectId) bool

func Distinct

func Distinct(collection *mgo.Collection, q bson.M, field string, i interface{})

按field去重

func Err

func Err(err error) bool

DB处理错误

func Get

func Get(collection *mgo.Collection, id string, i interface{})

func Get2

func Get2(collection *mgo.Collection, id bson.ObjectId, i interface{})

func GetByIdAndUserId

func GetByIdAndUserId(collection *mgo.Collection, id, userId string, i interface{})

func GetByIdAndUserId2

func GetByIdAndUserId2(collection *mgo.Collection, id, userId bson.ObjectId, i interface{})

func GetByQ

func GetByQ(collection *mgo.Collection, q interface{}, i interface{})

func GetByQWithFields

func GetByQWithFields(collection *mgo.Collection, q bson.M, fields []string, i interface{})

查询某些字段, q是查询条件, fields是字段名列表

func GetIdAndUserIdBsonQ

func GetIdAndUserIdBsonQ(id, userId bson.ObjectId) bson.M

func GetIdAndUserIdQ

func GetIdAndUserIdQ(id, userId string) bson.M

得到主键和userId的复合查询条件

func Has

func Has(collection *mgo.Collection, q interface{}) bool

func Init

func Init(url, dbname string)

初始化时连接数据库

func Insert

func Insert(collection *mgo.Collection, i interface{}) bool

func ListByQ

func ListByQ(collection *mgo.Collection, q interface{}, i interface{})

func ListByQLimit

func ListByQLimit(collection *mgo.Collection, q interface{}, i interface{}, limit int)

func ListByQWithFields

func ListByQWithFields(collection *mgo.Collection, q bson.M, fields []string, i interface{})

查询某些字段, q是查询条件, fields是字段名列表

func Update

func Update(collection *mgo.Collection, query interface{}, i interface{}) bool

适合一条记录全部更新

func UpdateAll

func UpdateAll(collection *mgo.Collection, query interface{}, i interface{}) bool

func UpdateByIdAndUserId

func UpdateByIdAndUserId(collection *mgo.Collection, id, userId string, i interface{}) bool

func UpdateByIdAndUserId2

func UpdateByIdAndUserId2(collection *mgo.Collection, id, userId bson.ObjectId, i interface{}) bool

func UpdateByIdAndUserIdField

func UpdateByIdAndUserIdField(collection *mgo.Collection, id, userId, field string, value interface{}) bool

func UpdateByIdAndUserIdField2

func UpdateByIdAndUserIdField2(collection *mgo.Collection, id, userId bson.ObjectId, field string, value interface{}) bool

func UpdateByIdAndUserIdMap

func UpdateByIdAndUserIdMap(collection *mgo.Collection, id, userId string, v bson.M) bool

func UpdateByIdAndUserIdMap2

func UpdateByIdAndUserIdMap2(collection *mgo.Collection, id, userId bson.ObjectId, v bson.M) bool

func UpdateByQField

func UpdateByQField(collection *mgo.Collection, q interface{}, field string, value interface{}) bool

func UpdateByQI

func UpdateByQI(collection *mgo.Collection, q interface{}, v interface{}) bool

func UpdateByQMap

func UpdateByQMap(collection *mgo.Collection, q interface{}, v interface{}) bool

查询条件和值

func Upsert

func Upsert(collection *mgo.Collection, query interface{}, i interface{}) bool