Method update

core/db.go:368–448

(ctx context.Context, model Model, withValidations bool, isForAuxDB bool)

}

func (app *BaseApp) update(ctx context.Context, model Model, withValidations bool, isForAuxDB bool) error {
	event := new(ModelEvent)
	event.App = app
	event.Context = ctx
	event.Type = ModelEventTypeUpdate
	event.Model = model

	saveErr := app.OnModelUpdate().Trigger(event, func(e *ModelEvent) error {
		// run validations (if any)
		if withValidations {
			validateErr := e.App.ValidateWithContext(e.Context, e.Model)
			if validateErr != nil {
				return validateErr
			}
		}

		// db write
		return e.App.OnModelUpdateExecute().Trigger(event, func(e *ModelEvent) error {
			var db dbx.Builder
			if isForAuxDB {
				db = e.App.AuxNonconcurrentDB()
			} else {
				db = e.App.NonconcurrentDB()
			}

			return baseLockRetry(func(attempt int) error {
				if m, ok := e.Model.(DBExporter); ok {
					data, err := m.DBExport(e.App)
					if err != nil {
						return err
					}

					// note: for now disallow primary key change for consistency with dbx.ModelQuery.Update()
					if data[idColumn] != e.Model.LastSavedPK() {
						return errors.New("primary key change is not allowed")
					}

					_, err = db.Update(e.Model.TableName(), data, dbx.HashExp{
						idColumn: e.Model.LastSavedPK(),
					}).WithContext(e.Context).Execute()

					return err
				}

				return db.Model(e.Model).WithContext(e.Context).Update()
			}, defaultMaxLockRetries)
		})
	})
	if saveErr != nil {
		errEvent := &ModelErrorEvent{ModelEvent: *event, Error: saveErr}
		errEvent.App = app // replace with the initial app in case it was changed by the hook
		hookErr := app.OnModelAfterUpdateError().Trigger(errEvent)
		if hookErr != nil {
			return errors.Join(saveErr, hookErr)
		}

		return saveErr
	}