-
-
Notifications
You must be signed in to change notification settings - Fork 13
/
example_test.go
96 lines (84 loc) · 1.96 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
package readervfs_test
import (
"database/sql"
"fmt"
"log"
"strings"
_ "embed"
_ "github.com/ncruces/go-sqlite3/driver"
_ "github.com/ncruces/go-sqlite3/embed"
"github.com/ncruces/go-sqlite3/util/ioutil"
"github.com/ncruces/go-sqlite3/vfs/readervfs"
"github.com/psanford/httpreadat"
)
//go:embed testdata/test.db
var testDB string
func Example_http() {
readervfs.Create("demo.db", httpreadat.New("https://sanford.io/demo.db"))
defer readervfs.Delete("demo.db")
db, err := sql.Open("sqlite3", "file:demo.db?vfs=reader")
if err != nil {
log.Fatal(err)
}
defer db.Close()
magname := map[int]string{
3: "thousand",
6: "million",
9: "billion",
}
rows, err := db.Query(`
SELECT period, data_value, magntude, units FROM csv
WHERE period > '2010'
LIMIT 10`)
if err != nil {
log.Fatal(err)
}
defer rows.Close()
for rows.Next() {
var period, units string
var value int64
var mag int
err = rows.Scan(&period, &value, &mag, &units)
if err != nil {
log.Fatal(err)
}
fmt.Printf("%s: %d %s %s\n", period, value, magname[mag], units)
}
// Output:
// 2010.03: 17463 million Dollars
// 2010.06: 17260 million Dollars
// 2010.09: 15419 million Dollars
// 2010.12: 17088 million Dollars
// 2011.03: 18516 million Dollars
// 2011.06: 18835 million Dollars
// 2011.09: 16390 million Dollars
// 2011.12: 18748 million Dollars
// 2012.03: 18477 million Dollars
// 2012.06: 18270 million Dollars
}
func Example_embed() {
readervfs.Create("test.db", ioutil.NewSizeReaderAt(strings.NewReader(testDB)))
defer readervfs.Delete("test.db")
db, err := sql.Open("sqlite3", "file:test.db?vfs=reader")
if err != nil {
log.Fatal(err)
}
defer db.Close()
rows, err := db.Query(`SELECT id, name FROM users`)
if err != nil {
log.Fatal(err)
}
defer rows.Close()
for rows.Next() {
var id, name string
err = rows.Scan(&id, &name)
if err != nil {
log.Fatal(err)
}
fmt.Printf("%s %s\n", id, name)
}
// Output:
// 0 go
// 1 zig
// 2 whatever
}