forked from go-reform/reform
-
Notifications
You must be signed in to change notification settings - Fork 0
/
cmd_query.go
83 lines (75 loc) · 2.09 KB
/
cmd_query.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
package main
import (
"bytes"
"flag"
"fmt"
"os"
"strings"
"text/tabwriter"
"gopkg.in/reform.v1"
)
var (
queryFlags = flag.NewFlagSet("query", flag.ExitOnError)
)
func init() {
queryFlags.Usage = func() {
fmt.Fprintf(os.Stderr, "`query` command executes SQL queries from given files or stdin, and returns results.\n\n")
fmt.Fprintf(os.Stderr, "Usage:\n")
fmt.Fprintf(os.Stderr, " %s [global flags] query [file names]\n\n", os.Args[0])
fmt.Fprintf(os.Stderr, "Global flags:\n")
flag.PrintDefaults()
queryFlags.PrintDefaults()
fmt.Fprintf(os.Stderr, `
Each file's content is executed as a single query. If it contains multiple
statements, make sure SQL driver supports them. If file names are not given,
a query is read from stdin until EOF, then executed.
`)
}
}
// cmdQuery implements query command.
func cmdQuery(db *reform.DB, files []string) {
queries := readFiles(files)
for _, q := range queries {
rows, err := db.Query(q)
if err != nil {
logger.Fatalf("failed to query %s: %s", q, err)
}
columns, err := rows.Columns()
if err != nil {
logger.Fatalf("failed to get columns for %s: %s", q, err)
}
logger.Debugf("result columns: %v", columns)
// write table header
w := tabwriter.NewWriter(os.Stdout, 0, 0, 1, ' ', tabwriter.Debug)
if _, err = fmt.Fprintln(w, strings.Join(columns, "\t")); err != nil {
logger.Fatalf("%s", err)
}
for i, c := range columns {
columns[i] = strings.Repeat("-", len(c))
}
if _, err = fmt.Fprintln(w, strings.Join(columns, "\t")); err != nil {
logger.Fatalf("%s", err)
}
// read all rows, scan each field to []byte
for rows.Next() {
line := make([][]byte, len(columns))
dests := make([]interface{}, len(line))
for i := range dests {
dests[i] = &line[i]
}
if err = rows.Scan(dests...); err != nil {
logger.Fatalf("%s", err)
}
fmt.Fprintf(w, "%s\n", bytes.Join(line, []byte("\t")))
}
if err = rows.Err(); err != nil {
logger.Fatalf("%s", err)
}
if err = w.Flush(); err != nil {
logger.Fatalf("%s", err)
}
if err = rows.Close(); err != nil {
logger.Fatalf("%s", err)
}
}
}