-
Notifications
You must be signed in to change notification settings - Fork 1k
Expand file tree
/
Copy pathquery.sql.go
More file actions
72 lines (67 loc) · 1.57 KB
/
query.sql.go
File metadata and controls
72 lines (67 loc) · 1.57 KB
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
// Code generated by sqlc. DO NOT EDIT.
// versions:
// sqlc v1.30.0
// source: query.sql
package querytest
import (
"context"
"strings"
)
const brokenQuery = `-- name: BrokenQuery :many
SELECT id, typ, name, val
FROM mytable
WHERE
typ IN (/*SLICE:types*/?)
AND (? OR (name IN (/*SLICE:names*/?)))
`
type BrokenQueryParams struct {
Types []int64
Allnames interface{}
Names []string
}
func (q *Queries) BrokenQuery(ctx context.Context, arg BrokenQueryParams) ([]Mytable, error) {
query := brokenQuery
var queryParams []interface{}
if len(arg.Types) > 0 {
for _, v := range arg.Types {
queryParams = append(queryParams, v)
}
query = strings.Replace(query, "/*SLICE:types*/?", strings.Repeat(",?", len(arg.Types))[1:], 1)
} else {
query = strings.Replace(query, "/*SLICE:types*/?", "NULL", 1)
}
queryParams = append(queryParams, arg.Allnames)
if len(arg.Names) > 0 {
for _, v := range arg.Names {
queryParams = append(queryParams, v)
}
query = strings.Replace(query, "/*SLICE:names*/?", strings.Repeat(",?", len(arg.Names))[1:], 1)
} else {
query = strings.Replace(query, "/*SLICE:names*/?", "NULL", 1)
}
rows, err := q.db.QueryContext(ctx, query, queryParams...)
if err != nil {
return nil, err
}
defer rows.Close()
var items []Mytable
for rows.Next() {
var i Mytable
if err := rows.Scan(
&i.ID,
&i.Typ,
&i.Name,
&i.Val,
); err != nil {
return nil, err
}
items = append(items, i)
}
if err := rows.Close(); err != nil {
return nil, err
}
if err := rows.Err(); err != nil {
return nil, err
}
return items, nil
}