demo
This commit is contained in:
@@ -9,31 +9,31 @@ func main() {
|
|||||||
c.Remove(c.Str("test.db"))
|
c.Remove(c.Str("test.db"))
|
||||||
|
|
||||||
db, err := sqlite.Open(c.Str("test.db"))
|
db, err := sqlite.Open(c.Str("test.db"))
|
||||||
check(err, "sqlite: OpenV2")
|
check(err, db, "sqlite: Open")
|
||||||
|
|
||||||
err = db.Exec(c.Str("CREATE TABLE foo (id INT, name TEXT)"), nil, nil, nil)
|
err = db.Exec(c.Str("CREATE TABLE users (id INTEGER PRIMARY KEY, name TEXT)"), nil, nil, nil)
|
||||||
check(err, "sqlite: Exec CREATE TABLE")
|
check(err, db, "sqlite: Exec CREATE TABLE")
|
||||||
|
|
||||||
stmt, err := db.PrepareV3("INSERT INTO foo (id, name) VALUES (?, ?)", 0, nil)
|
stmt, err := db.PrepareV3("INSERT INTO users (id, name) VALUES (?, ?)", 0, nil)
|
||||||
check(err, "sqlite: PrepareV3 INSERT")
|
check(err, db, "sqlite: PrepareV3 INSERT")
|
||||||
|
|
||||||
stmt.BindInt(1, 100)
|
stmt.BindInt(1, 100)
|
||||||
stmt.BindText(2, c.Str("Hello World"), -1, nil)
|
stmt.BindText(2, c.Str("Hello World"), -1, nil)
|
||||||
|
|
||||||
err = stmt.Step()
|
err = stmt.Step()
|
||||||
checkDone(err, "sqlite: Step INSERT 1")
|
checkDone(err, db, "sqlite: Step INSERT 1")
|
||||||
|
|
||||||
stmt.Reset()
|
stmt.Reset()
|
||||||
stmt.BindInt(1, 200)
|
stmt.BindInt(1, 200)
|
||||||
stmt.BindText(2, c.Str("This is llgo"), -1, nil)
|
stmt.BindText(2, c.Str("This is llgo"), -1, nil)
|
||||||
|
|
||||||
err = stmt.Step()
|
err = stmt.Step()
|
||||||
checkDone(err, "sqlite: Step INSERT 2")
|
checkDone(err, db, "sqlite: Step INSERT 2")
|
||||||
|
|
||||||
stmt.Close()
|
stmt.Close()
|
||||||
|
|
||||||
stmt, err = db.PrepareV3("SELECT * FROM foo", 0, nil)
|
stmt, err = db.PrepareV3("SELECT * FROM users", 0, nil)
|
||||||
check(err, "sqlite: PrepareV3 SELECT")
|
check(err, db, "sqlite: PrepareV3 SELECT")
|
||||||
|
|
||||||
for {
|
for {
|
||||||
if err = stmt.Step(); err != sqlite.HasRow {
|
if err = stmt.Step(); err != sqlite.HasRow {
|
||||||
@@ -41,21 +41,21 @@ func main() {
|
|||||||
}
|
}
|
||||||
c.Printf(c.Str("==> id=%d, name=%s\n"), stmt.ColumnInt(0), stmt.ColumnText(1))
|
c.Printf(c.Str("==> id=%d, name=%s\n"), stmt.ColumnInt(0), stmt.ColumnText(1))
|
||||||
}
|
}
|
||||||
checkDone(err, "sqlite: Step done")
|
checkDone(err, db, "sqlite: Step done")
|
||||||
|
|
||||||
stmt.Close()
|
stmt.Close()
|
||||||
db.Close()
|
db.Close()
|
||||||
}
|
}
|
||||||
|
|
||||||
func check(err sqlite.Errno, at string) {
|
func check(err sqlite.Errno, db *sqlite.Sqlite3, at string) {
|
||||||
if err != sqlite.OK {
|
if err != sqlite.OK {
|
||||||
c.Printf(c.Str("==> %s Error: (%d) %s\n"), c.AllocaCStr(at), err, err.Errstr())
|
c.Printf(c.Str("==> %s Error: (%d) %s\n"), c.AllocaCStr(at), err, db.Errmsg())
|
||||||
c.Exit(1)
|
c.Exit(1)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func checkDone(err sqlite.Errno, at string) {
|
func checkDone(err sqlite.Errno, db *sqlite.Sqlite3, at string) {
|
||||||
if err != sqlite.Done {
|
if err != sqlite.Done {
|
||||||
check(err, at)
|
check(err, db, at)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user