forked from rethinkdb/rethinkdb-go
-
Notifications
You must be signed in to change notification settings - Fork 0
/
example_query_select_test.go
129 lines (111 loc) · 2.67 KB
/
example_query_select_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
package gorethink
import (
"fmt"
)
// Find a document by ID.
func ExampleTerm_Get() {
// Fetch the row from the database
res, err := DB("examples").Table("heroes").Get(2).Run(session)
if err != nil {
fmt.Print(err)
return
}
defer res.Close()
if res.IsNil() {
fmt.Print("Row not found")
return
}
var hero map[string]interface{}
err = res.One(&hero)
if err != nil {
fmt.Print("Error scanning database result: %s", err)
return
}
fmt.Print(hero["name"])
// Output: Superman
}
// Find a document and merge another document with it.
func ExampleTerm_Get_merge() {
// Fetch the row from the database
res, err := DB("examples").Table("heroes").Get(4).Merge(map[string]interface{}{
"powers": []string{"speed"},
}).Run(session)
if err != nil {
fmt.Print(err)
return
}
defer res.Close()
if res.IsNil() {
fmt.Print("Row not found")
return
}
var hero map[string]interface{}
err = res.One(&hero)
if err != nil {
fmt.Print("Error scanning database result: %s", err)
return
}
fmt.Printf("%s: %v", hero["name"], hero["powers"])
// Output: The Flash: [speed]
}
// Get all users who are 30 years old.
func ExampleTerm_Filter() {
// Fetch the row from the database
res, err := DB("examples").Table("users").Filter(map[string]interface{}{
"age": 30,
}).Run(session)
if err != nil {
fmt.Print(err)
return
}
defer res.Close()
// Scan query result into the person variable
var users []interface{}
err = res.All(&users)
if err != nil {
fmt.Print("Error scanning database result: %s", err)
return
}
fmt.Printf("%d users", len(users))
// Output: 2 users
}
// Get all users who are more than 25 years old.
func ExampleTerm_Filter_row() {
// Fetch the row from the database
res, err := DB("examples").Table("users").Filter(Row.Field("age").Gt(25)).Run(session)
if err != nil {
fmt.Print(err)
return
}
defer res.Close()
// Scan query result into the person variable
var users []interface{}
err = res.All(&users)
if err != nil {
fmt.Print("Error scanning database result: %s", err)
return
}
fmt.Printf("%d users", len(users))
// Output: 3 users
}
// Retrieve all users who have a gmail account (whose field email ends with @gmail.com).
func ExampleTerm_Filter_function() {
// Fetch the row from the database
res, err := DB("examples").Table("users").Filter(func(user Term) Term {
return user.Field("email").Match("@gmail.com$")
}).Run(session)
if err != nil {
fmt.Print(err)
return
}
defer res.Close()
// Scan query result into the person variable
var users []interface{}
err = res.All(&users)
if err != nil {
fmt.Print("Error scanning database result: %s", err)
return
}
fmt.Printf("%d users", len(users))
// Output: 1 users
}