Simple Example

package main

import (
    "encoding/json"
    "fmt"

    r "github.com/dancannon/gorethink"
)

var session *r.Session

// Struct tags are used to map struct fields to fields in the database
type Person struct {
    Id    string `gorethink:"id,omitempty"`
    Name  string `gorethink:"name"`
    Place string `gorethink:"place"`
}

func init() {
    var err error
    session, err = r.Connect(r.ConnectOpts{
        Address:  "localhost:28015",
        Database: "test",
    })
    if err != nil {
        fmt.Println(err)
        return
    }
}

func main() {
    // Create a table
    createTable()

    // Insert a record
    id := insertRecord()

    if id != "" {
        // Update a record
        updateRecord(id)
    }

    // Fetch one
    fetchOneRecord()

    // Record count
    recordCount()

    // Fetch all
    fetchAllRecords()

    if id != "" {
        // Delete a record
        deleteRecord(id)
    }
}

func createTable() {
    result, err := r.DB("test").TableCreate("people").RunWrite(session)
    if err != nil {
        fmt.Println(err)
    }

    printStr("*** Create table result: ***")
    printObj(result)
    printStr("\n")
}

func insertRecord() string {
    var data = map[string]interface{}{
        "Name":  "David Davidson",
        "Place": "Somewhere",
    }

    result, err := r.Table("people").Insert(data).RunWrite(session)
    if err != nil {
        fmt.Println(err)
        return ""
    }

    printStr("*** Insert result: ***")
    printObj(result)
    printStr("\n")

    return result.GeneratedKeys[0]
}

func updateRecord(id string) {
    var data = map[string]interface{}{
        "Name":  "Steve Stevenson",
        "Place": "Anywhere",
    }

    result, err := r.Table("people").Get(id).Update(data).RunWrite(session)
    if err != nil {
        fmt.Println(err)
        return
    }

    printStr("*** Update result: ***")
    printObj(result)
    printStr("\n")
}

func fetchOneRecord() {
    cursor, err := r.Table("people").Run(session)
    if err != nil {
        fmt.Println(err)
        return
    }

    var person interface{}
    cursor.One(&person)
    cursor.Close()

    printStr("*** Fetch one record: ***")
    printObj(person)
    printStr("\n")
}

func recordCount() {
    cursor, err := r.Table("people").Count().Run(session)
    if err != nil {
        fmt.Println(err)
        return
    }

    var cnt int
    cursor.One(&cnt)
    cursor.Close()

    printStr("*** Count: ***")
    printObj(cnt)
    printStr("\n")
}

func fetchAllRecords() {
    rows, err := r.Table("people").Run(session)
    if err != nil {
        fmt.Println(err)
        return
    }

    // Read records into persons slice
    var persons []Person
    err2 := rows.All(&persons)
    if err2 != nil {
        fmt.Println(err2)
        return
    }

    printStr("*** Fetch all rows: ***")
    for _, p := range persons {
        printObj(p)
    }
    printStr("\n")
}

func deleteRecord(id string) {
    result, err := r.Table("people").Get(id).Delete().Run(session)
    if err != nil {
        fmt.Println(err)
        return
    }

    printStr("*** Delete result: ***")
    printObj(result)
    printStr("\n")
}

func printStr(v string) {
    fmt.Println(v)
}
func printObj(v interface{}) {
    vBytes, _ := json.Marshal(v)
    fmt.Println(string(vBytes))
}