pixeldrain/gocqlx
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

example use query rebind

Browse Source
This commit is contained in:
Michał Matczuk
2017-07-25 11:08:53 +02:00
parent 51c33ef077
commit 9676daf60d
1 changed files with 20 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
example_test.go
View File

@@ -42,20 +42,32 @@ func TestExample(t *testing.T) {
session := createSession(t) session := createSession(t)
defer session.Close() defer session.Close()
// Exec the schema or fail
mustExec := func(q *gocql.Query) { mustExec := func(q *gocql.Query) {
if err := q.Exec(); err != nil { if err := q.Exec(); err != nil {
t.Fatal("insert:", q, err) t.Fatal("insert:", q, err)
} }
} }
// Fill person table
{
mustExec(session.Query(personSchema)) mustExec(session.Query(personSchema))
q := session.Query("INSERT INTO gocqlx_test.person (first_name, last_name, email) VALUES (?, ?, ?)")
mustExec(q.Bind("Jason", "Moiron", []string{"jmoiron@jmoiron.net"}))
mustExec(q.Bind("John", "Doe", []string{"johndoeDNE@gmail.net"}))
q.Release()
}
// Fill place table
{
mustExec(session.Query(placeSchema)) mustExec(session.Query(placeSchema))
mustExec(session.Query("INSERT INTO gocqlx_test.person (first_name, last_name, email) VALUES (?, ?, ?)", "Jason", "Moiron", []string{"jmoiron@jmoiron.net"})) q := session.Query("INSERT INTO gocqlx_test.place (country, city, telcode) VALUES (?, ?, ?)")
mustExec(session.Query("INSERT INTO gocqlx_test.person (first_name, last_name, email) VALUES (?, ?, ?)", "John", "Doe", []string{"johndoeDNE@gmail.net"})) mustExec(q.Bind("United States", "New York", 1))
mustExec(session.Query("INSERT INTO gocqlx_test.place (country, city, telcode) VALUES (?, ?, ?)", "United States", "New York", 1)) mustExec(q.Bind("Hong Kong", "", 852))
mustExec(session.Query("INSERT INTO gocqlx_test.place (country, city, telcode) VALUES (?, ?, ?)", "Hong Kong", "", 852)) mustExec(q.Bind("Singapore", "", 65))
mustExec(session.Query("INSERT INTO gocqlx_test.place (country, city, telcode) VALUES (?, ?, ?)", "Singapore", "", 65)) q.Release()
}
// TODO // TODO
// tx.NamedExec("INSERT INTO person (first_name, last_name, email) VALUES (:first_name, :last_name, :email)", &Person{"Jane", "Citizen", "jane.citzen@gocqlx_test.com"}) // tx.NamedExec("INSERT INTO person (first_name, last_name, email) VALUES (:first_name, :last_name, :email)", &Person{"Jane", "Citizen", "jane.citzen@gocqlx_test.com"})