Simple Example

package main

import (
	"fmt"
	"encoding/json"
	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))
}