callbacks.go 3.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283
  1. package callbacks
  2. import (
  3. "gorm.io/gorm"
  4. )
  5. var (
  6. createClauses = []string{"INSERT", "VALUES", "ON CONFLICT"}
  7. queryClauses = []string{"SELECT", "FROM", "WHERE", "GROUP BY", "ORDER BY", "LIMIT", "FOR"}
  8. updateClauses = []string{"UPDATE", "SET", "WHERE"}
  9. deleteClauses = []string{"DELETE", "FROM", "WHERE"}
  10. )
  11. type Config struct {
  12. LastInsertIDReversed bool
  13. WithReturning bool
  14. CreateClauses []string
  15. QueryClauses []string
  16. UpdateClauses []string
  17. DeleteClauses []string
  18. }
  19. func RegisterDefaultCallbacks(db *gorm.DB, config *Config) {
  20. enableTransaction := func(db *gorm.DB) bool {
  21. return !db.SkipDefaultTransaction
  22. }
  23. createCallback := db.Callback().Create()
  24. createCallback.Match(enableTransaction).Register("gorm:begin_transaction", BeginTransaction)
  25. createCallback.Register("gorm:before_create", BeforeCreate)
  26. createCallback.Register("gorm:save_before_associations", SaveBeforeAssociations(true))
  27. createCallback.Register("gorm:create", Create(config))
  28. createCallback.Register("gorm:save_after_associations", SaveAfterAssociations(true))
  29. createCallback.Register("gorm:after_create", AfterCreate)
  30. createCallback.Match(enableTransaction).Register("gorm:commit_or_rollback_transaction", CommitOrRollbackTransaction)
  31. if len(config.CreateClauses) == 0 {
  32. config.CreateClauses = createClauses
  33. }
  34. createCallback.Clauses = config.CreateClauses
  35. queryCallback := db.Callback().Query()
  36. queryCallback.Register("gorm:query", Query)
  37. queryCallback.Register("gorm:preload", Preload)
  38. queryCallback.Register("gorm:after_query", AfterQuery)
  39. if len(config.QueryClauses) == 0 {
  40. config.QueryClauses = queryClauses
  41. }
  42. queryCallback.Clauses = config.QueryClauses
  43. deleteCallback := db.Callback().Delete()
  44. deleteCallback.Match(enableTransaction).Register("gorm:begin_transaction", BeginTransaction)
  45. deleteCallback.Register("gorm:before_delete", BeforeDelete)
  46. deleteCallback.Register("gorm:delete_before_associations", DeleteBeforeAssociations)
  47. deleteCallback.Register("gorm:delete", Delete)
  48. deleteCallback.Register("gorm:after_delete", AfterDelete)
  49. deleteCallback.Match(enableTransaction).Register("gorm:commit_or_rollback_transaction", CommitOrRollbackTransaction)
  50. if len(config.DeleteClauses) == 0 {
  51. config.DeleteClauses = deleteClauses
  52. }
  53. deleteCallback.Clauses = config.DeleteClauses
  54. updateCallback := db.Callback().Update()
  55. updateCallback.Match(enableTransaction).Register("gorm:begin_transaction", BeginTransaction)
  56. updateCallback.Register("gorm:setup_reflect_value", SetupUpdateReflectValue)
  57. updateCallback.Register("gorm:before_update", BeforeUpdate)
  58. updateCallback.Register("gorm:save_before_associations", SaveBeforeAssociations(false))
  59. updateCallback.Register("gorm:update", Update)
  60. updateCallback.Register("gorm:save_after_associations", SaveAfterAssociations(false))
  61. updateCallback.Register("gorm:after_update", AfterUpdate)
  62. updateCallback.Match(enableTransaction).Register("gorm:commit_or_rollback_transaction", CommitOrRollbackTransaction)
  63. if len(config.UpdateClauses) == 0 {
  64. config.UpdateClauses = updateClauses
  65. }
  66. updateCallback.Clauses = config.UpdateClauses
  67. rowCallback := db.Callback().Row()
  68. rowCallback.Register("gorm:row", RowQuery)
  69. rowCallback.Clauses = config.QueryClauses
  70. rawCallback := db.Callback().Raw()
  71. rawCallback.Register("gorm:raw", RawExec)
  72. rawCallback.Clauses = config.QueryClauses
  73. }