4 Commits

Author SHA1 Message Date
jdl
0d8cc762c0 wip 2024-11-19 16:20:18 +01:00
jdl
5577f90f95 wip 2024-11-19 08:57:49 +01:00
jdl
587cd1c9b4 wip 2024-11-18 17:04:37 +01:00
jdl
3b23aeabbe wip 2024-11-18 17:01:17 +01:00
2 changed files with 28 additions and 22 deletions

View File

@@ -48,27 +48,29 @@ func {{.Type}}_Insert(
func {{.Type}}_Update( func {{.Type}}_Update(
tx TX, tx TX,
row *{{.Type}}, row *{{.Type}},
) (found bool, err error) { ) (err error) {
{{.Type}}_Sanitize(row) {{.Type}}_Sanitize(row)
if err = {{.Type}}_Validate(row); err != nil { if err = {{.Type}}_Validate(row); err != nil {
return false, err return err
} }
result, err := tx.Exec("{{.UpdateQuery}}", {{.UpdateArgs}}) result, err := tx.Exec("{{.UpdateQuery}}", {{.UpdateArgs}})
if err != nil { if err != nil {
return false, err return err
} }
n, err := result.RowsAffected() n, err := result.RowsAffected()
if err != nil { if err != nil {
panic(err) panic(err)
} }
switch n {
if n > 1 { case 0:
return sql.ErrNoRows
case 1:
return nil
default:
panic("multiple rows updated") panic("multiple rows updated")
} }
return n != 0, nil
} }
{{- end}} {{- end}}
@@ -77,27 +79,29 @@ func {{.Type}}_Update(
func {{.Type}}_UpdateFull( func {{.Type}}_UpdateFull(
tx TX, tx TX,
row *{{.Type}}, row *{{.Type}},
) (found bool, err error) { ) (err error) {
{{.Type}}_Sanitize(row) {{.Type}}_Sanitize(row)
if err = {{.Type}}_Validate(row); err != nil { if err = {{.Type}}_Validate(row); err != nil {
return false, err return err
} }
result, err := tx.Exec("{{.UpdateFullQuery}}", {{.UpdateFullArgs}}) result, err := tx.Exec("{{.UpdateFullQuery}}", {{.UpdateFullArgs}})
if err != nil { if err != nil {
return false, err return err
} }
n, err := result.RowsAffected() n, err := result.RowsAffected()
if err != nil { if err != nil {
panic(err) panic(err)
} }
switch n {
if n > 1 { case 0:
return sql.ErrNoRows
case 1:
return nil
default:
panic("multiple rows updated") panic("multiple rows updated")
} }
return n != 0, nil
} }
{{- end}} {{- end}}
@@ -109,22 +113,24 @@ func {{.Type}}_UpdateFull(
func {{.Type}}_Delete( func {{.Type}}_Delete(
tx TX, tx TX,
{{.PKFunctionArgs -}} {{.PKFunctionArgs -}}
) (found bool, err error) { ) (err error) {
result, err := tx.Exec("{{.DeleteQuery}}", {{.DeleteArgs}}) result, err := tx.Exec("{{.DeleteQuery}}", {{.DeleteArgs}})
if err != nil { if err != nil {
return false, err return err
} }
n, err := result.RowsAffected() n, err := result.RowsAffected()
if err != nil { if err != nil {
panic(err) panic(err)
} }
switch n {
if n > 1 { case 0:
return sql.ErrNoRows
case 1:
return nil
default:
panic("multiple rows deleted") panic("multiple rows deleted")
} }
return n != 0, nil
} }
{{- end}} {{- end}}

View File

@@ -2,7 +2,7 @@ package sqliteutil
import "github.com/mattn/go-sqlite3" import "github.com/mattn/go-sqlite3"
func ErrIsDuplicate(err error) bool { func ErrIsConstraint(err error) bool {
e, ok := err.(sqlite3.Error) e, ok := err.(sqlite3.Error)
return ok && e.Code == 19 return ok && e.Code == 19
} }