// Code generated by SQLBoiler 4.19.5 (https://github.com/aarondl/sqlboiler). DO NOT EDIT. // This file is meant to be re-generated in place and/or deleted at any time. package models import ( "context" "database/sql" "fmt" "reflect" "strconv" "strings" "sync" "time" "github.com/aarondl/null/v8" "github.com/aarondl/sqlboiler/v4/boil" "github.com/aarondl/sqlboiler/v4/queries" "github.com/aarondl/sqlboiler/v4/queries/qm" "github.com/aarondl/sqlboiler/v4/queries/qmhelper" "github.com/aarondl/sqlboiler/v4/types" "github.com/aarondl/strmangle" "github.com/friendsofgo/errors" ) // User is an object representing the database table. type User struct { ID string `boil:"id" json:"id" toml:"id" yaml:"id"` Username null.String `boil:"username" json:"username,omitempty" toml:"username" yaml:"username,omitempty"` Password null.String `boil:"password" json:"password,omitempty" toml:"password" yaml:"password,omitempty"` IsActive bool `boil:"is_active" json:"is_active" toml:"is_active" yaml:"is_active"` Scopes types.StringArray `boil:"scopes" json:"scopes" toml:"scopes" yaml:"scopes"` LastAuthenticatedAt null.Time `boil:"last_authenticated_at" json:"last_authenticated_at,omitempty" toml:"last_authenticated_at" yaml:"last_authenticated_at,omitempty"` CreatedAt time.Time `boil:"created_at" json:"created_at" toml:"created_at" yaml:"created_at"` UpdatedAt time.Time `boil:"updated_at" json:"updated_at" toml:"updated_at" yaml:"updated_at"` RequiresConfirmation bool `boil:"requires_confirmation" json:"requires_confirmation" toml:"requires_confirmation" yaml:"requires_confirmation"` R *userR `boil:"-" json:"-" toml:"-" yaml:"-"` L userL `boil:"-" json:"-" toml:"-" yaml:"-"` } var UserColumns = struct { ID string Username string Password string IsActive string Scopes string LastAuthenticatedAt string CreatedAt string UpdatedAt string RequiresConfirmation string }{ ID: "id", Username: "username", Password: "password", IsActive: "is_active", Scopes: "scopes", LastAuthenticatedAt: "last_authenticated_at", CreatedAt: "created_at", UpdatedAt: "updated_at", RequiresConfirmation: "requires_confirmation", } var UserTableColumns = struct { ID string Username string Password string IsActive string Scopes string LastAuthenticatedAt string CreatedAt string UpdatedAt string RequiresConfirmation string }{ ID: "users.id", Username: "users.username", Password: "users.password", IsActive: "users.is_active", Scopes: "users.scopes", LastAuthenticatedAt: "users.last_authenticated_at", CreatedAt: "users.created_at", UpdatedAt: "users.updated_at", RequiresConfirmation: "users.requires_confirmation", } // Generated where type whereHelpernull_String struct{ field string } func (w whereHelpernull_String) EQ(x null.String) qm.QueryMod { return qmhelper.WhereNullEQ(w.field, false, x) } func (w whereHelpernull_String) NEQ(x null.String) qm.QueryMod { return qmhelper.WhereNullEQ(w.field, true, x) } func (w whereHelpernull_String) LT(x null.String) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.LT, x) } func (w whereHelpernull_String) LTE(x null.String) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.LTE, x) } func (w whereHelpernull_String) GT(x null.String) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.GT, x) } func (w whereHelpernull_String) GTE(x null.String) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.GTE, x) } func (w whereHelpernull_String) LIKE(x null.String) qm.QueryMod { return qm.Where(w.field+" LIKE ?", x) } func (w whereHelpernull_String) NLIKE(x null.String) qm.QueryMod { return qm.Where(w.field+" NOT LIKE ?", x) } func (w whereHelpernull_String) ILIKE(x null.String) qm.QueryMod { return qm.Where(w.field+" ILIKE ?", x) } func (w whereHelpernull_String) NILIKE(x null.String) qm.QueryMod { return qm.Where(w.field+" NOT ILIKE ?", x) } func (w whereHelpernull_String) SIMILAR(x null.String) qm.QueryMod { return qm.Where(w.field+" SIMILAR TO ?", x) } func (w whereHelpernull_String) NSIMILAR(x null.String) qm.QueryMod { return qm.Where(w.field+" NOT SIMILAR TO ?", x) } func (w whereHelpernull_String) IN(slice []string) qm.QueryMod { values := make([]interface{}, 0, len(slice)) for _, value := range slice { values = append(values, value) } return qm.WhereIn(fmt.Sprintf("%s IN ?", w.field), values...) } func (w whereHelpernull_String) NIN(slice []string) qm.QueryMod { values := make([]interface{}, 0, len(slice)) for _, value := range slice { values = append(values, value) } return qm.WhereNotIn(fmt.Sprintf("%s NOT IN ?", w.field), values...) } func (w whereHelpernull_String) IsNull() qm.QueryMod { return qmhelper.WhereIsNull(w.field) } func (w whereHelpernull_String) IsNotNull() qm.QueryMod { return qmhelper.WhereIsNotNull(w.field) } type whereHelperbool struct{ field string } func (w whereHelperbool) EQ(x bool) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.EQ, x) } func (w whereHelperbool) NEQ(x bool) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.NEQ, x) } func (w whereHelperbool) LT(x bool) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.LT, x) } func (w whereHelperbool) LTE(x bool) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.LTE, x) } func (w whereHelperbool) GT(x bool) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.GT, x) } func (w whereHelperbool) GTE(x bool) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.GTE, x) } type whereHelpertypes_StringArray struct{ field string } func (w whereHelpertypes_StringArray) EQ(x types.StringArray) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.EQ, x) } func (w whereHelpertypes_StringArray) NEQ(x types.StringArray) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.NEQ, x) } func (w whereHelpertypes_StringArray) LT(x types.StringArray) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.LT, x) } func (w whereHelpertypes_StringArray) LTE(x types.StringArray) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.LTE, x) } func (w whereHelpertypes_StringArray) GT(x types.StringArray) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.GT, x) } func (w whereHelpertypes_StringArray) GTE(x types.StringArray) qm.QueryMod { return qmhelper.Where(w.field, qmhelper.GTE, x) } var UserWhere = struct { ID whereHelperstring Username whereHelpernull_String Password whereHelpernull_String IsActive whereHelperbool Scopes whereHelpertypes_StringArray LastAuthenticatedAt whereHelpernull_Time CreatedAt whereHelpertime_Time UpdatedAt whereHelpertime_Time RequiresConfirmation whereHelperbool }{ ID: whereHelperstring{field: "\"users\".\"id\""}, Username: whereHelpernull_String{field: "\"users\".\"username\""}, Password: whereHelpernull_String{field: "\"users\".\"password\""}, IsActive: whereHelperbool{field: "\"users\".\"is_active\""}, Scopes: whereHelpertypes_StringArray{field: "\"users\".\"scopes\""}, LastAuthenticatedAt: whereHelpernull_Time{field: "\"users\".\"last_authenticated_at\""}, CreatedAt: whereHelpertime_Time{field: "\"users\".\"created_at\""}, UpdatedAt: whereHelpertime_Time{field: "\"users\".\"updated_at\""}, RequiresConfirmation: whereHelperbool{field: "\"users\".\"requires_confirmation\""}, } // UserRels is where relationship names are stored. var UserRels = struct { AppUserProfile string AccessTokens string ConfirmationTokens string PasswordResetTokens string PushTokens string RefreshTokens string }{ AppUserProfile: "AppUserProfile", AccessTokens: "AccessTokens", ConfirmationTokens: "ConfirmationTokens", PasswordResetTokens: "PasswordResetTokens", PushTokens: "PushTokens", RefreshTokens: "RefreshTokens", } // userR is where relationships are stored. type userR struct { AppUserProfile *AppUserProfile `boil:"AppUserProfile" json:"AppUserProfile" toml:"AppUserProfile" yaml:"AppUserProfile"` AccessTokens AccessTokenSlice `boil:"AccessTokens" json:"AccessTokens" toml:"AccessTokens" yaml:"AccessTokens"` ConfirmationTokens ConfirmationTokenSlice `boil:"ConfirmationTokens" json:"ConfirmationTokens" toml:"ConfirmationTokens" yaml:"ConfirmationTokens"` PasswordResetTokens PasswordResetTokenSlice `boil:"PasswordResetTokens" json:"PasswordResetTokens" toml:"PasswordResetTokens" yaml:"PasswordResetTokens"` PushTokens PushTokenSlice `boil:"PushTokens" json:"PushTokens" toml:"PushTokens" yaml:"PushTokens"` RefreshTokens RefreshTokenSlice `boil:"RefreshTokens" json:"RefreshTokens" toml:"RefreshTokens" yaml:"RefreshTokens"` } // NewStruct creates a new relationship struct func (*userR) NewStruct() *userR { return &userR{} } func (o *User) GetAppUserProfile() *AppUserProfile { if o == nil { return nil } return o.R.GetAppUserProfile() } func (r *userR) GetAppUserProfile() *AppUserProfile { if r == nil { return nil } return r.AppUserProfile } func (o *User) GetAccessTokens() AccessTokenSlice { if o == nil { return nil } return o.R.GetAccessTokens() } func (r *userR) GetAccessTokens() AccessTokenSlice { if r == nil { return nil } return r.AccessTokens } func (o *User) GetConfirmationTokens() ConfirmationTokenSlice { if o == nil { return nil } return o.R.GetConfirmationTokens() } func (r *userR) GetConfirmationTokens() ConfirmationTokenSlice { if r == nil { return nil } return r.ConfirmationTokens } func (o *User) GetPasswordResetTokens() PasswordResetTokenSlice { if o == nil { return nil } return o.R.GetPasswordResetTokens() } func (r *userR) GetPasswordResetTokens() PasswordResetTokenSlice { if r == nil { return nil } return r.PasswordResetTokens } func (o *User) GetPushTokens() PushTokenSlice { if o == nil { return nil } return o.R.GetPushTokens() } func (r *userR) GetPushTokens() PushTokenSlice { if r == nil { return nil } return r.PushTokens } func (o *User) GetRefreshTokens() RefreshTokenSlice { if o == nil { return nil } return o.R.GetRefreshTokens() } func (r *userR) GetRefreshTokens() RefreshTokenSlice { if r == nil { return nil } return r.RefreshTokens } // userL is where Load methods for each relationship are stored. type userL struct{} var ( userAllColumns = []string{"id", "username", "password", "is_active", "scopes", "last_authenticated_at", "created_at", "updated_at", "requires_confirmation"} userColumnsWithoutDefault = []string{"is_active", "scopes", "created_at", "updated_at"} userColumnsWithDefault = []string{"id", "username", "password", "last_authenticated_at", "requires_confirmation"} userPrimaryKeyColumns = []string{"id"} userGeneratedColumns = []string{} ) type ( // UserSlice is an alias for a slice of pointers to User. // This should almost always be used instead of []User. UserSlice []*User userQuery struct { *queries.Query } ) // Cache for insert, update and upsert var ( userType = reflect.TypeOf(&User{}) userMapping = queries.MakeStructMapping(userType) userPrimaryKeyMapping, _ = queries.BindMapping(userType, userMapping, userPrimaryKeyColumns) userInsertCacheMut sync.RWMutex userInsertCache = make(map[string]insertCache) userUpdateCacheMut sync.RWMutex userUpdateCache = make(map[string]updateCache) userUpsertCacheMut sync.RWMutex userUpsertCache = make(map[string]insertCache) ) var ( // Force time package dependency for automated UpdatedAt/CreatedAt. _ = time.Second // Force qmhelper dependency for where clause generation (which doesn't // always happen) _ = qmhelper.Where ) // One returns a single user record from the query. func (q userQuery) One(ctx context.Context, exec boil.ContextExecutor) (*User, error) { o := &User{} queries.SetLimit(q.Query, 1) err := q.Bind(ctx, exec, o) if err != nil { if errors.Is(err, sql.ErrNoRows) { return nil, sql.ErrNoRows } return nil, errors.Wrap(err, "models: failed to execute a one query for users") } return o, nil } // All returns all User records from the query. func (q userQuery) All(ctx context.Context, exec boil.ContextExecutor) (UserSlice, error) { var o []*User err := q.Bind(ctx, exec, &o) if err != nil { return nil, errors.Wrap(err, "models: failed to assign all query results to User slice") } return o, nil } // Count returns the count of all User records in the query. func (q userQuery) Count(ctx context.Context, exec boil.ContextExecutor) (int64, error) { var count int64 queries.SetSelect(q.Query, nil) queries.SetCount(q.Query) err := q.Query.QueryRowContext(ctx, exec).Scan(&count) if err != nil { return 0, errors.Wrap(err, "models: failed to count users rows") } return count, nil } // Exists checks if the row exists in the table. func (q userQuery) Exists(ctx context.Context, exec boil.ContextExecutor) (bool, error) { var count int64 queries.SetSelect(q.Query, nil) queries.SetCount(q.Query) queries.SetLimit(q.Query, 1) err := q.Query.QueryRowContext(ctx, exec).Scan(&count) if err != nil { return false, errors.Wrap(err, "models: failed to check if users exists") } return count > 0, nil } // AppUserProfile pointed to by the foreign key. func (o *User) AppUserProfile(mods ...qm.QueryMod) appUserProfileQuery { queryMods := []qm.QueryMod{ qm.Where("\"user_id\" = ?", o.ID), } queryMods = append(queryMods, mods...) return AppUserProfiles(queryMods...) } // AccessTokens retrieves all the access_token's AccessTokens with an executor. func (o *User) AccessTokens(mods ...qm.QueryMod) accessTokenQuery { var queryMods []qm.QueryMod if len(mods) != 0 { queryMods = append(queryMods, mods...) } queryMods = append(queryMods, qm.Where("\"access_tokens\".\"user_id\"=?", o.ID), ) return AccessTokens(queryMods...) } // ConfirmationTokens retrieves all the confirmation_token's ConfirmationTokens with an executor. func (o *User) ConfirmationTokens(mods ...qm.QueryMod) confirmationTokenQuery { var queryMods []qm.QueryMod if len(mods) != 0 { queryMods = append(queryMods, mods...) } queryMods = append(queryMods, qm.Where("\"confirmation_tokens\".\"user_id\"=?", o.ID), ) return ConfirmationTokens(queryMods...) } // PasswordResetTokens retrieves all the password_reset_token's PasswordResetTokens with an executor. func (o *User) PasswordResetTokens(mods ...qm.QueryMod) passwordResetTokenQuery { var queryMods []qm.QueryMod if len(mods) != 0 { queryMods = append(queryMods, mods...) } queryMods = append(queryMods, qm.Where("\"password_reset_tokens\".\"user_id\"=?", o.ID), ) return PasswordResetTokens(queryMods...) } // PushTokens retrieves all the push_token's PushTokens with an executor. func (o *User) PushTokens(mods ...qm.QueryMod) pushTokenQuery { var queryMods []qm.QueryMod if len(mods) != 0 { queryMods = append(queryMods, mods...) } queryMods = append(queryMods, qm.Where("\"push_tokens\".\"user_id\"=?", o.ID), ) return PushTokens(queryMods...) } // RefreshTokens retrieves all the refresh_token's RefreshTokens with an executor. func (o *User) RefreshTokens(mods ...qm.QueryMod) refreshTokenQuery { var queryMods []qm.QueryMod if len(mods) != 0 { queryMods = append(queryMods, mods...) } queryMods = append(queryMods, qm.Where("\"refresh_tokens\".\"user_id\"=?", o.ID), ) return RefreshTokens(queryMods...) } // LoadAppUserProfile allows an eager lookup of values, cached into the // loaded structs of the objects. This is for a 1-1 relationship. func (userL) LoadAppUserProfile(ctx context.Context, e boil.ContextExecutor, singular bool, maybeUser interface{}, mods queries.Applicator) error { var slice []*User var object *User if singular { var ok bool object, ok = maybeUser.(*User) if !ok { object = new(User) ok = queries.SetFromEmbeddedStruct(&object, &maybeUser) if !ok { return errors.New(fmt.Sprintf("failed to set %T from embedded struct %T", object, maybeUser)) } } } else { s, ok := maybeUser.(*[]*User) if ok { slice = *s } else { ok = queries.SetFromEmbeddedStruct(&slice, maybeUser) if !ok { return errors.New(fmt.Sprintf("failed to set %T from embedded struct %T", slice, maybeUser)) } } } args := make(map[interface{}]struct{}) if singular { if object.R == nil { object.R = &userR{} } args[object.ID] = struct{}{} } else { for _, obj := range slice { if obj.R == nil { obj.R = &userR{} } args[obj.ID] = struct{}{} } } if len(args) == 0 { return nil } argsSlice := make([]interface{}, len(args)) i := 0 for arg := range args { argsSlice[i] = arg i++ } query := NewQuery( qm.From(`app_user_profiles`), qm.WhereIn(`app_user_profiles.user_id in ?`, argsSlice...), ) if mods != nil { mods.Apply(query) } results, err := query.QueryContext(ctx, e) if err != nil { return errors.Wrap(err, "failed to eager load AppUserProfile") } var resultSlice []*AppUserProfile if err = queries.Bind(results, &resultSlice); err != nil { return errors.Wrap(err, "failed to bind eager loaded slice AppUserProfile") } if err = results.Close(); err != nil { return errors.Wrap(err, "failed to close results of eager load for app_user_profiles") } if err = results.Err(); err != nil { return errors.Wrap(err, "error occurred during iteration of eager loaded relations for app_user_profiles") } if len(resultSlice) == 0 { return nil } if singular { foreign := resultSlice[0] object.R.AppUserProfile = foreign if foreign.R == nil { foreign.R = &appUserProfileR{} } foreign.R.User = object } for _, local := range slice { for _, foreign := range resultSlice { if local.ID == foreign.UserID { local.R.AppUserProfile = foreign if foreign.R == nil { foreign.R = &appUserProfileR{} } foreign.R.User = local break } } } return nil } // LoadAccessTokens allows an eager lookup of values, cached into the // loaded structs of the objects. This is for a 1-M or N-M relationship. func (userL) LoadAccessTokens(ctx context.Context, e boil.ContextExecutor, singular bool, maybeUser interface{}, mods queries.Applicator) error { var slice []*User var object *User if singular { var ok bool object, ok = maybeUser.(*User) if !ok { object = new(User) ok = queries.SetFromEmbeddedStruct(&object, &maybeUser) if !ok { return errors.New(fmt.Sprintf("failed to set %T from embedded struct %T", object, maybeUser)) } } } else { s, ok := maybeUser.(*[]*User) if ok { slice = *s } else { ok = queries.SetFromEmbeddedStruct(&slice, maybeUser) if !ok { return errors.New(fmt.Sprintf("failed to set %T from embedded struct %T", slice, maybeUser)) } } } args := make(map[interface{}]struct{}) if singular { if object.R == nil { object.R = &userR{} } args[object.ID] = struct{}{} } else { for _, obj := range slice { if obj.R == nil { obj.R = &userR{} } args[obj.ID] = struct{}{} } } if len(args) == 0 { return nil } argsSlice := make([]interface{}, len(args)) i := 0 for arg := range args { argsSlice[i] = arg i++ } query := NewQuery( qm.From(`access_tokens`), qm.WhereIn(`access_tokens.user_id in ?`, argsSlice...), ) if mods != nil { mods.Apply(query) } results, err := query.QueryContext(ctx, e) if err != nil { return errors.Wrap(err, "failed to eager load access_tokens") } var resultSlice []*AccessToken if err = queries.Bind(results, &resultSlice); err != nil { return errors.Wrap(err, "failed to bind eager loaded slice access_tokens") } if err = results.Close(); err != nil { return errors.Wrap(err, "failed to close results in eager load on access_tokens") } if err = results.Err(); err != nil { return errors.Wrap(err, "error occurred during iteration of eager loaded relations for access_tokens") } if singular { object.R.AccessTokens = resultSlice for _, foreign := range resultSlice { if foreign.R == nil { foreign.R = &accessTokenR{} } foreign.R.User = object } return nil } for _, foreign := range resultSlice { for _, local := range slice { if local.ID == foreign.UserID { local.R.AccessTokens = append(local.R.AccessTokens, foreign) if foreign.R == nil { foreign.R = &accessTokenR{} } foreign.R.User = local break } } } return nil } // LoadConfirmationTokens allows an eager lookup of values, cached into the // loaded structs of the objects. This is for a 1-M or N-M relationship. func (userL) LoadConfirmationTokens(ctx context.Context, e boil.ContextExecutor, singular bool, maybeUser interface{}, mods queries.Applicator) error { var slice []*User var object *User if singular { var ok bool object, ok = maybeUser.(*User) if !ok { object = new(User) ok = queries.SetFromEmbeddedStruct(&object, &maybeUser) if !ok { return errors.New(fmt.Sprintf("failed to set %T from embedded struct %T", object, maybeUser)) } } } else { s, ok := maybeUser.(*[]*User) if ok { slice = *s } else { ok = queries.SetFromEmbeddedStruct(&slice, maybeUser) if !ok { return errors.New(fmt.Sprintf("failed to set %T from embedded struct %T", slice, maybeUser)) } } } args := make(map[interface{}]struct{}) if singular { if object.R == nil { object.R = &userR{} } args[object.ID] = struct{}{} } else { for _, obj := range slice { if obj.R == nil { obj.R = &userR{} } args[obj.ID] = struct{}{} } } if len(args) == 0 { return nil } argsSlice := make([]interface{}, len(args)) i := 0 for arg := range args { argsSlice[i] = arg i++ } query := NewQuery( qm.From(`confirmation_tokens`), qm.WhereIn(`confirmation_tokens.user_id in ?`, argsSlice...), ) if mods != nil { mods.Apply(query) } results, err := query.QueryContext(ctx, e) if err != nil { return errors.Wrap(err, "failed to eager load confirmation_tokens") } var resultSlice []*ConfirmationToken if err = queries.Bind(results, &resultSlice); err != nil { return errors.Wrap(err, "failed to bind eager loaded slice confirmation_tokens") } if err = results.Close(); err != nil { return errors.Wrap(err, "failed to close results in eager load on confirmation_tokens") } if err = results.Err(); err != nil { return errors.Wrap(err, "error occurred during iteration of eager loaded relations for confirmation_tokens") } if singular { object.R.ConfirmationTokens = resultSlice for _, foreign := range resultSlice { if foreign.R == nil { foreign.R = &confirmationTokenR{} } foreign.R.User = object } return nil } for _, foreign := range resultSlice { for _, local := range slice { if local.ID == foreign.UserID { local.R.ConfirmationTokens = append(local.R.ConfirmationTokens, foreign) if foreign.R == nil { foreign.R = &confirmationTokenR{} } foreign.R.User = local break } } } return nil } // LoadPasswordResetTokens allows an eager lookup of values, cached into the // loaded structs of the objects. This is for a 1-M or N-M relationship. func (userL) LoadPasswordResetTokens(ctx context.Context, e boil.ContextExecutor, singular bool, maybeUser interface{}, mods queries.Applicator) error { var slice []*User var object *User if singular { var ok bool object, ok = maybeUser.(*User) if !ok { object = new(User) ok = queries.SetFromEmbeddedStruct(&object, &maybeUser) if !ok { return errors.New(fmt.Sprintf("failed to set %T from embedded struct %T", object, maybeUser)) } } } else { s, ok := maybeUser.(*[]*User) if ok { slice = *s } else { ok = queries.SetFromEmbeddedStruct(&slice, maybeUser) if !ok { return errors.New(fmt.Sprintf("failed to set %T from embedded struct %T", slice, maybeUser)) } } } args := make(map[interface{}]struct{}) if singular { if object.R == nil { object.R = &userR{} } args[object.ID] = struct{}{} } else { for _, obj := range slice { if obj.R == nil { obj.R = &userR{} } args[obj.ID] = struct{}{} } } if len(args) == 0 { return nil } argsSlice := make([]interface{}, len(args)) i := 0 for arg := range args { argsSlice[i] = arg i++ } query := NewQuery( qm.From(`password_reset_tokens`), qm.WhereIn(`password_reset_tokens.user_id in ?`, argsSlice...), ) if mods != nil { mods.Apply(query) } results, err := query.QueryContext(ctx, e) if err != nil { return errors.Wrap(err, "failed to eager load password_reset_tokens") } var resultSlice []*PasswordResetToken if err = queries.Bind(results, &resultSlice); err != nil { return errors.Wrap(err, "failed to bind eager loaded slice password_reset_tokens") } if err = results.Close(); err != nil { return errors.Wrap(err, "failed to close results in eager load on password_reset_tokens") } if err = results.Err(); err != nil { return errors.Wrap(err, "error occurred during iteration of eager loaded relations for password_reset_tokens") } if singular { object.R.PasswordResetTokens = resultSlice for _, foreign := range resultSlice { if foreign.R == nil { foreign.R = &passwordResetTokenR{} } foreign.R.User = object } return nil } for _, foreign := range resultSlice { for _, local := range slice { if local.ID == foreign.UserID { local.R.PasswordResetTokens = append(local.R.PasswordResetTokens, foreign) if foreign.R == nil { foreign.R = &passwordResetTokenR{} } foreign.R.User = local break } } } return nil } // LoadPushTokens allows an eager lookup of values, cached into the // loaded structs of the objects. This is for a 1-M or N-M relationship. func (userL) LoadPushTokens(ctx context.Context, e boil.ContextExecutor, singular bool, maybeUser interface{}, mods queries.Applicator) error { var slice []*User var object *User if singular { var ok bool object, ok = maybeUser.(*User) if !ok { object = new(User) ok = queries.SetFromEmbeddedStruct(&object, &maybeUser) if !ok { return errors.New(fmt.Sprintf("failed to set %T from embedded struct %T", object, maybeUser)) } } } else { s, ok := maybeUser.(*[]*User) if ok { slice = *s } else { ok = queries.SetFromEmbeddedStruct(&slice, maybeUser) if !ok { return errors.New(fmt.Sprintf("failed to set %T from embedded struct %T", slice, maybeUser)) } } } args := make(map[interface{}]struct{}) if singular { if object.R == nil { object.R = &userR{} } args[object.ID] = struct{}{} } else { for _, obj := range slice { if obj.R == nil { obj.R = &userR{} } args[obj.ID] = struct{}{} } } if len(args) == 0 { return nil } argsSlice := make([]interface{}, len(args)) i := 0 for arg := range args { argsSlice[i] = arg i++ } query := NewQuery( qm.From(`push_tokens`), qm.WhereIn(`push_tokens.user_id in ?`, argsSlice...), ) if mods != nil { mods.Apply(query) } results, err := query.QueryContext(ctx, e) if err != nil { return errors.Wrap(err, "failed to eager load push_tokens") } var resultSlice []*PushToken if err = queries.Bind(results, &resultSlice); err != nil { return errors.Wrap(err, "failed to bind eager loaded slice push_tokens") } if err = results.Close(); err != nil { return errors.Wrap(err, "failed to close results in eager load on push_tokens") } if err = results.Err(); err != nil { return errors.Wrap(err, "error occurred during iteration of eager loaded relations for push_tokens") } if singular { object.R.PushTokens = resultSlice for _, foreign := range resultSlice { if foreign.R == nil { foreign.R = &pushTokenR{} } foreign.R.User = object } return nil } for _, foreign := range resultSlice { for _, local := range slice { if local.ID == foreign.UserID { local.R.PushTokens = append(local.R.PushTokens, foreign) if foreign.R == nil { foreign.R = &pushTokenR{} } foreign.R.User = local break } } } return nil } // LoadRefreshTokens allows an eager lookup of values, cached into the // loaded structs of the objects. This is for a 1-M or N-M relationship. func (userL) LoadRefreshTokens(ctx context.Context, e boil.ContextExecutor, singular bool, maybeUser interface{}, mods queries.Applicator) error { var slice []*User var object *User if singular { var ok bool object, ok = maybeUser.(*User) if !ok { object = new(User) ok = queries.SetFromEmbeddedStruct(&object, &maybeUser) if !ok { return errors.New(fmt.Sprintf("failed to set %T from embedded struct %T", object, maybeUser)) } } } else { s, ok := maybeUser.(*[]*User) if ok { slice = *s } else { ok = queries.SetFromEmbeddedStruct(&slice, maybeUser) if !ok { return errors.New(fmt.Sprintf("failed to set %T from embedded struct %T", slice, maybeUser)) } } } args := make(map[interface{}]struct{}) if singular { if object.R == nil { object.R = &userR{} } args[object.ID] = struct{}{} } else { for _, obj := range slice { if obj.R == nil { obj.R = &userR{} } args[obj.ID] = struct{}{} } } if len(args) == 0 { return nil } argsSlice := make([]interface{}, len(args)) i := 0 for arg := range args { argsSlice[i] = arg i++ } query := NewQuery( qm.From(`refresh_tokens`), qm.WhereIn(`refresh_tokens.user_id in ?`, argsSlice...), ) if mods != nil { mods.Apply(query) } results, err := query.QueryContext(ctx, e) if err != nil { return errors.Wrap(err, "failed to eager load refresh_tokens") } var resultSlice []*RefreshToken if err = queries.Bind(results, &resultSlice); err != nil { return errors.Wrap(err, "failed to bind eager loaded slice refresh_tokens") } if err = results.Close(); err != nil { return errors.Wrap(err, "failed to close results in eager load on refresh_tokens") } if err = results.Err(); err != nil { return errors.Wrap(err, "error occurred during iteration of eager loaded relations for refresh_tokens") } if singular { object.R.RefreshTokens = resultSlice for _, foreign := range resultSlice { if foreign.R == nil { foreign.R = &refreshTokenR{} } foreign.R.User = object } return nil } for _, foreign := range resultSlice { for _, local := range slice { if local.ID == foreign.UserID { local.R.RefreshTokens = append(local.R.RefreshTokens, foreign) if foreign.R == nil { foreign.R = &refreshTokenR{} } foreign.R.User = local break } } } return nil } // SetAppUserProfile of the user to the related item. // Sets o.R.AppUserProfile to related. // Adds o to related.R.User. func (o *User) SetAppUserProfile(ctx context.Context, exec boil.ContextExecutor, insert bool, related *AppUserProfile) error { var err error if insert { related.UserID = o.ID if err = related.Insert(ctx, exec, boil.Infer()); err != nil { return errors.Wrap(err, "failed to insert into foreign table") } } else { updateQuery := fmt.Sprintf( "UPDATE \"app_user_profiles\" SET %s WHERE %s", strmangle.SetParamNames("\"", "\"", 1, []string{"user_id"}), strmangle.WhereClause("\"", "\"", 2, appUserProfilePrimaryKeyColumns), ) values := []interface{}{o.ID, related.UserID} if boil.IsDebug(ctx) { writer := boil.DebugWriterFrom(ctx) fmt.Fprintln(writer, updateQuery) fmt.Fprintln(writer, values) } if _, err = exec.ExecContext(ctx, updateQuery, values...); err != nil { return errors.Wrap(err, "failed to update foreign table") } related.UserID = o.ID } if o.R == nil { o.R = &userR{ AppUserProfile: related, } } else { o.R.AppUserProfile = related } if related.R == nil { related.R = &appUserProfileR{ User: o, } } else { related.R.User = o } return nil } // AddAccessTokens adds the given related objects to the existing relationships // of the user, optionally inserting them as new records. // Appends related to o.R.AccessTokens. // Sets related.R.User appropriately. func (o *User) AddAccessTokens(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*AccessToken) error { var err error for _, rel := range related { if insert { rel.UserID = o.ID if err = rel.Insert(ctx, exec, boil.Infer()); err != nil { return errors.Wrap(err, "failed to insert into foreign table") } } else { updateQuery := fmt.Sprintf( "UPDATE \"access_tokens\" SET %s WHERE %s", strmangle.SetParamNames("\"", "\"", 1, []string{"user_id"}), strmangle.WhereClause("\"", "\"", 2, accessTokenPrimaryKeyColumns), ) values := []interface{}{o.ID, rel.Token} if boil.IsDebug(ctx) { writer := boil.DebugWriterFrom(ctx) fmt.Fprintln(writer, updateQuery) fmt.Fprintln(writer, values) } if _, err = exec.ExecContext(ctx, updateQuery, values...); err != nil { return errors.Wrap(err, "failed to update foreign table") } rel.UserID = o.ID } } if o.R == nil { o.R = &userR{ AccessTokens: related, } } else { o.R.AccessTokens = append(o.R.AccessTokens, related...) } for _, rel := range related { if rel.R == nil { rel.R = &accessTokenR{ User: o, } } else { rel.R.User = o } } return nil } // AddConfirmationTokens adds the given related objects to the existing relationships // of the user, optionally inserting them as new records. // Appends related to o.R.ConfirmationTokens. // Sets related.R.User appropriately. func (o *User) AddConfirmationTokens(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*ConfirmationToken) error { var err error for _, rel := range related { if insert { rel.UserID = o.ID if err = rel.Insert(ctx, exec, boil.Infer()); err != nil { return errors.Wrap(err, "failed to insert into foreign table") } } else { updateQuery := fmt.Sprintf( "UPDATE \"confirmation_tokens\" SET %s WHERE %s", strmangle.SetParamNames("\"", "\"", 1, []string{"user_id"}), strmangle.WhereClause("\"", "\"", 2, confirmationTokenPrimaryKeyColumns), ) values := []interface{}{o.ID, rel.Token} if boil.IsDebug(ctx) { writer := boil.DebugWriterFrom(ctx) fmt.Fprintln(writer, updateQuery) fmt.Fprintln(writer, values) } if _, err = exec.ExecContext(ctx, updateQuery, values...); err != nil { return errors.Wrap(err, "failed to update foreign table") } rel.UserID = o.ID } } if o.R == nil { o.R = &userR{ ConfirmationTokens: related, } } else { o.R.ConfirmationTokens = append(o.R.ConfirmationTokens, related...) } for _, rel := range related { if rel.R == nil { rel.R = &confirmationTokenR{ User: o, } } else { rel.R.User = o } } return nil } // AddPasswordResetTokens adds the given related objects to the existing relationships // of the user, optionally inserting them as new records. // Appends related to o.R.PasswordResetTokens. // Sets related.R.User appropriately. func (o *User) AddPasswordResetTokens(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*PasswordResetToken) error { var err error for _, rel := range related { if insert { rel.UserID = o.ID if err = rel.Insert(ctx, exec, boil.Infer()); err != nil { return errors.Wrap(err, "failed to insert into foreign table") } } else { updateQuery := fmt.Sprintf( "UPDATE \"password_reset_tokens\" SET %s WHERE %s", strmangle.SetParamNames("\"", "\"", 1, []string{"user_id"}), strmangle.WhereClause("\"", "\"", 2, passwordResetTokenPrimaryKeyColumns), ) values := []interface{}{o.ID, rel.Token} if boil.IsDebug(ctx) { writer := boil.DebugWriterFrom(ctx) fmt.Fprintln(writer, updateQuery) fmt.Fprintln(writer, values) } if _, err = exec.ExecContext(ctx, updateQuery, values...); err != nil { return errors.Wrap(err, "failed to update foreign table") } rel.UserID = o.ID } } if o.R == nil { o.R = &userR{ PasswordResetTokens: related, } } else { o.R.PasswordResetTokens = append(o.R.PasswordResetTokens, related...) } for _, rel := range related { if rel.R == nil { rel.R = &passwordResetTokenR{ User: o, } } else { rel.R.User = o } } return nil } // AddPushTokens adds the given related objects to the existing relationships // of the user, optionally inserting them as new records. // Appends related to o.R.PushTokens. // Sets related.R.User appropriately. func (o *User) AddPushTokens(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*PushToken) error { var err error for _, rel := range related { if insert { rel.UserID = o.ID if err = rel.Insert(ctx, exec, boil.Infer()); err != nil { return errors.Wrap(err, "failed to insert into foreign table") } } else { updateQuery := fmt.Sprintf( "UPDATE \"push_tokens\" SET %s WHERE %s", strmangle.SetParamNames("\"", "\"", 1, []string{"user_id"}), strmangle.WhereClause("\"", "\"", 2, pushTokenPrimaryKeyColumns), ) values := []interface{}{o.ID, rel.ID} if boil.IsDebug(ctx) { writer := boil.DebugWriterFrom(ctx) fmt.Fprintln(writer, updateQuery) fmt.Fprintln(writer, values) } if _, err = exec.ExecContext(ctx, updateQuery, values...); err != nil { return errors.Wrap(err, "failed to update foreign table") } rel.UserID = o.ID } } if o.R == nil { o.R = &userR{ PushTokens: related, } } else { o.R.PushTokens = append(o.R.PushTokens, related...) } for _, rel := range related { if rel.R == nil { rel.R = &pushTokenR{ User: o, } } else { rel.R.User = o } } return nil } // AddRefreshTokens adds the given related objects to the existing relationships // of the user, optionally inserting them as new records. // Appends related to o.R.RefreshTokens. // Sets related.R.User appropriately. func (o *User) AddRefreshTokens(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*RefreshToken) error { var err error for _, rel := range related { if insert { rel.UserID = o.ID if err = rel.Insert(ctx, exec, boil.Infer()); err != nil { return errors.Wrap(err, "failed to insert into foreign table") } } else { updateQuery := fmt.Sprintf( "UPDATE \"refresh_tokens\" SET %s WHERE %s", strmangle.SetParamNames("\"", "\"", 1, []string{"user_id"}), strmangle.WhereClause("\"", "\"", 2, refreshTokenPrimaryKeyColumns), ) values := []interface{}{o.ID, rel.Token} if boil.IsDebug(ctx) { writer := boil.DebugWriterFrom(ctx) fmt.Fprintln(writer, updateQuery) fmt.Fprintln(writer, values) } if _, err = exec.ExecContext(ctx, updateQuery, values...); err != nil { return errors.Wrap(err, "failed to update foreign table") } rel.UserID = o.ID } } if o.R == nil { o.R = &userR{ RefreshTokens: related, } } else { o.R.RefreshTokens = append(o.R.RefreshTokens, related...) } for _, rel := range related { if rel.R == nil { rel.R = &refreshTokenR{ User: o, } } else { rel.R.User = o } } return nil } // Users retrieves all the records using an executor. func Users(mods ...qm.QueryMod) userQuery { mods = append(mods, qm.From("\"users\"")) q := NewQuery(mods...) if len(queries.GetSelect(q)) == 0 { queries.SetSelect(q, []string{"\"users\".*"}) } return userQuery{q} } // FindUser retrieves a single record by ID with an executor. // If selectCols is empty Find will return all columns. func FindUser(ctx context.Context, exec boil.ContextExecutor, iD string, selectCols ...string) (*User, error) { userObj := &User{} sel := "*" if len(selectCols) > 0 { sel = strings.Join(strmangle.IdentQuoteSlice(dialect.LQ, dialect.RQ, selectCols), ",") } query := fmt.Sprintf( "select %s from \"users\" where \"id\"=$1", sel, ) q := queries.Raw(query, iD) err := q.Bind(ctx, exec, userObj) if err != nil { if errors.Is(err, sql.ErrNoRows) { return nil, sql.ErrNoRows } return nil, errors.Wrap(err, "models: unable to select from users") } return userObj, nil } // Insert a single record using an executor. // See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts. func (o *User) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error { if o == nil { return errors.New("models: no users provided for insertion") } var err error if !boil.TimestampsAreSkipped(ctx) { currTime := time.Now().In(boil.GetLocation()) if o.CreatedAt.IsZero() { o.CreatedAt = currTime } if o.UpdatedAt.IsZero() { o.UpdatedAt = currTime } } nzDefaults := queries.NonZeroDefaultSet(userColumnsWithDefault, o) key := makeCacheKey(columns, nzDefaults) userInsertCacheMut.RLock() cache, cached := userInsertCache[key] userInsertCacheMut.RUnlock() if !cached { wl, returnColumns := columns.InsertColumnSet( userAllColumns, userColumnsWithDefault, userColumnsWithoutDefault, nzDefaults, ) cache.valueMapping, err = queries.BindMapping(userType, userMapping, wl) if err != nil { return err } cache.retMapping, err = queries.BindMapping(userType, userMapping, returnColumns) if err != nil { return err } if len(wl) != 0 { cache.query = fmt.Sprintf("INSERT INTO \"users\" (\"%s\") %%sVALUES (%s)%%s", strings.Join(wl, "\",\""), strmangle.Placeholders(dialect.UseIndexPlaceholders, len(wl), 1, 1)) } else { cache.query = "INSERT INTO \"users\" %sDEFAULT VALUES%s" } var queryOutput, queryReturning string if len(cache.retMapping) != 0 { queryReturning = fmt.Sprintf(" RETURNING \"%s\"", strings.Join(returnColumns, "\",\"")) } cache.query = fmt.Sprintf(cache.query, queryOutput, queryReturning) } value := reflect.Indirect(reflect.ValueOf(o)) vals := queries.ValuesFromMapping(value, cache.valueMapping) if boil.IsDebug(ctx) { writer := boil.DebugWriterFrom(ctx) fmt.Fprintln(writer, cache.query) fmt.Fprintln(writer, vals) } if len(cache.retMapping) != 0 { err = exec.QueryRowContext(ctx, cache.query, vals...).Scan(queries.PtrsFromMapping(value, cache.retMapping)...) } else { _, err = exec.ExecContext(ctx, cache.query, vals...) } if err != nil { return errors.Wrap(err, "models: unable to insert into users") } if !cached { userInsertCacheMut.Lock() userInsertCache[key] = cache userInsertCacheMut.Unlock() } return nil } // Update uses an executor to update the User. // See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. // Update does not automatically update the record in case of default values. Use .Reload() to refresh the records. func (o *User) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error) { if !boil.TimestampsAreSkipped(ctx) { currTime := time.Now().In(boil.GetLocation()) o.UpdatedAt = currTime } var err error key := makeCacheKey(columns, nil) userUpdateCacheMut.RLock() cache, cached := userUpdateCache[key] userUpdateCacheMut.RUnlock() if !cached { wl := columns.UpdateColumnSet( userAllColumns, userPrimaryKeyColumns, ) if !columns.IsWhitelist() { wl = strmangle.SetComplement(wl, []string{"created_at"}) } if len(wl) == 0 { return 0, errors.New("models: unable to update users, could not build whitelist") } cache.query = fmt.Sprintf("UPDATE \"users\" SET %s WHERE %s", strmangle.SetParamNames("\"", "\"", 1, wl), strmangle.WhereClause("\"", "\"", len(wl)+1, userPrimaryKeyColumns), ) cache.valueMapping, err = queries.BindMapping(userType, userMapping, append(wl, userPrimaryKeyColumns...)) if err != nil { return 0, err } } values := queries.ValuesFromMapping(reflect.Indirect(reflect.ValueOf(o)), cache.valueMapping) if boil.IsDebug(ctx) { writer := boil.DebugWriterFrom(ctx) fmt.Fprintln(writer, cache.query) fmt.Fprintln(writer, values) } var result sql.Result result, err = exec.ExecContext(ctx, cache.query, values...) if err != nil { return 0, errors.Wrap(err, "models: unable to update users row") } rowsAff, err := result.RowsAffected() if err != nil { return 0, errors.Wrap(err, "models: failed to get rows affected by update for users") } if !cached { userUpdateCacheMut.Lock() userUpdateCache[key] = cache userUpdateCacheMut.Unlock() } return rowsAff, nil } // UpdateAll updates all rows with the specified column values. func (q userQuery) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error) { queries.SetUpdate(q.Query, cols) result, err := q.Query.ExecContext(ctx, exec) if err != nil { return 0, errors.Wrap(err, "models: unable to update all for users") } rowsAff, err := result.RowsAffected() if err != nil { return 0, errors.Wrap(err, "models: unable to retrieve rows affected for users") } return rowsAff, nil } // UpdateAll updates all rows with the specified column values, using an executor. func (o UserSlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error) { ln := int64(len(o)) if ln == 0 { return 0, nil } if len(cols) == 0 { return 0, errors.New("models: update all requires at least one column argument") } colNames := make([]string, len(cols)) args := make([]interface{}, len(cols)) i := 0 for name, value := range cols { colNames[i] = name args[i] = value i++ } // Append all of the primary key values for each column for _, obj := range o { pkeyArgs := queries.ValuesFromMapping(reflect.Indirect(reflect.ValueOf(obj)), userPrimaryKeyMapping) args = append(args, pkeyArgs...) } sql := fmt.Sprintf("UPDATE \"users\" SET %s WHERE %s", strmangle.SetParamNames("\"", "\"", 1, colNames), strmangle.WhereClauseRepeated(string(dialect.LQ), string(dialect.RQ), len(colNames)+1, userPrimaryKeyColumns, len(o))) if boil.IsDebug(ctx) { writer := boil.DebugWriterFrom(ctx) fmt.Fprintln(writer, sql) fmt.Fprintln(writer, args...) } result, err := exec.ExecContext(ctx, sql, args...) if err != nil { return 0, errors.Wrap(err, "models: unable to update all in user slice") } rowsAff, err := result.RowsAffected() if err != nil { return 0, errors.Wrap(err, "models: unable to retrieve rows affected all in update all user") } return rowsAff, nil } // Upsert attempts an insert using an executor, and does an update or ignore on conflict. // See boil.Columns documentation for how to properly use updateColumns and insertColumns. func (o *User) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns, opts ...UpsertOptionFunc) error { if o == nil { return errors.New("models: no users provided for upsert") } if !boil.TimestampsAreSkipped(ctx) { currTime := time.Now().In(boil.GetLocation()) if o.CreatedAt.IsZero() { o.CreatedAt = currTime } o.UpdatedAt = currTime } nzDefaults := queries.NonZeroDefaultSet(userColumnsWithDefault, o) // Build cache key in-line uglily - mysql vs psql problems buf := strmangle.GetBuffer() if updateOnConflict { buf.WriteByte('t') } else { buf.WriteByte('f') } buf.WriteByte('.') for _, c := range conflictColumns { buf.WriteString(c) } buf.WriteByte('.') buf.WriteString(strconv.Itoa(updateColumns.Kind)) for _, c := range updateColumns.Cols { buf.WriteString(c) } buf.WriteByte('.') buf.WriteString(strconv.Itoa(insertColumns.Kind)) for _, c := range insertColumns.Cols { buf.WriteString(c) } buf.WriteByte('.') for _, c := range nzDefaults { buf.WriteString(c) } key := buf.String() strmangle.PutBuffer(buf) userUpsertCacheMut.RLock() cache, cached := userUpsertCache[key] userUpsertCacheMut.RUnlock() var err error if !cached { insert, _ := insertColumns.InsertColumnSet( userAllColumns, userColumnsWithDefault, userColumnsWithoutDefault, nzDefaults, ) update := updateColumns.UpdateColumnSet( userAllColumns, userPrimaryKeyColumns, ) if updateOnConflict && len(update) == 0 { return errors.New("models: unable to upsert users, could not build update column list") } ret := strmangle.SetComplement(userAllColumns, strmangle.SetIntersect(insert, update)) conflict := conflictColumns if len(conflict) == 0 && updateOnConflict && len(update) != 0 { if len(userPrimaryKeyColumns) == 0 { return errors.New("models: unable to upsert users, could not build conflict column list") } conflict = make([]string, len(userPrimaryKeyColumns)) copy(conflict, userPrimaryKeyColumns) } cache.query = buildUpsertQueryPostgres(dialect, "\"users\"", updateOnConflict, ret, update, conflict, insert, opts...) cache.valueMapping, err = queries.BindMapping(userType, userMapping, insert) if err != nil { return err } if len(ret) != 0 { cache.retMapping, err = queries.BindMapping(userType, userMapping, ret) if err != nil { return err } } } value := reflect.Indirect(reflect.ValueOf(o)) vals := queries.ValuesFromMapping(value, cache.valueMapping) var returns []interface{} if len(cache.retMapping) != 0 { returns = queries.PtrsFromMapping(value, cache.retMapping) } if boil.IsDebug(ctx) { writer := boil.DebugWriterFrom(ctx) fmt.Fprintln(writer, cache.query) fmt.Fprintln(writer, vals) } if len(cache.retMapping) != 0 { err = exec.QueryRowContext(ctx, cache.query, vals...).Scan(returns...) if errors.Is(err, sql.ErrNoRows) { err = nil // Postgres doesn't return anything when there's no update } } else { _, err = exec.ExecContext(ctx, cache.query, vals...) } if err != nil { return errors.Wrap(err, "models: unable to upsert users") } if !cached { userUpsertCacheMut.Lock() userUpsertCache[key] = cache userUpsertCacheMut.Unlock() } return nil } // Delete deletes a single User record with an executor. // Delete will match against the primary key column to find the record to delete. func (o *User) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error) { if o == nil { return 0, errors.New("models: no User provided for delete") } args := queries.ValuesFromMapping(reflect.Indirect(reflect.ValueOf(o)), userPrimaryKeyMapping) sql := "DELETE FROM \"users\" WHERE \"id\"=$1" if boil.IsDebug(ctx) { writer := boil.DebugWriterFrom(ctx) fmt.Fprintln(writer, sql) fmt.Fprintln(writer, args...) } result, err := exec.ExecContext(ctx, sql, args...) if err != nil { return 0, errors.Wrap(err, "models: unable to delete from users") } rowsAff, err := result.RowsAffected() if err != nil { return 0, errors.Wrap(err, "models: failed to get rows affected by delete for users") } return rowsAff, nil } // DeleteAll deletes all matching rows. func (q userQuery) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error) { if q.Query == nil { return 0, errors.New("models: no userQuery provided for delete all") } queries.SetDelete(q.Query) result, err := q.Query.ExecContext(ctx, exec) if err != nil { return 0, errors.Wrap(err, "models: unable to delete all from users") } rowsAff, err := result.RowsAffected() if err != nil { return 0, errors.Wrap(err, "models: failed to get rows affected by deleteall for users") } return rowsAff, nil } // DeleteAll deletes all rows in the slice, using an executor. func (o UserSlice) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error) { if len(o) == 0 { return 0, nil } var args []interface{} for _, obj := range o { pkeyArgs := queries.ValuesFromMapping(reflect.Indirect(reflect.ValueOf(obj)), userPrimaryKeyMapping) args = append(args, pkeyArgs...) } sql := "DELETE FROM \"users\" WHERE " + strmangle.WhereClauseRepeated(string(dialect.LQ), string(dialect.RQ), 1, userPrimaryKeyColumns, len(o)) if boil.IsDebug(ctx) { writer := boil.DebugWriterFrom(ctx) fmt.Fprintln(writer, sql) fmt.Fprintln(writer, args) } result, err := exec.ExecContext(ctx, sql, args...) if err != nil { return 0, errors.Wrap(err, "models: unable to delete all from user slice") } rowsAff, err := result.RowsAffected() if err != nil { return 0, errors.Wrap(err, "models: failed to get rows affected by deleteall for users") } return rowsAff, nil } // Reload refetches the object from the database // using the primary keys with an executor. func (o *User) Reload(ctx context.Context, exec boil.ContextExecutor) error { ret, err := FindUser(ctx, exec, o.ID) if err != nil { return err } *o = *ret return nil } // ReloadAll refetches every row with matching primary key column values // and overwrites the original object slice with the newly updated slice. func (o *UserSlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error { if o == nil || len(*o) == 0 { return nil } slice := UserSlice{} var args []interface{} for _, obj := range *o { pkeyArgs := queries.ValuesFromMapping(reflect.Indirect(reflect.ValueOf(obj)), userPrimaryKeyMapping) args = append(args, pkeyArgs...) } sql := "SELECT \"users\".* FROM \"users\" WHERE " + strmangle.WhereClauseRepeated(string(dialect.LQ), string(dialect.RQ), 1, userPrimaryKeyColumns, len(*o)) q := queries.Raw(sql, args...) err := q.Bind(ctx, exec, &slice) if err != nil { return errors.Wrap(err, "models: unable to reload all in UserSlice") } *o = slice return nil } // UserExists checks if the User row exists. func UserExists(ctx context.Context, exec boil.ContextExecutor, iD string) (bool, error) { var exists bool sql := "select exists(select 1 from \"users\" where \"id\"=$1 limit 1)" if boil.IsDebug(ctx) { writer := boil.DebugWriterFrom(ctx) fmt.Fprintln(writer, sql) fmt.Fprintln(writer, iD) } row := exec.QueryRowContext(ctx, sql, iD) err := row.Scan(&exists) if err != nil { return false, errors.Wrap(err, "models: unable to check if users exists") } return exists, nil } // Exists checks if the User row exists. func (o *User) Exists(ctx context.Context, exec boil.ContextExecutor) (bool, error) { return UserExists(ctx, exec, o.ID) }