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)) }