From 64bbe6202c7977066bb9d6c81751b0f0fdd184cc Mon Sep 17 00:00:00 2001 From: Yasuhiro Matsumoto Date: Thu, 25 Jan 2024 22:12:05 +0900 Subject: [PATCH] add example --- _example/json/json.go | 81 +++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 81 insertions(+) create mode 100644 _example/json/json.go diff --git a/_example/json/json.go b/_example/json/json.go new file mode 100644 index 00000000..181934b9 --- /dev/null +++ b/_example/json/json.go @@ -0,0 +1,81 @@ +package main + +import ( + "database/sql" + "database/sql/driver" + "encoding/json" + "fmt" + _ "github.com/mattn/go-sqlite3" + "log" + "os" +) + +type Tag struct { + Name string `json:"name"` + Country string `json:"country"` +} + +func (t *Tag) Scan(value interface{}) error { + return json.Unmarshal([]byte(value.(string)), t) +} + +func (t *Tag) Value() (driver.Value, error) { + b, err := json.Marshal(t) + return string(b), err +} + +func main() { + os.Remove("./foo.db") + + db, err := sql.Open("sqlite3", "./foo.db") + if err != nil { + log.Fatal(err) + } + defer db.Close() + + _, err = db.Exec(`create table foo (tag jsonb)`) + if err != nil { + log.Fatal(err) + } + + stmt, err := db.Prepare("insert into foo(tag) values(?)") + if err != nil { + log.Fatal(err) + } + defer stmt.Close() + _, err = stmt.Exec(`{"name": "mattn", "country": "japan"}`) + if err != nil { + log.Fatal(err) + } + _, err = stmt.Exec(`{"name": "michael", "country": "usa"}`) + if err != nil { + log.Fatal(err) + } + + var country string + err = db.QueryRow("select tag->>'country' from foo where tag->>'name' = 'mattn'").Scan(&country) + if err != nil { + log.Fatal(err) + } + fmt.Println(country) + + var tag Tag + err = db.QueryRow("select tag from foo where tag->>'name' = 'mattn'").Scan(&tag) + if err != nil { + log.Fatal(err) + } + + fmt.Println(tag.Name) + + tag.Country = "日本" + _, err = db.Exec(`update foo set tag = ? where tag->>'name' == 'mattn'`, &tag) + if err != nil { + log.Fatal(err) + } + + err = db.QueryRow("select tag->>'country' from foo where tag->>'name' = 'mattn'").Scan(&country) + if err != nil { + log.Fatal(err) + } + fmt.Println(country) +}