Oleksiy Chechel

package main

import (
	"encoding/json"
	"fmt"
	"gopkg.in/mgo.v2"
)

type (
	obj map[string]interface{}
	arr []interface{}
)

func main() {
	mongo, err := mgo.Dial("localhost")
	if err != nil {
		panic(err)
	}

	info := []obj{}

	if err := mongo.DB("myDB").C("authors").Pipe(arr{
		obj{"$match": obj{"banned": false}},
		obj{"$lookup": obj{"from": "news", "localField": "_id", "foreignField": "authorID", "as": "news"}},
	}).All(&info); err != nil {
		fmt.Println("Error:", err)
	}

	printJSON(info)
}

func printJSON(t interface{}) {
	j, _ := json.MarshalIndent(t, "", "\t")
	fmt.Println(string(j))
}

package main

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

type (
	person struct {
		Name  string
		Phone string
	}
)

func main() {
	session, err := mgo.Dial("localhost")
	if err != nil {
		panic(err)
	}

	session.SetMode(mgo.Monotonic, true)
	col := session.DB("database").C("collection")

	count, _ := col.Count()
	fmt.Println(fmt.Sprintf("Messages count: %d", count))

	err = col.Insert(&person{Name: "TestName", Phone: "+365756765"})
}

> use database
switched to db database
> db.collection.find()
{ "_id" : ObjectId("56bf67529ac5b6a0afcbe7b4"), "name" : "TestName", "phone" : "+365756765" }
{ "_id" : ObjectId("56bf67569ac5b6a0afcbe7b5"), "name" : "TestName", "phone" : "+365756765" }
{ "_id" : ObjectId("56bf67589ac5b6a0afcbe7b6"), "name" : "TestName", "phone" : "+365756765" }
{ "_id" : ObjectId("56bf675a9ac5b6a0afcbe7b7"), "name" : "TestName", "phone" : "+365756765" }