app/sqlgen
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

WIP

Browse Source
This commit is contained in:
jdl
2026-06-25 13:24:15 +02:00
parent ad59b98aef
commit 9a0beaf9cb
1 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
gen.go.tmpl
View File

@@ -150,7 +150,6 @@ func {{.LowerType}}_Get(
return return
} }
func {{.LowerType}}_GetWhere( func {{.LowerType}}_GetWhere(
tx TX, tx TX,
query string, query string,
@@ -167,8 +166,6 @@ func {{.LowerType}}_GetWhere(
return return
} }
func {{.LowerType}}_Iterate( func {{.LowerType}}_Iterate(
tx TX, tx TX,
query string, query string,
@@ -178,12 +175,12 @@ func {{.LowerType}}_Iterate(
) { ) {
rows, err := tx.Query(query, args...) rows, err := tx.Query(query, args...)
if err != nil { if err != nil {
return func(yield func(*{{.Type}}, error) bool) { return func(yield func({{.Type}}, error) bool) {
yield(nil, err) yield(nil, err)
} }
} }
return func(yield func(*{{.Type}}, error) bool) { return func(yield func({{.Type}}, error) bool) {
defer rows.Close() defer rows.Close()
for rows.Next() { for rows.Next() {
row := {{.Type}}{} row := {{.Type}}{}
@@ -192,7 +189,7 @@ func {{.LowerType}}_Iterate(
return return
} }
} }
if err != rows.Err() ; err != nil { if err := rows.Err(); err != nil {
yield({{.Type}}{}, err) yield({{.Type}}{}, err)
} }
} }
@@ -203,7 +200,7 @@ func {{.LowerType}}_List(
query string, query string,
args ...any, args ...any,
) ( ) (
l []*{{.Type}}, l []{{.Type}},
err error, err error,
) { ) {
for row, err := range {{.LowerType}}_Iterate(tx, query, args...) { for row, err := range {{.LowerType}}_Iterate(tx, query, args...) {