Method create

core/db.go:273–366

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

}

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

	saveErr := app.OnModelCreate().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.OnModelCreateExecute().Trigger(event, func(e *ModelEvent) error {
			var db dbx.Builder
			if isForAuxDB {
				db = e.App.AuxNonconcurrentDB()
			} else {
				db = e.App.NonconcurrentDB()
			}

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

					// manually add the id to the data if missing
					if _, ok := data[idColumn]; !ok {
						data[idColumn] = e.Model.PK()
					}

					if cast.ToString(data[idColumn]) == "" {
						return errors.New("empty primary key is not allowed when using the DBExporter interface")
					}

					_, err = db.Insert(e.Model.TableName(), data).WithContext(e.Context).Execute()

					return err
				}

				return db.Model(e.Model).WithContext(e.Context).Insert()
			}, defaultMaxLockRetries)
			if dbErr != nil {
				return dbErr
			}

			e.Model.MarkAsNotNew()

			return nil
		})
	})
	if saveErr != nil {