callbacks.go 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. package callbacks
  2. import (
  3. "github.com/jinzhu/gorm"
  4. )
  5. func RegisterDefaultCallbacks(db *gorm.DB) {
  6. enableTransaction := func(db *gorm.DB) bool {
  7. return !db.SkipDefaultTransaction
  8. }
  9. createCallback := db.Callback().Create()
  10. createCallback.Match(enableTransaction).Register("gorm:begin_transaction", BeginTransaction)
  11. createCallback.Register("gorm:before_create", BeforeCreate)
  12. createCallback.Register("gorm:save_before_associations", SaveBeforeAssociations)
  13. createCallback.Register("gorm:create", Create)
  14. createCallback.Register("gorm:save_after_associations", SaveAfterAssociations)
  15. createCallback.Register("gorm:after_create", AfterCreate)
  16. createCallback.Match(enableTransaction).Register("gorm:commit_or_rollback_transaction", CommitOrRollbackTransaction)
  17. queryCallback := db.Callback().Query()
  18. queryCallback.Register("gorm:query", Query)
  19. queryCallback.Register("gorm:preload", Preload)
  20. queryCallback.Register("gorm:after_query", AfterQuery)
  21. deleteCallback := db.Callback().Delete()
  22. deleteCallback.Match(enableTransaction).Register("gorm:begin_transaction", BeginTransaction)
  23. deleteCallback.Register("gorm:before_delete", BeforeDelete)
  24. deleteCallback.Register("gorm:delete", Delete)
  25. deleteCallback.Register("gorm:after_delete", AfterDelete)
  26. deleteCallback.Match(enableTransaction).Register("gorm:commit_or_rollback_transaction", CommitOrRollbackTransaction)
  27. updateCallback := db.Callback().Update()
  28. updateCallback.Match(enableTransaction).Register("gorm:begin_transaction", BeginTransaction)
  29. updateCallback.Register("gorm:before_update", BeforeUpdate)
  30. updateCallback.Register("gorm:save_before_associations", SaveBeforeAssociations)
  31. updateCallback.Register("gorm:update", Update)
  32. updateCallback.Register("gorm:save_after_associations", SaveAfterAssociations)
  33. updateCallback.Register("gorm:after_update", AfterUpdate)
  34. updateCallback.Match(enableTransaction).Register("gorm:commit_or_rollback_transaction", CommitOrRollbackTransaction)
  35. db.Callback().Row().Register("gorm:raw", RowQuery)
  36. db.Callback().Raw().Register("gorm:raw", RawExec)
  37. }