// Code generated by BobGen psql v0.41.1. DO NOT EDIT. // This file is meant to be re-generated in place and/or deleted at any time. package models import ( "context" "fmt" "io" "time" "github.com/aarondl/opt/null" "github.com/aarondl/opt/omit" "github.com/aarondl/opt/omitnull" "github.com/stephenafamo/bob" "github.com/stephenafamo/bob/dialect/psql" "github.com/stephenafamo/bob/dialect/psql/dialect" "github.com/stephenafamo/bob/dialect/psql/dm" "github.com/stephenafamo/bob/dialect/psql/sm" "github.com/stephenafamo/bob/dialect/psql/um" "github.com/stephenafamo/bob/expr" "github.com/stephenafamo/bob/mods" "github.com/stephenafamo/bob/orm" "github.com/stephenafamo/bob/types/pgtypes" ) // FSSpeciesabundance is an object representing the database table. type FSSpeciesabundance struct { OrganizationID int32 `db:"organization_id" ` Bloodedfem null.Val[int16] `db:"bloodedfem" ` Creationdate null.Val[int64] `db:"creationdate" ` Creator null.Val[string] `db:"creator" ` Eggs null.Val[int16] `db:"eggs" ` Editdate null.Val[int64] `db:"editdate" ` Editor null.Val[string] `db:"editor" ` Females null.Val[int64] `db:"females" ` Gravidfem null.Val[int16] `db:"gravidfem" ` Globalid string `db:"globalid" ` Larvae null.Val[int16] `db:"larvae" ` Males null.Val[int16] `db:"males" ` Objectid int32 `db:"objectid,pk" ` Poolstogen null.Val[int16] `db:"poolstogen" ` Processed null.Val[int16] `db:"processed" ` Pupae null.Val[int16] `db:"pupae" ` Species null.Val[string] `db:"species" ` Total null.Val[int64] `db:"total" ` TrapdataID null.Val[string] `db:"trapdata_id" ` Unknown null.Val[int16] `db:"unknown" ` CreatedDate null.Val[int64] `db:"created_date" ` CreatedUser null.Val[string] `db:"created_user" ` GeometryX null.Val[float64] `db:"geometry_x" ` GeometryY null.Val[float64] `db:"geometry_y" ` LastEditedDate null.Val[int64] `db:"last_edited_date" ` LastEditedUser null.Val[string] `db:"last_edited_user" ` Globalzscore null.Val[float64] `db:"globalzscore" ` H3R7 null.Val[string] `db:"h3r7" ` H3R8 null.Val[string] `db:"h3r8" ` R7score null.Val[float64] `db:"r7score" ` R8score null.Val[float64] `db:"r8score" ` Yearweek null.Val[int64] `db:"yearweek" ` Updated time.Time `db:"updated" ` R fsSpeciesabundanceR `db:"-" ` } // FSSpeciesabundanceSlice is an alias for a slice of pointers to FSSpeciesabundance. // This should almost always be used instead of []*FSSpeciesabundance. type FSSpeciesabundanceSlice []*FSSpeciesabundance // FSSpeciesabundances contains methods to work with the fs_speciesabundance table var FSSpeciesabundances = psql.NewTablex[*FSSpeciesabundance, FSSpeciesabundanceSlice, *FSSpeciesabundanceSetter]("", "fs_speciesabundance", buildFSSpeciesabundanceColumns("fs_speciesabundance")) // FSSpeciesabundancesQuery is a query on the fs_speciesabundance table type FSSpeciesabundancesQuery = *psql.ViewQuery[*FSSpeciesabundance, FSSpeciesabundanceSlice] // fsSpeciesabundanceR is where relationships are stored. type fsSpeciesabundanceR struct { Organization *Organization // fs_speciesabundance.fs_speciesabundance_organization_id_fkey } func buildFSSpeciesabundanceColumns(alias string) fsSpeciesabundanceColumns { return fsSpeciesabundanceColumns{ ColumnsExpr: expr.NewColumnsExpr( "organization_id", "bloodedfem", "creationdate", "creator", "eggs", "editdate", "editor", "females", "gravidfem", "globalid", "larvae", "males", "objectid", "poolstogen", "processed", "pupae", "species", "total", "trapdata_id", "unknown", "created_date", "created_user", "geometry_x", "geometry_y", "last_edited_date", "last_edited_user", "globalzscore", "h3r7", "h3r8", "r7score", "r8score", "yearweek", "updated", ).WithParent("fs_speciesabundance"), tableAlias: alias, OrganizationID: psql.Quote(alias, "organization_id"), Bloodedfem: psql.Quote(alias, "bloodedfem"), Creationdate: psql.Quote(alias, "creationdate"), Creator: psql.Quote(alias, "creator"), Eggs: psql.Quote(alias, "eggs"), Editdate: psql.Quote(alias, "editdate"), Editor: psql.Quote(alias, "editor"), Females: psql.Quote(alias, "females"), Gravidfem: psql.Quote(alias, "gravidfem"), Globalid: psql.Quote(alias, "globalid"), Larvae: psql.Quote(alias, "larvae"), Males: psql.Quote(alias, "males"), Objectid: psql.Quote(alias, "objectid"), Poolstogen: psql.Quote(alias, "poolstogen"), Processed: psql.Quote(alias, "processed"), Pupae: psql.Quote(alias, "pupae"), Species: psql.Quote(alias, "species"), Total: psql.Quote(alias, "total"), TrapdataID: psql.Quote(alias, "trapdata_id"), Unknown: psql.Quote(alias, "unknown"), CreatedDate: psql.Quote(alias, "created_date"), CreatedUser: psql.Quote(alias, "created_user"), GeometryX: psql.Quote(alias, "geometry_x"), GeometryY: psql.Quote(alias, "geometry_y"), LastEditedDate: psql.Quote(alias, "last_edited_date"), LastEditedUser: psql.Quote(alias, "last_edited_user"), Globalzscore: psql.Quote(alias, "globalzscore"), H3R7: psql.Quote(alias, "h3r7"), H3R8: psql.Quote(alias, "h3r8"), R7score: psql.Quote(alias, "r7score"), R8score: psql.Quote(alias, "r8score"), Yearweek: psql.Quote(alias, "yearweek"), Updated: psql.Quote(alias, "updated"), } } type fsSpeciesabundanceColumns struct { expr.ColumnsExpr tableAlias string OrganizationID psql.Expression Bloodedfem psql.Expression Creationdate psql.Expression Creator psql.Expression Eggs psql.Expression Editdate psql.Expression Editor psql.Expression Females psql.Expression Gravidfem psql.Expression Globalid psql.Expression Larvae psql.Expression Males psql.Expression Objectid psql.Expression Poolstogen psql.Expression Processed psql.Expression Pupae psql.Expression Species psql.Expression Total psql.Expression TrapdataID psql.Expression Unknown psql.Expression CreatedDate psql.Expression CreatedUser psql.Expression GeometryX psql.Expression GeometryY psql.Expression LastEditedDate psql.Expression LastEditedUser psql.Expression Globalzscore psql.Expression H3R7 psql.Expression H3R8 psql.Expression R7score psql.Expression R8score psql.Expression Yearweek psql.Expression Updated psql.Expression } func (c fsSpeciesabundanceColumns) Alias() string { return c.tableAlias } func (fsSpeciesabundanceColumns) AliasedAs(alias string) fsSpeciesabundanceColumns { return buildFSSpeciesabundanceColumns(alias) } // FSSpeciesabundanceSetter is used for insert/upsert/update operations // All values are optional, and do not have to be set // Generated columns are not included type FSSpeciesabundanceSetter struct { OrganizationID omit.Val[int32] `db:"organization_id" ` Bloodedfem omitnull.Val[int16] `db:"bloodedfem" ` Creationdate omitnull.Val[int64] `db:"creationdate" ` Creator omitnull.Val[string] `db:"creator" ` Eggs omitnull.Val[int16] `db:"eggs" ` Editdate omitnull.Val[int64] `db:"editdate" ` Editor omitnull.Val[string] `db:"editor" ` Females omitnull.Val[int64] `db:"females" ` Gravidfem omitnull.Val[int16] `db:"gravidfem" ` Globalid omit.Val[string] `db:"globalid" ` Larvae omitnull.Val[int16] `db:"larvae" ` Males omitnull.Val[int16] `db:"males" ` Objectid omit.Val[int32] `db:"objectid,pk" ` Poolstogen omitnull.Val[int16] `db:"poolstogen" ` Processed omitnull.Val[int16] `db:"processed" ` Pupae omitnull.Val[int16] `db:"pupae" ` Species omitnull.Val[string] `db:"species" ` Total omitnull.Val[int64] `db:"total" ` TrapdataID omitnull.Val[string] `db:"trapdata_id" ` Unknown omitnull.Val[int16] `db:"unknown" ` CreatedDate omitnull.Val[int64] `db:"created_date" ` CreatedUser omitnull.Val[string] `db:"created_user" ` GeometryX omitnull.Val[float64] `db:"geometry_x" ` GeometryY omitnull.Val[float64] `db:"geometry_y" ` LastEditedDate omitnull.Val[int64] `db:"last_edited_date" ` LastEditedUser omitnull.Val[string] `db:"last_edited_user" ` Globalzscore omitnull.Val[float64] `db:"globalzscore" ` H3R7 omitnull.Val[string] `db:"h3r7" ` H3R8 omitnull.Val[string] `db:"h3r8" ` R7score omitnull.Val[float64] `db:"r7score" ` R8score omitnull.Val[float64] `db:"r8score" ` Yearweek omitnull.Val[int64] `db:"yearweek" ` Updated omit.Val[time.Time] `db:"updated" ` } func (s FSSpeciesabundanceSetter) SetColumns() []string { vals := make([]string, 0, 33) if s.OrganizationID.IsValue() { vals = append(vals, "organization_id") } if !s.Bloodedfem.IsUnset() { vals = append(vals, "bloodedfem") } if !s.Creationdate.IsUnset() { vals = append(vals, "creationdate") } if !s.Creator.IsUnset() { vals = append(vals, "creator") } if !s.Eggs.IsUnset() { vals = append(vals, "eggs") } if !s.Editdate.IsUnset() { vals = append(vals, "editdate") } if !s.Editor.IsUnset() { vals = append(vals, "editor") } if !s.Females.IsUnset() { vals = append(vals, "females") } if !s.Gravidfem.IsUnset() { vals = append(vals, "gravidfem") } if s.Globalid.IsValue() { vals = append(vals, "globalid") } if !s.Larvae.IsUnset() { vals = append(vals, "larvae") } if !s.Males.IsUnset() { vals = append(vals, "males") } if s.Objectid.IsValue() { vals = append(vals, "objectid") } if !s.Poolstogen.IsUnset() { vals = append(vals, "poolstogen") } if !s.Processed.IsUnset() { vals = append(vals, "processed") } if !s.Pupae.IsUnset() { vals = append(vals, "pupae") } if !s.Species.IsUnset() { vals = append(vals, "species") } if !s.Total.IsUnset() { vals = append(vals, "total") } if !s.TrapdataID.IsUnset() { vals = append(vals, "trapdata_id") } if !s.Unknown.IsUnset() { vals = append(vals, "unknown") } if !s.CreatedDate.IsUnset() { vals = append(vals, "created_date") } if !s.CreatedUser.IsUnset() { vals = append(vals, "created_user") } if !s.GeometryX.IsUnset() { vals = append(vals, "geometry_x") } if !s.GeometryY.IsUnset() { vals = append(vals, "geometry_y") } if !s.LastEditedDate.IsUnset() { vals = append(vals, "last_edited_date") } if !s.LastEditedUser.IsUnset() { vals = append(vals, "last_edited_user") } if !s.Globalzscore.IsUnset() { vals = append(vals, "globalzscore") } if !s.H3R7.IsUnset() { vals = append(vals, "h3r7") } if !s.H3R8.IsUnset() { vals = append(vals, "h3r8") } if !s.R7score.IsUnset() { vals = append(vals, "r7score") } if !s.R8score.IsUnset() { vals = append(vals, "r8score") } if !s.Yearweek.IsUnset() { vals = append(vals, "yearweek") } if s.Updated.IsValue() { vals = append(vals, "updated") } return vals } func (s FSSpeciesabundanceSetter) Overwrite(t *FSSpeciesabundance) { if s.OrganizationID.IsValue() { t.OrganizationID = s.OrganizationID.MustGet() } if !s.Bloodedfem.IsUnset() { t.Bloodedfem = s.Bloodedfem.MustGetNull() } if !s.Creationdate.IsUnset() { t.Creationdate = s.Creationdate.MustGetNull() } if !s.Creator.IsUnset() { t.Creator = s.Creator.MustGetNull() } if !s.Eggs.IsUnset() { t.Eggs = s.Eggs.MustGetNull() } if !s.Editdate.IsUnset() { t.Editdate = s.Editdate.MustGetNull() } if !s.Editor.IsUnset() { t.Editor = s.Editor.MustGetNull() } if !s.Females.IsUnset() { t.Females = s.Females.MustGetNull() } if !s.Gravidfem.IsUnset() { t.Gravidfem = s.Gravidfem.MustGetNull() } if s.Globalid.IsValue() { t.Globalid = s.Globalid.MustGet() } if !s.Larvae.IsUnset() { t.Larvae = s.Larvae.MustGetNull() } if !s.Males.IsUnset() { t.Males = s.Males.MustGetNull() } if s.Objectid.IsValue() { t.Objectid = s.Objectid.MustGet() } if !s.Poolstogen.IsUnset() { t.Poolstogen = s.Poolstogen.MustGetNull() } if !s.Processed.IsUnset() { t.Processed = s.Processed.MustGetNull() } if !s.Pupae.IsUnset() { t.Pupae = s.Pupae.MustGetNull() } if !s.Species.IsUnset() { t.Species = s.Species.MustGetNull() } if !s.Total.IsUnset() { t.Total = s.Total.MustGetNull() } if !s.TrapdataID.IsUnset() { t.TrapdataID = s.TrapdataID.MustGetNull() } if !s.Unknown.IsUnset() { t.Unknown = s.Unknown.MustGetNull() } if !s.CreatedDate.IsUnset() { t.CreatedDate = s.CreatedDate.MustGetNull() } if !s.CreatedUser.IsUnset() { t.CreatedUser = s.CreatedUser.MustGetNull() } if !s.GeometryX.IsUnset() { t.GeometryX = s.GeometryX.MustGetNull() } if !s.GeometryY.IsUnset() { t.GeometryY = s.GeometryY.MustGetNull() } if !s.LastEditedDate.IsUnset() { t.LastEditedDate = s.LastEditedDate.MustGetNull() } if !s.LastEditedUser.IsUnset() { t.LastEditedUser = s.LastEditedUser.MustGetNull() } if !s.Globalzscore.IsUnset() { t.Globalzscore = s.Globalzscore.MustGetNull() } if !s.H3R7.IsUnset() { t.H3R7 = s.H3R7.MustGetNull() } if !s.H3R8.IsUnset() { t.H3R8 = s.H3R8.MustGetNull() } if !s.R7score.IsUnset() { t.R7score = s.R7score.MustGetNull() } if !s.R8score.IsUnset() { t.R8score = s.R8score.MustGetNull() } if !s.Yearweek.IsUnset() { t.Yearweek = s.Yearweek.MustGetNull() } if s.Updated.IsValue() { t.Updated = s.Updated.MustGet() } } func (s *FSSpeciesabundanceSetter) Apply(q *dialect.InsertQuery) { q.AppendHooks(func(ctx context.Context, exec bob.Executor) (context.Context, error) { return FSSpeciesabundances.BeforeInsertHooks.RunHooks(ctx, exec, s) }) q.AppendValues(bob.ExpressionFunc(func(ctx context.Context, w io.Writer, d bob.Dialect, start int) ([]any, error) { vals := make([]bob.Expression, 33) if s.OrganizationID.IsValue() { vals[0] = psql.Arg(s.OrganizationID.MustGet()) } else { vals[0] = psql.Raw("DEFAULT") } if !s.Bloodedfem.IsUnset() { vals[1] = psql.Arg(s.Bloodedfem.MustGetNull()) } else { vals[1] = psql.Raw("DEFAULT") } if !s.Creationdate.IsUnset() { vals[2] = psql.Arg(s.Creationdate.MustGetNull()) } else { vals[2] = psql.Raw("DEFAULT") } if !s.Creator.IsUnset() { vals[3] = psql.Arg(s.Creator.MustGetNull()) } else { vals[3] = psql.Raw("DEFAULT") } if !s.Eggs.IsUnset() { vals[4] = psql.Arg(s.Eggs.MustGetNull()) } else { vals[4] = psql.Raw("DEFAULT") } if !s.Editdate.IsUnset() { vals[5] = psql.Arg(s.Editdate.MustGetNull()) } else { vals[5] = psql.Raw("DEFAULT") } if !s.Editor.IsUnset() { vals[6] = psql.Arg(s.Editor.MustGetNull()) } else { vals[6] = psql.Raw("DEFAULT") } if !s.Females.IsUnset() { vals[7] = psql.Arg(s.Females.MustGetNull()) } else { vals[7] = psql.Raw("DEFAULT") } if !s.Gravidfem.IsUnset() { vals[8] = psql.Arg(s.Gravidfem.MustGetNull()) } else { vals[8] = psql.Raw("DEFAULT") } if s.Globalid.IsValue() { vals[9] = psql.Arg(s.Globalid.MustGet()) } else { vals[9] = psql.Raw("DEFAULT") } if !s.Larvae.IsUnset() { vals[10] = psql.Arg(s.Larvae.MustGetNull()) } else { vals[10] = psql.Raw("DEFAULT") } if !s.Males.IsUnset() { vals[11] = psql.Arg(s.Males.MustGetNull()) } else { vals[11] = psql.Raw("DEFAULT") } if s.Objectid.IsValue() { vals[12] = psql.Arg(s.Objectid.MustGet()) } else { vals[12] = psql.Raw("DEFAULT") } if !s.Poolstogen.IsUnset() { vals[13] = psql.Arg(s.Poolstogen.MustGetNull()) } else { vals[13] = psql.Raw("DEFAULT") } if !s.Processed.IsUnset() { vals[14] = psql.Arg(s.Processed.MustGetNull()) } else { vals[14] = psql.Raw("DEFAULT") } if !s.Pupae.IsUnset() { vals[15] = psql.Arg(s.Pupae.MustGetNull()) } else { vals[15] = psql.Raw("DEFAULT") } if !s.Species.IsUnset() { vals[16] = psql.Arg(s.Species.MustGetNull()) } else { vals[16] = psql.Raw("DEFAULT") } if !s.Total.IsUnset() { vals[17] = psql.Arg(s.Total.MustGetNull()) } else { vals[17] = psql.Raw("DEFAULT") } if !s.TrapdataID.IsUnset() { vals[18] = psql.Arg(s.TrapdataID.MustGetNull()) } else { vals[18] = psql.Raw("DEFAULT") } if !s.Unknown.IsUnset() { vals[19] = psql.Arg(s.Unknown.MustGetNull()) } else { vals[19] = psql.Raw("DEFAULT") } if !s.CreatedDate.IsUnset() { vals[20] = psql.Arg(s.CreatedDate.MustGetNull()) } else { vals[20] = psql.Raw("DEFAULT") } if !s.CreatedUser.IsUnset() { vals[21] = psql.Arg(s.CreatedUser.MustGetNull()) } else { vals[21] = psql.Raw("DEFAULT") } if !s.GeometryX.IsUnset() { vals[22] = psql.Arg(s.GeometryX.MustGetNull()) } else { vals[22] = psql.Raw("DEFAULT") } if !s.GeometryY.IsUnset() { vals[23] = psql.Arg(s.GeometryY.MustGetNull()) } else { vals[23] = psql.Raw("DEFAULT") } if !s.LastEditedDate.IsUnset() { vals[24] = psql.Arg(s.LastEditedDate.MustGetNull()) } else { vals[24] = psql.Raw("DEFAULT") } if !s.LastEditedUser.IsUnset() { vals[25] = psql.Arg(s.LastEditedUser.MustGetNull()) } else { vals[25] = psql.Raw("DEFAULT") } if !s.Globalzscore.IsUnset() { vals[26] = psql.Arg(s.Globalzscore.MustGetNull()) } else { vals[26] = psql.Raw("DEFAULT") } if !s.H3R7.IsUnset() { vals[27] = psql.Arg(s.H3R7.MustGetNull()) } else { vals[27] = psql.Raw("DEFAULT") } if !s.H3R8.IsUnset() { vals[28] = psql.Arg(s.H3R8.MustGetNull()) } else { vals[28] = psql.Raw("DEFAULT") } if !s.R7score.IsUnset() { vals[29] = psql.Arg(s.R7score.MustGetNull()) } else { vals[29] = psql.Raw("DEFAULT") } if !s.R8score.IsUnset() { vals[30] = psql.Arg(s.R8score.MustGetNull()) } else { vals[30] = psql.Raw("DEFAULT") } if !s.Yearweek.IsUnset() { vals[31] = psql.Arg(s.Yearweek.MustGetNull()) } else { vals[31] = psql.Raw("DEFAULT") } if s.Updated.IsValue() { vals[32] = psql.Arg(s.Updated.MustGet()) } else { vals[32] = psql.Raw("DEFAULT") } return bob.ExpressSlice(ctx, w, d, start, vals, "", ", ", "") })) } func (s FSSpeciesabundanceSetter) UpdateMod() bob.Mod[*dialect.UpdateQuery] { return um.Set(s.Expressions()...) } func (s FSSpeciesabundanceSetter) Expressions(prefix ...string) []bob.Expression { exprs := make([]bob.Expression, 0, 33) if s.OrganizationID.IsValue() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "organization_id")...), psql.Arg(s.OrganizationID), }}) } if !s.Bloodedfem.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "bloodedfem")...), psql.Arg(s.Bloodedfem), }}) } if !s.Creationdate.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "creationdate")...), psql.Arg(s.Creationdate), }}) } if !s.Creator.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "creator")...), psql.Arg(s.Creator), }}) } if !s.Eggs.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "eggs")...), psql.Arg(s.Eggs), }}) } if !s.Editdate.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "editdate")...), psql.Arg(s.Editdate), }}) } if !s.Editor.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "editor")...), psql.Arg(s.Editor), }}) } if !s.Females.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "females")...), psql.Arg(s.Females), }}) } if !s.Gravidfem.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "gravidfem")...), psql.Arg(s.Gravidfem), }}) } if s.Globalid.IsValue() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "globalid")...), psql.Arg(s.Globalid), }}) } if !s.Larvae.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "larvae")...), psql.Arg(s.Larvae), }}) } if !s.Males.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "males")...), psql.Arg(s.Males), }}) } if s.Objectid.IsValue() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "objectid")...), psql.Arg(s.Objectid), }}) } if !s.Poolstogen.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "poolstogen")...), psql.Arg(s.Poolstogen), }}) } if !s.Processed.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "processed")...), psql.Arg(s.Processed), }}) } if !s.Pupae.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "pupae")...), psql.Arg(s.Pupae), }}) } if !s.Species.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "species")...), psql.Arg(s.Species), }}) } if !s.Total.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "total")...), psql.Arg(s.Total), }}) } if !s.TrapdataID.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "trapdata_id")...), psql.Arg(s.TrapdataID), }}) } if !s.Unknown.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "unknown")...), psql.Arg(s.Unknown), }}) } if !s.CreatedDate.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "created_date")...), psql.Arg(s.CreatedDate), }}) } if !s.CreatedUser.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "created_user")...), psql.Arg(s.CreatedUser), }}) } if !s.GeometryX.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "geometry_x")...), psql.Arg(s.GeometryX), }}) } if !s.GeometryY.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "geometry_y")...), psql.Arg(s.GeometryY), }}) } if !s.LastEditedDate.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "last_edited_date")...), psql.Arg(s.LastEditedDate), }}) } if !s.LastEditedUser.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "last_edited_user")...), psql.Arg(s.LastEditedUser), }}) } if !s.Globalzscore.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "globalzscore")...), psql.Arg(s.Globalzscore), }}) } if !s.H3R7.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "h3r7")...), psql.Arg(s.H3R7), }}) } if !s.H3R8.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "h3r8")...), psql.Arg(s.H3R8), }}) } if !s.R7score.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "r7score")...), psql.Arg(s.R7score), }}) } if !s.R8score.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "r8score")...), psql.Arg(s.R8score), }}) } if !s.Yearweek.IsUnset() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "yearweek")...), psql.Arg(s.Yearweek), }}) } if s.Updated.IsValue() { exprs = append(exprs, expr.Join{Sep: " = ", Exprs: []bob.Expression{ psql.Quote(append(prefix, "updated")...), psql.Arg(s.Updated), }}) } return exprs } // FindFSSpeciesabundance retrieves a single record by primary key // If cols is empty Find will return all columns. func FindFSSpeciesabundance(ctx context.Context, exec bob.Executor, ObjectidPK int32, cols ...string) (*FSSpeciesabundance, error) { if len(cols) == 0 { return FSSpeciesabundances.Query( sm.Where(FSSpeciesabundances.Columns.Objectid.EQ(psql.Arg(ObjectidPK))), ).One(ctx, exec) } return FSSpeciesabundances.Query( sm.Where(FSSpeciesabundances.Columns.Objectid.EQ(psql.Arg(ObjectidPK))), sm.Columns(FSSpeciesabundances.Columns.Only(cols...)), ).One(ctx, exec) } // FSSpeciesabundanceExists checks the presence of a single record by primary key func FSSpeciesabundanceExists(ctx context.Context, exec bob.Executor, ObjectidPK int32) (bool, error) { return FSSpeciesabundances.Query( sm.Where(FSSpeciesabundances.Columns.Objectid.EQ(psql.Arg(ObjectidPK))), ).Exists(ctx, exec) } // AfterQueryHook is called after FSSpeciesabundance is retrieved from the database func (o *FSSpeciesabundance) AfterQueryHook(ctx context.Context, exec bob.Executor, queryType bob.QueryType) error { var err error switch queryType { case bob.QueryTypeSelect: ctx, err = FSSpeciesabundances.AfterSelectHooks.RunHooks(ctx, exec, FSSpeciesabundanceSlice{o}) case bob.QueryTypeInsert: ctx, err = FSSpeciesabundances.AfterInsertHooks.RunHooks(ctx, exec, FSSpeciesabundanceSlice{o}) case bob.QueryTypeUpdate: ctx, err = FSSpeciesabundances.AfterUpdateHooks.RunHooks(ctx, exec, FSSpeciesabundanceSlice{o}) case bob.QueryTypeDelete: ctx, err = FSSpeciesabundances.AfterDeleteHooks.RunHooks(ctx, exec, FSSpeciesabundanceSlice{o}) } return err } // primaryKeyVals returns the primary key values of the FSSpeciesabundance func (o *FSSpeciesabundance) primaryKeyVals() bob.Expression { return psql.Arg(o.Objectid) } func (o *FSSpeciesabundance) pkEQ() dialect.Expression { return psql.Quote("fs_speciesabundance", "objectid").EQ(bob.ExpressionFunc(func(ctx context.Context, w io.Writer, d bob.Dialect, start int) ([]any, error) { return o.primaryKeyVals().WriteSQL(ctx, w, d, start) })) } // Update uses an executor to update the FSSpeciesabundance func (o *FSSpeciesabundance) Update(ctx context.Context, exec bob.Executor, s *FSSpeciesabundanceSetter) error { v, err := FSSpeciesabundances.Update(s.UpdateMod(), um.Where(o.pkEQ())).One(ctx, exec) if err != nil { return err } o.R = v.R *o = *v return nil } // Delete deletes a single FSSpeciesabundance record with an executor func (o *FSSpeciesabundance) Delete(ctx context.Context, exec bob.Executor) error { _, err := FSSpeciesabundances.Delete(dm.Where(o.pkEQ())).Exec(ctx, exec) return err } // Reload refreshes the FSSpeciesabundance using the executor func (o *FSSpeciesabundance) Reload(ctx context.Context, exec bob.Executor) error { o2, err := FSSpeciesabundances.Query( sm.Where(FSSpeciesabundances.Columns.Objectid.EQ(psql.Arg(o.Objectid))), ).One(ctx, exec) if err != nil { return err } o2.R = o.R *o = *o2 return nil } // AfterQueryHook is called after FSSpeciesabundanceSlice is retrieved from the database func (o FSSpeciesabundanceSlice) AfterQueryHook(ctx context.Context, exec bob.Executor, queryType bob.QueryType) error { var err error switch queryType { case bob.QueryTypeSelect: ctx, err = FSSpeciesabundances.AfterSelectHooks.RunHooks(ctx, exec, o) case bob.QueryTypeInsert: ctx, err = FSSpeciesabundances.AfterInsertHooks.RunHooks(ctx, exec, o) case bob.QueryTypeUpdate: ctx, err = FSSpeciesabundances.AfterUpdateHooks.RunHooks(ctx, exec, o) case bob.QueryTypeDelete: ctx, err = FSSpeciesabundances.AfterDeleteHooks.RunHooks(ctx, exec, o) } return err } func (o FSSpeciesabundanceSlice) pkIN() dialect.Expression { if len(o) == 0 { return psql.Raw("NULL") } return psql.Quote("fs_speciesabundance", "objectid").In(bob.ExpressionFunc(func(ctx context.Context, w io.Writer, d bob.Dialect, start int) ([]any, error) { pkPairs := make([]bob.Expression, len(o)) for i, row := range o { pkPairs[i] = row.primaryKeyVals() } return bob.ExpressSlice(ctx, w, d, start, pkPairs, "", ", ", "") })) } // copyMatchingRows finds models in the given slice that have the same primary key // then it first copies the existing relationships from the old model to the new model // and then replaces the old model in the slice with the new model func (o FSSpeciesabundanceSlice) copyMatchingRows(from ...*FSSpeciesabundance) { for i, old := range o { for _, new := range from { if new.Objectid != old.Objectid { continue } new.R = old.R o[i] = new break } } } // UpdateMod modifies an update query with "WHERE primary_key IN (o...)" func (o FSSpeciesabundanceSlice) UpdateMod() bob.Mod[*dialect.UpdateQuery] { return bob.ModFunc[*dialect.UpdateQuery](func(q *dialect.UpdateQuery) { q.AppendHooks(func(ctx context.Context, exec bob.Executor) (context.Context, error) { return FSSpeciesabundances.BeforeUpdateHooks.RunHooks(ctx, exec, o) }) q.AppendLoader(bob.LoaderFunc(func(ctx context.Context, exec bob.Executor, retrieved any) error { var err error switch retrieved := retrieved.(type) { case *FSSpeciesabundance: o.copyMatchingRows(retrieved) case []*FSSpeciesabundance: o.copyMatchingRows(retrieved...) case FSSpeciesabundanceSlice: o.copyMatchingRows(retrieved...) default: // If the retrieved value is not a FSSpeciesabundance or a slice of FSSpeciesabundance // then run the AfterUpdateHooks on the slice _, err = FSSpeciesabundances.AfterUpdateHooks.RunHooks(ctx, exec, o) } return err })) q.AppendWhere(o.pkIN()) }) } // DeleteMod modifies an delete query with "WHERE primary_key IN (o...)" func (o FSSpeciesabundanceSlice) DeleteMod() bob.Mod[*dialect.DeleteQuery] { return bob.ModFunc[*dialect.DeleteQuery](func(q *dialect.DeleteQuery) { q.AppendHooks(func(ctx context.Context, exec bob.Executor) (context.Context, error) { return FSSpeciesabundances.BeforeDeleteHooks.RunHooks(ctx, exec, o) }) q.AppendLoader(bob.LoaderFunc(func(ctx context.Context, exec bob.Executor, retrieved any) error { var err error switch retrieved := retrieved.(type) { case *FSSpeciesabundance: o.copyMatchingRows(retrieved) case []*FSSpeciesabundance: o.copyMatchingRows(retrieved...) case FSSpeciesabundanceSlice: o.copyMatchingRows(retrieved...) default: // If the retrieved value is not a FSSpeciesabundance or a slice of FSSpeciesabundance // then run the AfterDeleteHooks on the slice _, err = FSSpeciesabundances.AfterDeleteHooks.RunHooks(ctx, exec, o) } return err })) q.AppendWhere(o.pkIN()) }) } func (o FSSpeciesabundanceSlice) UpdateAll(ctx context.Context, exec bob.Executor, vals FSSpeciesabundanceSetter) error { if len(o) == 0 { return nil } _, err := FSSpeciesabundances.Update(vals.UpdateMod(), o.UpdateMod()).All(ctx, exec) return err } func (o FSSpeciesabundanceSlice) DeleteAll(ctx context.Context, exec bob.Executor) error { if len(o) == 0 { return nil } _, err := FSSpeciesabundances.Delete(o.DeleteMod()).Exec(ctx, exec) return err } func (o FSSpeciesabundanceSlice) ReloadAll(ctx context.Context, exec bob.Executor) error { if len(o) == 0 { return nil } o2, err := FSSpeciesabundances.Query(sm.Where(o.pkIN())).All(ctx, exec) if err != nil { return err } o.copyMatchingRows(o2...) return nil } // Organization starts a query for related objects on organization func (o *FSSpeciesabundance) Organization(mods ...bob.Mod[*dialect.SelectQuery]) OrganizationsQuery { return Organizations.Query(append(mods, sm.Where(Organizations.Columns.ID.EQ(psql.Arg(o.OrganizationID))), )...) } func (os FSSpeciesabundanceSlice) Organization(mods ...bob.Mod[*dialect.SelectQuery]) OrganizationsQuery { pkOrganizationID := make(pgtypes.Array[int32], 0, len(os)) for _, o := range os { if o == nil { continue } pkOrganizationID = append(pkOrganizationID, o.OrganizationID) } PKArgExpr := psql.Select(sm.Columns( psql.F("unnest", psql.Cast(psql.Arg(pkOrganizationID), "integer[]")), )) return Organizations.Query(append(mods, sm.Where(psql.Group(Organizations.Columns.ID).OP("IN", PKArgExpr)), )...) } func attachFSSpeciesabundanceOrganization0(ctx context.Context, exec bob.Executor, count int, fsSpeciesabundance0 *FSSpeciesabundance, organization1 *Organization) (*FSSpeciesabundance, error) { setter := &FSSpeciesabundanceSetter{ OrganizationID: omit.From(organization1.ID), } err := fsSpeciesabundance0.Update(ctx, exec, setter) if err != nil { return nil, fmt.Errorf("attachFSSpeciesabundanceOrganization0: %w", err) } return fsSpeciesabundance0, nil } func (fsSpeciesabundance0 *FSSpeciesabundance) InsertOrganization(ctx context.Context, exec bob.Executor, related *OrganizationSetter) error { var err error organization1, err := Organizations.Insert(related).One(ctx, exec) if err != nil { return fmt.Errorf("inserting related objects: %w", err) } _, err = attachFSSpeciesabundanceOrganization0(ctx, exec, 1, fsSpeciesabundance0, organization1) if err != nil { return err } fsSpeciesabundance0.R.Organization = organization1 organization1.R.FSSpeciesabundances = append(organization1.R.FSSpeciesabundances, fsSpeciesabundance0) return nil } func (fsSpeciesabundance0 *FSSpeciesabundance) AttachOrganization(ctx context.Context, exec bob.Executor, organization1 *Organization) error { var err error _, err = attachFSSpeciesabundanceOrganization0(ctx, exec, 1, fsSpeciesabundance0, organization1) if err != nil { return err } fsSpeciesabundance0.R.Organization = organization1 organization1.R.FSSpeciesabundances = append(organization1.R.FSSpeciesabundances, fsSpeciesabundance0) return nil } type fsSpeciesabundanceWhere[Q psql.Filterable] struct { OrganizationID psql.WhereMod[Q, int32] Bloodedfem psql.WhereNullMod[Q, int16] Creationdate psql.WhereNullMod[Q, int64] Creator psql.WhereNullMod[Q, string] Eggs psql.WhereNullMod[Q, int16] Editdate psql.WhereNullMod[Q, int64] Editor psql.WhereNullMod[Q, string] Females psql.WhereNullMod[Q, int64] Gravidfem psql.WhereNullMod[Q, int16] Globalid psql.WhereMod[Q, string] Larvae psql.WhereNullMod[Q, int16] Males psql.WhereNullMod[Q, int16] Objectid psql.WhereMod[Q, int32] Poolstogen psql.WhereNullMod[Q, int16] Processed psql.WhereNullMod[Q, int16] Pupae psql.WhereNullMod[Q, int16] Species psql.WhereNullMod[Q, string] Total psql.WhereNullMod[Q, int64] TrapdataID psql.WhereNullMod[Q, string] Unknown psql.WhereNullMod[Q, int16] CreatedDate psql.WhereNullMod[Q, int64] CreatedUser psql.WhereNullMod[Q, string] GeometryX psql.WhereNullMod[Q, float64] GeometryY psql.WhereNullMod[Q, float64] LastEditedDate psql.WhereNullMod[Q, int64] LastEditedUser psql.WhereNullMod[Q, string] Globalzscore psql.WhereNullMod[Q, float64] H3R7 psql.WhereNullMod[Q, string] H3R8 psql.WhereNullMod[Q, string] R7score psql.WhereNullMod[Q, float64] R8score psql.WhereNullMod[Q, float64] Yearweek psql.WhereNullMod[Q, int64] Updated psql.WhereMod[Q, time.Time] } func (fsSpeciesabundanceWhere[Q]) AliasedAs(alias string) fsSpeciesabundanceWhere[Q] { return buildFSSpeciesabundanceWhere[Q](buildFSSpeciesabundanceColumns(alias)) } func buildFSSpeciesabundanceWhere[Q psql.Filterable](cols fsSpeciesabundanceColumns) fsSpeciesabundanceWhere[Q] { return fsSpeciesabundanceWhere[Q]{ OrganizationID: psql.Where[Q, int32](cols.OrganizationID), Bloodedfem: psql.WhereNull[Q, int16](cols.Bloodedfem), Creationdate: psql.WhereNull[Q, int64](cols.Creationdate), Creator: psql.WhereNull[Q, string](cols.Creator), Eggs: psql.WhereNull[Q, int16](cols.Eggs), Editdate: psql.WhereNull[Q, int64](cols.Editdate), Editor: psql.WhereNull[Q, string](cols.Editor), Females: psql.WhereNull[Q, int64](cols.Females), Gravidfem: psql.WhereNull[Q, int16](cols.Gravidfem), Globalid: psql.Where[Q, string](cols.Globalid), Larvae: psql.WhereNull[Q, int16](cols.Larvae), Males: psql.WhereNull[Q, int16](cols.Males), Objectid: psql.Where[Q, int32](cols.Objectid), Poolstogen: psql.WhereNull[Q, int16](cols.Poolstogen), Processed: psql.WhereNull[Q, int16](cols.Processed), Pupae: psql.WhereNull[Q, int16](cols.Pupae), Species: psql.WhereNull[Q, string](cols.Species), Total: psql.WhereNull[Q, int64](cols.Total), TrapdataID: psql.WhereNull[Q, string](cols.TrapdataID), Unknown: psql.WhereNull[Q, int16](cols.Unknown), CreatedDate: psql.WhereNull[Q, int64](cols.CreatedDate), CreatedUser: psql.WhereNull[Q, string](cols.CreatedUser), GeometryX: psql.WhereNull[Q, float64](cols.GeometryX), GeometryY: psql.WhereNull[Q, float64](cols.GeometryY), LastEditedDate: psql.WhereNull[Q, int64](cols.LastEditedDate), LastEditedUser: psql.WhereNull[Q, string](cols.LastEditedUser), Globalzscore: psql.WhereNull[Q, float64](cols.Globalzscore), H3R7: psql.WhereNull[Q, string](cols.H3R7), H3R8: psql.WhereNull[Q, string](cols.H3R8), R7score: psql.WhereNull[Q, float64](cols.R7score), R8score: psql.WhereNull[Q, float64](cols.R8score), Yearweek: psql.WhereNull[Q, int64](cols.Yearweek), Updated: psql.Where[Q, time.Time](cols.Updated), } } func (o *FSSpeciesabundance) Preload(name string, retrieved any) error { if o == nil { return nil } switch name { case "Organization": rel, ok := retrieved.(*Organization) if !ok { return fmt.Errorf("fsSpeciesabundance cannot load %T as %q", retrieved, name) } o.R.Organization = rel if rel != nil { rel.R.FSSpeciesabundances = FSSpeciesabundanceSlice{o} } return nil default: return fmt.Errorf("fsSpeciesabundance has no relationship %q", name) } } type fsSpeciesabundancePreloader struct { Organization func(...psql.PreloadOption) psql.Preloader } func buildFSSpeciesabundancePreloader() fsSpeciesabundancePreloader { return fsSpeciesabundancePreloader{ Organization: func(opts ...psql.PreloadOption) psql.Preloader { return psql.Preload[*Organization, OrganizationSlice](psql.PreloadRel{ Name: "Organization", Sides: []psql.PreloadSide{ { From: FSSpeciesabundances, To: Organizations, FromColumns: []string{"organization_id"}, ToColumns: []string{"id"}, }, }, }, Organizations.Columns.Names(), opts...) }, } } type fsSpeciesabundanceThenLoader[Q orm.Loadable] struct { Organization func(...bob.Mod[*dialect.SelectQuery]) orm.Loader[Q] } func buildFSSpeciesabundanceThenLoader[Q orm.Loadable]() fsSpeciesabundanceThenLoader[Q] { type OrganizationLoadInterface interface { LoadOrganization(context.Context, bob.Executor, ...bob.Mod[*dialect.SelectQuery]) error } return fsSpeciesabundanceThenLoader[Q]{ Organization: thenLoadBuilder[Q]( "Organization", func(ctx context.Context, exec bob.Executor, retrieved OrganizationLoadInterface, mods ...bob.Mod[*dialect.SelectQuery]) error { return retrieved.LoadOrganization(ctx, exec, mods...) }, ), } } // LoadOrganization loads the fsSpeciesabundance's Organization into the .R struct func (o *FSSpeciesabundance) LoadOrganization(ctx context.Context, exec bob.Executor, mods ...bob.Mod[*dialect.SelectQuery]) error { if o == nil { return nil } // Reset the relationship o.R.Organization = nil related, err := o.Organization(mods...).One(ctx, exec) if err != nil { return err } related.R.FSSpeciesabundances = FSSpeciesabundanceSlice{o} o.R.Organization = related return nil } // LoadOrganization loads the fsSpeciesabundance's Organization into the .R struct func (os FSSpeciesabundanceSlice) LoadOrganization(ctx context.Context, exec bob.Executor, mods ...bob.Mod[*dialect.SelectQuery]) error { if len(os) == 0 { return nil } organizations, err := os.Organization(mods...).All(ctx, exec) if err != nil { return err } for _, o := range os { if o == nil { continue } for _, rel := range organizations { if !(o.OrganizationID == rel.ID) { continue } rel.R.FSSpeciesabundances = append(rel.R.FSSpeciesabundances, o) o.R.Organization = rel break } } return nil } type fsSpeciesabundanceJoins[Q dialect.Joinable] struct { typ string Organization modAs[Q, organizationColumns] } func (j fsSpeciesabundanceJoins[Q]) aliasedAs(alias string) fsSpeciesabundanceJoins[Q] { return buildFSSpeciesabundanceJoins[Q](buildFSSpeciesabundanceColumns(alias), j.typ) } func buildFSSpeciesabundanceJoins[Q dialect.Joinable](cols fsSpeciesabundanceColumns, typ string) fsSpeciesabundanceJoins[Q] { return fsSpeciesabundanceJoins[Q]{ typ: typ, Organization: modAs[Q, organizationColumns]{ c: Organizations.Columns, f: func(to organizationColumns) bob.Mod[Q] { mods := make(mods.QueryMods[Q], 0, 1) { mods = append(mods, dialect.Join[Q](typ, Organizations.Name().As(to.Alias())).On( to.ID.EQ(cols.OrganizationID), )) } return mods }, }, } }