Compare commits
4 Commits
Author | SHA1 | Date | |
---|---|---|---|
|
0d8cc762c0 | ||
|
5577f90f95 | ||
|
587cd1c9b4 | ||
|
3b23aeabbe |
@@ -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}}
|
||||||
|
@@ -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
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user