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
|
package tests
import (
r "gopkg.in/rethinkdb/rethinkdb-go.v6"
)
func setupTestData() {
if *testdata {
// Delete any preexisting databases
r.DBDrop("test").Exec(session)
r.DBDrop("examples").Exec(session)
r.DBDrop("superheroes").Exec(session)
r.DBCreate("test").Exec(session)
r.DBCreate("examples").Exec(session)
r.DB("test").TableCreate("test").Exec(session)
r.DB("test").TableCreate("test2").Exec(session)
r.DB("test").TableCreate("changes").Exec(session)
r.DB("examples").TableCreate("posts").Exec(session)
r.DB("examples").TableCreate("heroes").Exec(session)
r.DB("examples").TableCreate("users").Exec(session)
r.DB("examples").TableCreate("games").Exec(session)
r.DB("examples").TableCreate("games2").Exec(session)
r.DB("examples").TableCreate("marvel").Exec(session)
r.DB("examples").Table("posts").IndexCreate("date").Exec(session)
r.DB("examples").Table("posts").IndexWait().Exec(session)
r.DB("examples").Table("posts").IndexCreateFunc(
"dateAndTitle",
[]interface{}{r.Row.Field("date"), r.Row.Field("title")},
).Exec(session)
r.DB("examples").Table("heroes").IndexCreate("code_name").Exec(session)
r.DB("examples").Table("heroes").IndexWait().Exec(session)
r.DB("examples").Table("games").IndexCreate("type").Exec(session)
r.DB("examples").Table("games").IndexWait().Exec(session)
// Create heroes table
r.DB("examples").Table("heroes").Insert([]interface{}{
map[string]interface{}{
"id": 1,
"code_name": "batman",
"name": "Batman",
},
map[string]interface{}{
"id": 2,
"code_name": "man_of_steel",
"name": "Superman",
},
map[string]interface{}{
"id": 3,
"code_name": "ant_man",
"name": "Ant Man",
},
map[string]interface{}{
"id": 4,
"code_name": "flash",
"name": "The Flash",
},
}).Exec(session)
// Create users table
r.DB("examples").Table("users").Insert([]interface{}{
map[string]interface{}{
"id": "william",
"email": "william@rethinkdb.com",
"age": 30,
},
map[string]interface{}{
"id": "lara",
"email": "lara@rethinkdb.com",
"age": 30,
},
map[string]interface{}{
"id": "john",
"email": "john@rethinkdb.com",
"age": 19,
},
map[string]interface{}{
"id": "jane",
"email": "jane@rethinkdb.com",
"age": 45,
},
map[string]interface{}{
"id": "bob",
"email": "bob@rethinkdb.com",
"age": 24,
},
map[string]interface{}{
"id": "brad",
"email": "brad@gmail.com",
"age": 15,
},
}).Exec(session)
// Create games table
r.DB("examples").Table("games").Insert([]interface{}{
map[string]interface{}{"id": 2, "player": "Bob", "points": 15, "type": "ranked"},
map[string]interface{}{"id": 5, "player": "Alice", "points": 7, "type": "free"},
map[string]interface{}{"id": 11, "player": "Bob", "points": 10, "type": "free"},
map[string]interface{}{"id": 12, "player": "Alice", "points": 2, "type": "free"},
}).Exec(session)
// Create games2 table
r.DB("examples").Table("games2").Insert([]interface{}{
map[string]interface{}{"id": 1, "matches": map[string]interface{}{"a": []int{1, 2, 3}, "b": []int{4, 5, 6}}},
map[string]interface{}{"id": 2, "matches": map[string]interface{}{"b": []int{100}, "c": []int{7, 8, 9}}},
map[string]interface{}{"id": 3, "matches": map[string]interface{}{"a": []int{10, 20}, "c": []int{70, 80}}},
}).Exec(session)
// Create marvel table
r.DB("examples").Table("marvel").Insert([]interface{}{
map[string]interface{}{"name": "Iron Man", "victories": 214},
map[string]interface{}{"name": "Jubilee", "victories": 9},
}).Exec(session)
}
}
|
