bench_mongo.go

package main

import (
        "time"
        "github.com/globalsign/mgo"
        "time"
        "github.com/globalsign/mgo"
)


func initDb() (*mgo.Session, error) {
        session, err := mgo.Dial("mongodb://localhost:27017/")
        if err != nil {
                return nil, err
        }

        return session, nil
}

func main() {
        session, err := initDb()
        if err != nil {
                println(err.Error())
        }

        doc := map[string]interface{}{"type" : "done", "order_id" : "a5cce297-3533-4032-917a-98e7cee4820b", "reason" :r}

        start := time.Now()
        for i := 0; i < 1000; i++ {
                err := session.DB("test_bench").C("TEST2").Insert(doc)
                if err != nil {
                        println(err.Error())
                }
        }
        elapsed := time.Since(start)
        println(elapsed);
}