package main

import (
	mgo "gopkg.in/mgo.v2"
)

func getSession() (*mgo.Session, error) {
	session, err := mgo.Dial("mongodb://" + config.Mongodb.IP)
	if err != nil {
		panic(err)
	}
	//defer session.Close()

	// Optional. Switch the session to a monotonic behavior.
	session.SetMode(mgo.Monotonic, true)

	// Optional. Switch the session to a monotonic behavior.
	session.SetMode(mgo.Monotonic, true)

	return session, err
}
func getCollection(session *mgo.Session, collection string) *mgo.Collection {

	c := session.DB(config.Mongodb.Database).C(collection)
	return c
}