diff options
author | mattn <mattn.jp@gmail.com> | 2013-08-28 14:50:02 +0900 |
---|---|---|
committer | mattn <mattn.jp@gmail.com> | 2013-08-28 14:50:02 +0900 |
commit | 501b1ea772a8ad6a5126ab5a1307da4b3e613ade (patch) | |
tree | 98605d164a415dd14ef632cae1c112c59d71a893 /_example/simple | |
parent | Use sqlite3.c in all platforms (diff) | |
download | golite-501b1ea772a8ad6a5126ab5a1307da4b3e613ade.tar.gz golite-501b1ea772a8ad6a5126ab5a1307da4b3e613ade.tar.xz |
mv
Diffstat (limited to '_example/simple')
-rw-r--r-- | _example/simple/simple.go | 95 |
1 files changed, 95 insertions, 0 deletions
diff --git a/_example/simple/simple.go b/_example/simple/simple.go new file mode 100644 index 0000000..5e9c902 --- /dev/null +++ b/_example/simple/simple.go @@ -0,0 +1,95 @@ +package main + +import ( + "database/sql" + "fmt" + _ "github.com/mattn/go-sqlite3" + "log" + "os" +) + +func main() { + os.Remove("./foo.db") + + db, err := sql.Open("sqlite3", "./foo.db") + if err != nil { + log.Fatal(err) + } + defer db.Close() + + sqls := []string{ + "create table foo (id integer not null primary key, name text)", + "delete from foo", + } + for _, sql := range sqls { + _, err = db.Exec(sql) + if err != nil { + log.Printf("%q: %s\n", err, sql) + return + } + } + + tx, err := db.Begin() + if err != nil { + log.Fatal(err) + } + stmt, err := tx.Prepare("insert into foo(id, name) values(?, ?)") + if err != nil { + log.Fatal(err) + } + defer stmt.Close() + for i := 0; i < 100; i++ { + _, err = stmt.Exec(i, fmt.Sprintf("こんにちわ世界%03d", i)) + if err != nil { + log.Fatal(err) + } + } + tx.Commit() + + rows, err := db.Query("select id, name from foo") + if err != nil { + log.Fatal(err) + } + defer rows.Close() + for rows.Next() { + var id int + var name string + rows.Scan(&id, &name) + fmt.Println(id, name) + } + rows.Close() + + stmt, err = db.Prepare("select name from foo where id = ?") + if err != nil { + log.Fatal(err) + } + defer stmt.Close() + var name string + err = stmt.QueryRow("3").Scan(&name) + if err != nil { + log.Fatal(err) + } + fmt.Println(name) + + _, err = db.Exec("delete from foo") + if err != nil { + log.Fatal(err) + } + + _, err = db.Exec("insert into foo(id, name) values(1, 'foo'), (2, 'bar'), (3, 'baz')") + if err != nil { + log.Fatal(err) + } + + rows, err = db.Query("select id, name from foo") + if err != nil { + log.Fatal(err) + } + defer rows.Close() + for rows.Next() { + var id int + var name string + rows.Scan(&id, &name) + fmt.Println(id, name) + } +} |