// Code generated by the atomctl ; DO NOT EDIT. // Code generated by the atomctl ; DO NOT EDIT. // Code generated by the atomctl ; DO NOT EDIT. package model import ( "context" . "github.com/go-jet/jet/v2/postgres" "github.com/samber/lo" log "github.com/sirupsen/logrus" "time" ) // conds func (m *Orders) CondID(id int64) Cond { return func(cond BoolExpression) BoolExpression { return cond.AND(tblOrders.ID.EQ(Int(id))) } } // funcs func (m *Orders) log() *log.Entry { return log.WithField("model", "Orders") } func (m *Orders) Create(ctx context.Context) error { m.CreatedAt = time.Now() m.UpdatedAt = time.Now() stmt := tblOrders.INSERT(tblOrders.MutableColumns).MODEL(m).RETURNING(tblOrders.AllColumns) m.log().WithField("func", "Create").Info(stmt.DebugSql()) if err := stmt.QueryContext(ctx, db, m); err != nil { m.log().WithField("func", "Create").Errorf("error creating Orders item: %v", err) return err } m.log().WithField("func", "Create").Infof("Orders item created successfully") return nil } func (m *Orders) BatchCreate(ctx context.Context, models []*Orders) error { stmt := tblOrders.INSERT(tblOrders.MutableColumns).MODELS(models) m.log().WithField("func", "BatchCreate").Info(stmt.DebugSql()) if _, err := stmt.ExecContext(ctx, db); err != nil { m.log().WithField("func", "Create").Errorf("error creating Orders item: %v", err) return err } m.log().WithField("func", "BatchCreate").Infof("Orders items created successfully") return nil } func (m *Orders) Delete(ctx context.Context) error { stmt := tblOrders.DELETE().WHERE(tblOrders.ID.EQ(Int(m.ID))) m.log().WithField("func", "Delete").Info(stmt.DebugSql()) if err := stmt.QueryContext(ctx, db, m); err != nil { m.log().WithField("func", "Delete").Errorf("error deleting Orders item: %v", err) return err } m.log().WithField("func", "Delete").Infof("Orders item deleted successfully") return nil } // BatchDelete func (m *Orders) BatchDelete(ctx context.Context, ids []int64) error { condIds := lo.Map(ids, func(id int64, _ int) Expression { return Int64(id) }) stmt := tblOrders.DELETE().WHERE(tblOrders.ID.IN(condIds...)) m.log().WithField("func", "BatchDelete").Info(stmt.DebugSql()) if err := stmt.QueryContext(ctx, db, m); err != nil { m.log().WithField("func", "BatchDelete").Errorf("error deleting Orders items: %v", err) return err } m.log().WithField("func", "BatchDelete").WithField("ids", ids).Infof("Orders items deleted successfully") return nil } func (m *Orders) Update(ctx context.Context) error { m.UpdatedAt = time.Now() stmt := tblOrders.UPDATE(tblOrdersUpdateMutableColumns).MODEL(m).WHERE(tblOrders.ID.EQ(Int(m.ID))).RETURNING(tblOrders.AllColumns) m.log().WithField("func", "Update").Info(stmt.DebugSql()) if err := stmt.QueryContext(ctx, db, m); err != nil { m.log().WithField("func", "Update").Errorf("error updating Orders item: %v", err) return err } m.log().WithField("func", "Update").Infof("Orders item updated successfully") return nil } // GetByCond func (m *Orders) GetByCond(ctx context.Context, conds ...Cond) (*Orders, error) { cond := CondTrue(conds...) stmt := tblOrders.SELECT(tblOrders.AllColumns).WHERE(cond) m.log().WithField("func", "GetByCond").Info(stmt.DebugSql()) if err := stmt.QueryContext(ctx, db, m); err != nil { m.log().WithField("func", "GetByCond").Errorf("error getting Orders item by ID: %v", err) return nil, err } m.log().WithField("func", "GetByCond").Infof("Orders item retrieved successfully") return m, nil } // GetByID func (m *Orders) GetByID(ctx context.Context, id int64, conds ...Cond) (*Orders, error) { return m.GetByCond(ctx, CondJoin(m.CondID(id), conds...)...) } // Count func (m *Orders) Count(ctx context.Context, conds ...Cond) (int64, error) { cond := CondTrue(conds...) stmt := tblOrders.SELECT(COUNT(tblOrders.ID).AS("count")).WHERE(cond) m.log().Infof("sql: %s", stmt.DebugSql()) var count struct { Count int64 } if err := stmt.QueryContext(ctx, db, &count); err != nil { m.log().Errorf("error counting Orders items: %v", err) return 0, err } return count.Count, nil }