-
Notifications
You must be signed in to change notification settings - Fork 0
/
stmt.go
75 lines (57 loc) · 2.24 KB
/
stmt.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
package sqlp
import (
"context"
"database/sql"
)
type Stmt struct {
SqlStmt *sql.Stmt
query string
}
func (s *Stmt) Close() error {
return s.SqlStmt.Close()
}
func (s *Stmt) sqlExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error) {
return s.SqlStmt.ExecContext(ctx, args...)
}
func (s *Stmt) sqlQueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) {
return s.SqlStmt.QueryContext(ctx, args...)
}
func (s *Stmt) sqlPrepareContext(ctx context.Context, query string) (*sql.Stmt, error) {
return nil, nil
}
func (s *Stmt) ExecContext(ctx context.Context, args ...interface{}) (Result, error) {
return execContext(ctx, s, s.query, args...)
}
func (s *Stmt) Exec(args ...interface{}) (Result, error) {
return s.ExecContext(context.Background(), args...)
}
func (s *Stmt) QueryContext(ctx context.Context, args ...interface{}) (*Rows, error) {
return queryContext(ctx, s, s.query, args...)
}
func (s *Stmt) Query(args ...interface{}) (*Rows, error) {
return s.QueryContext(context.Background(), args...)
}
func (s *Stmt) QueryRowContext(ctx context.Context, args ...interface{}) *Row {
return queryRowContext(ctx, s, s.query, args...)
}
func (s *Stmt) QueryRow(args ...interface{}) *Row {
return s.QueryRowContext(context.Background(), args...)
}
func (s *Stmt) SelectToStructContext(ctx context.Context, structSlicePtr interface{}, args ...interface{}) error {
return selectToStructContext(ctx, s, structSlicePtr, s.query, args...)
}
func (s *Stmt) SelectToStruct(structSlicePtr interface{}, args ...interface{}) error {
return s.SelectToStructContext(context.Background(), structSlicePtr, args...)
}
func (s *Stmt) SelectToMapContext(ctx context.Context, args ...interface{}) ([]map[string]string, error) {
return selectToMapContext(ctx, s, s.query, args...)
}
func (s *Stmt) SelectToMap(args ...interface{}) ([]map[string]string, error) {
return s.SelectToMapContext(context.Background(), args...)
}
func (s *Stmt) SelectToSliceContext(ctx context.Context, args ...interface{}) ([][]string, error) {
return selectToSliceContext(ctx, s, s.query, args...)
}
func (s *Stmt) SelectToSlice(args ...interface{}) ([][]string, error) {
return s.SelectToSliceContext(context.Background(), args...)
}