MCPcopy
hub / github.com/cloudreve/cloudreve / sqlSave

Method sqlSave

ent/fsevent_update.go:179–242  ·  view source on GitHub ↗
(ctx context.Context)

Source from the content-addressed store, hash-verified

177}
178
179func (feu *FsEventUpdate) sqlSave(ctx context.Context) (n int, err error) {
180 _spec := sqlgraph.NewUpdateSpec(fsevent.Table, fsevent.Columns, sqlgraph.NewFieldSpec(fsevent.FieldID, field.TypeInt))
181 if ps := feu.mutation.predicates; len(ps) > 0 {
182 _spec.Predicate = func(selector *sql.Selector) {
183 for i := range ps {
184 ps[i](selector)
185 }
186 }
187 }
188 if value, ok := feu.mutation.UpdatedAt(); ok {
189 _spec.SetField(fsevent.FieldUpdatedAt, field.TypeTime, value)
190 }
191 if value, ok := feu.mutation.DeletedAt(); ok {
192 _spec.SetField(fsevent.FieldDeletedAt, field.TypeTime, value)
193 }
194 if feu.mutation.DeletedAtCleared() {
195 _spec.ClearField(fsevent.FieldDeletedAt, field.TypeTime)
196 }
197 if value, ok := feu.mutation.Event(); ok {
198 _spec.SetField(fsevent.FieldEvent, field.TypeString, value)
199 }
200 if value, ok := feu.mutation.Subscriber(); ok {
201 _spec.SetField(fsevent.FieldSubscriber, field.TypeUUID, value)
202 }
203 if feu.mutation.UserCleared() {
204 edge := &sqlgraph.EdgeSpec{
205 Rel: sqlgraph.M2O,
206 Inverse: true,
207 Table: fsevent.UserTable,
208 Columns: []string{fsevent.UserColumn},
209 Bidi: false,
210 Target: &sqlgraph.EdgeTarget{
211 IDSpec: sqlgraph.NewFieldSpec(user.FieldID, field.TypeInt),
212 },
213 }
214 _spec.Edges.Clear = append(_spec.Edges.Clear, edge)
215 }
216 if nodes := feu.mutation.UserIDs(); len(nodes) > 0 {
217 edge := &sqlgraph.EdgeSpec{
218 Rel: sqlgraph.M2O,
219 Inverse: true,
220 Table: fsevent.UserTable,
221 Columns: []string{fsevent.UserColumn},
222 Bidi: false,
223 Target: &sqlgraph.EdgeTarget{
224 IDSpec: sqlgraph.NewFieldSpec(user.FieldID, field.TypeInt),
225 },
226 }
227 for _, k := range nodes {
228 edge.Target.Nodes = append(edge.Target.Nodes, k)
229 }
230 _spec.Edges.Add = append(_spec.Edges.Add, edge)
231 }
232 if n, err = sqlgraph.UpdateNodes(ctx, feu.driver, _spec); err != nil {
233 if _, ok := err.(*sqlgraph.NotFoundError); ok {
234 err = &NotFoundError{fsevent.Label}
235 } else if sqlgraph.IsConstraintError(err) {
236 err = &ConstraintError{msg: err.Error(), wrap: err}

Callers

nothing calls this directly

Calls 10

EventMethod · 0.80
SubscriberMethod · 0.80
UpdatedAtMethod · 0.65
ErrorMethod · 0.65
SetFieldMethod · 0.45
DeletedAtMethod · 0.45
DeletedAtClearedMethod · 0.45
ClearFieldMethod · 0.45
UserClearedMethod · 0.45
UserIDsMethod · 0.45

Tested by

no test coverage detected