Mongo Mgo Cheat Sheet

conn.go

func mgoSession() *mgo.Session {
	uri := "127.0.0.1"
	if uri == "" {
		fmt.Println("no connection string provided")
		os.Exit(1)
	}

	sess, err := mgo.Dial(uri)
	if err != nil {
		fmt.Printf("Can't connect to mongo, go error %v\n", err)
		os.Exit(1)
	}
	// defer sess.Close()

	return sess
}

insert.go

sess := mgoSession()

collection := sess.DB("db").C("collection")
collection.Insert(&offer)

query_find.go

sess := mgoSession()

sess.DB("db").C("collection").
		Find(bson.M{"items": bson.M{"$elemMatch": bson.M{"name": item}}}).
		All(&oL)