-
Notifications
You must be signed in to change notification settings - Fork 0
/
utils.go
134 lines (114 loc) · 2.09 KB
/
utils.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
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
package main
import (
"database/sql"
_ "github.com/lib/pq"
"os"
"fmt"
"flag"
)
var (
user = flag.String("user", "postgres", "the database user")
password = flag.String("password", "postgres", "the database password")
port *int = flag.Int("port", 5432, "the database port")
server = flag.String("server", "192.168.200.10", "the database server")
database = flag.String("database", "test", "the database")
connString string
)
// grom, pg
type User struct {
Id int
Name string
Address string
Tel string
Age string
}
// genmai
type Users struct {
Id int
Name string
Address string
Tel string
Age string
}
func checkErr(err error) {
if err != nil {
fmt.Println(err)
os.Exit(2)
}
}
func initDB() {
sqls := []string{
`DROP TABLE IF EXISTS users;`,
`CREATE TABLE users (
id SERIAL NOT NULL,
name text NOT NULL,
address text NOT NULL,
tel text NOT NULL,
age integer NOT NULL,
CONSTRAINT users_pkey PRIMARY KEY (id)
) WITH (OIDS=FALSE);`,
}
DB, err := sql.Open("postgres", connString)
checkErr(err)
defer DB.Close()
err = DB.Ping()
checkErr(err)
for _, sql := range sqls {
_, err = DB.Exec(sql)
checkErr(err)
}
insert :=
`INSERT INTO users (
name,
address,
tel,
age
) VALUES (
'ORM benchmark',
'Tokyo, Japan',
90012345678,
100
)`;
for i := 1; i < 100000; i++ {
_, err = DB.Exec(insert)
checkErr(err)
}
}
func initDB2() {
sqls := []string{
`DROP TABLE IF EXISTS test;`,
`CREATE TABLE test (
id SERIAL NOT NULL,
name text NOT NULL,
address text NOT NULL,
tel text NOT NULL,
age integer NOT NULL,
CONSTRAINT test_pkey PRIMARY KEY (id)
) WITH (OIDS=FALSE);`,
}
DB, err := sql.Open("postgres", connString)
checkErr(err)
defer DB.Close()
err = DB.Ping()
checkErr(err)
for _, sql := range sqls {
_, err = DB.Exec(sql)
checkErr(err)
}
insert :=
`INSERT INTO test (
name,
address,
tel,
age
) VALUES (
'ORM benchmark',
'Tokyo, Japan',
90012345678,
100
)`;
for i := 1; i < 100000; i++ {
_, err = DB.Exec(insert)
checkErr(err)
}
}