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:52:41 +02:00
parent 6788b76bfc
commit 0451e18c81
1 changed files with 21 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
gen.go.tmpl
View File

@@ -28,15 +28,15 @@ const {{.LowerType}}_SelectQuery = "{{.SelectQuery}}"
func {{.LowerType}}_Insert( func {{.LowerType}}_Insert(
tx dbConn, tx dbConn,
row *{{.Type}}, row {{.Type}},
) (err error) { ) (row {{.Type}}, err error) {
{{.LowerType}}_Sanitize(row) row = {{.LowerType}}_Sanitize(row)
if err = {{.LowerType}}_Validate(row); err != nil { if err = {{.LowerType}}_Validate(row); err != nil {
return err return row, err
} }
_, err = tx.Exec("{{.InsertQuery}}", {{.InsertArgs}}) _, err = tx.Exec("{{.InsertQuery}}", {{.InsertArgs}})
return err return row, err
} }
{{- end}} {{/* if not .NoInsert */}} {{- end}} {{/* if not .NoInsert */}}
@@ -47,27 +47,27 @@ func {{.LowerType}}_Insert(
func {{.LowerType}}_Update( func {{.LowerType}}_Update(
tx dbConn, tx dbConn,
row *{{.Type}}, row {{.Type}},
) (err error) { ) (row {{.Type}}, err error) {
{{.LowerType}}_Sanitize(row) row = {{.LowerType}}_Sanitize(row)
if err = {{.LowerType}}_Validate(row); err != nil { if err = {{.LowerType}}_Validate(row); err != nil {
return err return row, err
} }
result, err := tx.Exec("{{.UpdateQuery}}", {{.UpdateArgs}}) result, err := tx.Exec("{{.UpdateQuery}}", {{.UpdateArgs}})
if err != nil { if err != nil {
return err return row, err
} }
n, err := result.RowsAffected() n, err := result.RowsAffected()
if err != nil { if err != nil {
return err return row, err
} }
switch n { switch n {
case 0: case 0:
return sql.ErrNoRows return row, sql.ErrNoRows
case 1: case 1:
return nil return row, nil
default: default:
panic("multiple rows updated") panic("multiple rows updated")
} }
@@ -78,27 +78,27 @@ func {{.LowerType}}_Update(
func {{.LowerType}}_UpdateFull( func {{.LowerType}}_UpdateFull(
tx dbConn, tx dbConn,
row *{{.Type}}, row {{.Type}},
) (err error) { ) (row {{.Type}}, err error) {
{{.LowerType}}_Sanitize(row) row = {{.LowerType}}_Sanitize(row)
if err = {{.LowerType}}_Validate(row); err != nil { if err = {{.LowerType}}_Validate(row); err != nil {
return err return row, err
} }
result, err := tx.Exec("{{.UpdateFullQuery}}", {{.UpdateFullArgs}}) result, err := tx.Exec("{{.UpdateFullQuery}}", {{.UpdateFullArgs}})
if err != nil { if err != nil {
return err return row, err
} }
n, err := result.RowsAffected() n, err := result.RowsAffected()
if err != nil { if err != nil {
return err return row, err
} }
switch n { switch n {
case 0: case 0:
return sql.ErrNoRows return row, sql.ErrNoRows
case 1: case 1:
return nil return row, nil
default: default:
panic("multiple rows updated") panic("multiple rows updated")
} }