2 Commits

Author SHA1 Message Date
jdl
b665ab59b1 WIP 2026-06-25 13:55:11 +02:00
jdl
0451e18c81 WIP 2026-06-25 13:52:41 +02:00

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) { ) ({{.Type}}, 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) { ) ({{.Type}}, 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) { ) ({{.Type}}, 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")
} }