db

Documentation

Index

• Variables
• func GetUserData(mapParams map[string]interface{}) (types.UserData, error)
• func RegisterUser(userData types.UserData) error
• type DB
  • func Connect() (*DB, error)
  • func (db *DB) Insert(obj interface{}, collection string) error
  • func (db *DB) Search(query bson.M, selectors []string, collection string, obj interface{}) error
  • func (db *DB) SearchOne(query bson.M, selectors []string, collection string, obj interface{}) error
  • func (db *DB) Update(query, updateQuery interface{}, collection string) error
  • func (db *DB) UpdateAll(query, updateQuery interface{}, collection string) error
  • func (db *DB) Upsert(query bson.M, obj interface{}, collection string) (*mgo.ChangeInfo, error)
• type Database

Variables

var (
	UserCollection = "users"
)

Collections names used in MongoDB.

Functions

func GetUserData

func GetUserData(mapParams map[string]interface{}) (types.UserData, error)

GetUserData queries MongoDB and returns user's data based on its username.

func RegisterUser

func RegisterUser(userData types.UserData) error

RegisterUser regisiter into MongoDB a new user and returns an error.

Types

type DB

type DB struct {
	Session *mgo.Session
}

DB is the struct that represents mongo session.

func Connect

func Connect() (*DB, error)

Connect connects to mongo and returns the session.

func (*DB) Insert

func (db *DB) Insert(obj interface{}, collection string) error

Insert inserts a new document.

func (*DB) Search

func (db *DB) Search(query bson.M, selectors []string, collection string, obj interface{}) error

Search searchs all documents that match the query. If selectors are present, the return will be only the chosen fields.

func (*DB) SearchOne

func (db *DB) SearchOne(query bson.M, selectors []string, collection string, obj interface{}) error

SearchOne searchs for the first element that matchs with the given query.

func (*DB) Update

func (db *DB) Update(query, updateQuery interface{}, collection string) error

Update updates a single document.

func (*DB) UpdateAll

func (db *DB) UpdateAll(query, updateQuery interface{}, collection string) error

UpdateAll updates all documents that match the query.

func (*DB) Upsert

func (db *DB) Upsert(query bson.M, obj interface{}, collection string) (*mgo.ChangeInfo, error)

Upsert inserts a document or update it if it already exists.

type Database

type Database interface {
	Insert(obj interface{}, collection string) error
	Search(query bson.M, selectors []string, collection string, obj interface{}) error
	Update(query bson.M, updateQuery interface{}, collection string) error
	UpdateAll(query, updateQuery bson.M, collection string) error
	Upsert(query bson.M, obj interface{}, collection string) (*mgo.ChangeInfo, error)
	SearchOne(query bson.M, selectors []string, collection string, obj interface{}) error
}

Database is the interface's database.