forked from gocraft/dbr
-
Notifications
You must be signed in to change notification settings - Fork 0
/
example_test.go
162 lines (136 loc) · 3.55 KB
/
example_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
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
package dbr
import (
"fmt"
"time"
)
func ExampleOpen() {
// create a connection (e.g. "postgres", "mysql", or "sqlite3")
conn, _ := Open("postgres", "...", nil)
conn.SetMaxOpenConns(10)
// create a session for each business unit of execution (e.g. a web request or goworkers job)
sess := conn.NewSession(nil)
// create a tx from sessions
sess.Begin()
}
func ExampleSelect() {
Select("title", "body").
From("suggestions").
OrderBy("id").
Limit(10)
}
func ExampleSelectBySql() {
SelectBySql("SELECT `title`, `body` FROM `suggestions` ORDER BY `id` ASC LIMIT 10")
}
func ExampleSelectStmt_Load() {
// columns are mapped by tag then by field
type Suggestion struct {
ID int64 // id, will be autoloaded by last insert id
Title NullString `db:"subject"` // subjects are called titles now
Url string `db:"-"` // ignored
secret string // ignored
}
// By default gocraft/dbr converts CamelCase property names to snake_case column_names.
// You can override this with struct tags, just like with JSON tags.
// This is especially helpful while migrating from legacy systems.
var suggestions []Suggestion
sess := mysqlSession
sess.Select("*").From("suggestions").Load(&suggestions)
}
func ExampleSelectStmt_Where() {
// database/sql uses prepared statements, which means each argument
// in an IN clause needs its own question mark.
// gocraft/dbr, on the other hand, handles interpolation itself
// so that you can easily use a single question mark paired with a
// dynamically sized slice.
sess := mysqlSession
ids := []int64{1, 2, 3, 4, 5}
sess.Select("*").From("suggestions").Where("id IN ?", ids)
}
func ExampleSelectStmt_Join() {
sess := mysqlSession
sess.Select("*").From("suggestions").
Join("subdomains", "suggestions.subdomain_id = subdomains.id")
sess.Select("*").From("suggestions").
LeftJoin("subdomains", "suggestions.subdomain_id = subdomains.id")
// join multiple tables
sess.Select("*").From("suggestions").
Join("subdomains", "suggestions.subdomain_id = subdomains.id").
Join("accounts", "subdomains.accounts_id = accounts.id")
}
func ExampleSelectStmt_As() {
sess := mysqlSession
sess.Select("count(id)").From(
Select("*").From("suggestions").As("count"),
)
}
func ExampleInsertStmt_Pair() {
sess := mysqlSession
sess.InsertInto("suggestions").
Pair("title", "Gopher").
Pair("body", "I love go.")
}
func ExampleInsertStmt_Record() {
type Suggestion struct {
ID int64
Title NullString
CreatedAt time.Time
}
sugg := &Suggestion{
Title: NewNullString("Gopher"),
CreatedAt: time.Now(),
}
sess := mysqlSession
sess.InsertInto("suggestions").
Columns("title").
Record(&sugg).
Exec()
// id is set automatically
fmt.Println(sugg.ID)
}
func ExampleUpdateStmt() {
sess := mysqlSession
sess.Update("suggestions").
Set("title", "Gopher").
Set("body", "I love go.").
Where("id = ?", 1)
}
func ExampleDeleteStmt() {
sess := mysqlSession
sess.DeleteFrom("suggestions").
Where("id = ?", 1)
}
func ExampleTx() {
sess := mysqlSession
tx, err := sess.Begin()
if err != nil {
return
}
defer tx.RollbackUnlessCommitted()
// do stuff...
tx.Commit()
}
func ExampleAnd() {
And(
Or(
Gt("created_at", "2015-09-10"),
Lte("created_at", "2015-09-11"),
),
Eq("title", "hello world"),
)
}
func ExampleI() {
// I, identifier, can be used to quote.
I("suggestions.id").As("id") // `suggestions`.`id`
}
func ExampleUnion() {
Union(
Select("*"),
Select("*"),
).As("subquery")
}
func ExampleUnionAll() {
UnionAll(
Select("*"),
Select("*"),
).As("subquery")
}