bulk.go

package main

import (
	"fmt"
	"strconv"
	"time"

	mgo "gopkg.in/mgo.v2"
	"gopkg.in/mgo.v2/bson"
)

type Person struct {
	ID        bson.ObjectId `bson:"_id,omitempty"`
	Name      string
	Phone     string
	Timestamp time.Time
}

var (
	IsDrop = true
)

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

	defer session.Close()

	session.SetMode(mgo.Monotonic, true)

	// Drop Database
	if IsDrop {
		err = session.DB("test").DropDatabase()
		if err != nil {
			panic(err)
		}
	}

	// Collection People
	c := session.DB("test").C("people")

	// Index
	index := mgo.Index{
		Key:        []string{"name", "phone"},
		Unique:     true,
		DropDups:   true,
		Background: true,
		Sparse:     true,
	}

	err = c.EnsureIndex(index)
	if err != nil {
		panic(err)
	}

	people := make([]Person, 5)
	for i := 0; i < 5; i++ {
		phone := "+55 53 1234 4321" + strconv.Itoa(i)
		people[i] = Person{
			Name: "Ale", Phone: phone, Timestamp: time.Now()}
	}

	bulk := c.Bulk()
	bulk.Unordered()
	bulk.Insert(&people)
	_, err = bulk.Run()

	if err != nil {
		fmt.Println(err)

	}
}