mongohqconnect.go

mongohqconnect.go

package main
 
import (
        "fmt"
        "gopkg.in/mgo.v2"
        "gopkg.in/mgo.v2/bson"
        "log"
        "os"
)
 
type Person struct {
        Name string
        Email string
}
 
func main() {
        // Do the following:
        // In a command window:
        // set MONGOLAB_URL=mongodb://IndianGuru:[email protected]:51523/godata
        // IndianGuru is my username, replace the same with yours. Type in your password.
        uri := os.Getenv("MONGOLAB_URL")
        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()
        
        sess.SetSafe(&mgo.Safe{})
        
        collection := sess.DB("godata").C("user")

        err = collection.Insert(&Person{"Stefan Klaste", "[email protected]"},
	                        &Person{"Nishant Modak", "[email protected]"},
	                        &Person{"Prathamesh Sonpatki", "[email protected]"},
	                        &Person{"murtuza kutub", "[email protected]"},
	                        &Person{"aniket joshi", "[email protected]"},
	                        &Person{"Michael de Silva", "[email protected]"},
	                        &Person{"Alejandro Cespedes Vicente", "[email protected]"})
        if err != nil {
                log.Fatal("Problem inserting data: ", err)
                return
        }

        result := Person{}
        err = collection.Find(bson.M{"name": "Prathamesh Sonpatki"}).One(&result)
        if err != nil {
                log.Fatal("Error finding record: ", err)
                return
        }

        fmt.Println("Email Id:", result.Email)
}