// Copyright 2019-present Facebook Inc. All rights reserved. // This source code is licensed under the Apache 2.0 license found // in the LICENSE file in the root directory of this source tree. // Code generated by ent, DO NOT EDIT. package ent import ( "context" "errors" "time" "entgo.io/ent/dialect/gremlin" "entgo.io/ent/dialect/gremlin/graph/dsl" "entgo.io/ent/dialect/gremlin/graph/dsl/g" "entgo.io/ent/entc/integration/gremlin/ent/license" "entgo.io/ent/entc/integration/gremlin/ent/predicate" ) // LicenseUpdate is the builder for updating License entities. type LicenseUpdate struct { config hooks []Hook mutation *LicenseMutation } // Where appends a list predicates to the LicenseUpdate builder. func (_u *LicenseUpdate) Where(ps ...predicate.License) *LicenseUpdate { _u.mutation.Where(ps...) return _u } // SetUpdateTime sets the "update_time" field. func (_u *LicenseUpdate) SetUpdateTime(v time.Time) *LicenseUpdate { _u.mutation.SetUpdateTime(v) return _u } // Mutation returns the LicenseMutation object of the builder. func (_u *LicenseUpdate) Mutation() *LicenseMutation { return _u.mutation } // Save executes the query and returns the number of nodes affected by the update operation. func (_u *LicenseUpdate) Save(ctx context.Context) (int, error) { _u.defaults() return withHooks(ctx, _u.gremlinSave, _u.mutation, _u.hooks) } // SaveX is like Save, but panics if an error occurs. func (_u *LicenseUpdate) SaveX(ctx context.Context) int { affected, err := _u.Save(ctx) if err != nil { panic(err) } return affected } // Exec executes the query. func (_u *LicenseUpdate) Exec(ctx context.Context) error { _, err := _u.Save(ctx) return err } // ExecX is like Exec, but panics if an error occurs. func (_u *LicenseUpdate) ExecX(ctx context.Context) { if err := _u.Exec(ctx); err != nil { panic(err) } } // defaults sets the default values of the builder before save. func (_u *LicenseUpdate) defaults() { if _, ok := _u.mutation.UpdateTime(); !ok { v := license.UpdateDefaultUpdateTime() _u.mutation.SetUpdateTime(v) } } func (_u *LicenseUpdate) gremlinSave(ctx context.Context) (int, error) { res := &gremlin.Response{} query, bindings := _u.gremlin().Query() if err := _u.driver.Exec(ctx, query, bindings, res); err != nil { return 0, err } if err, ok := isConstantError(res); ok { return 0, err } _u.mutation.done = true return res.ReadInt() } func (_u *LicenseUpdate) gremlin() *dsl.Traversal { v := g.V().HasLabel(license.Label) for _, p := range _u.mutation.Predicates() { p(v) } var ( trs []*dsl.Traversal ) if value, ok := _u.mutation.UpdateTime(); ok { v.Property(dsl.Single, license.FieldUpdateTime, value) } v.Count() trs = append(trs, v) return dsl.Join(trs...) } // LicenseUpdateOne is the builder for updating a single License entity. type LicenseUpdateOne struct { config fields []string hooks []Hook mutation *LicenseMutation } // SetUpdateTime sets the "update_time" field. func (_u *LicenseUpdateOne) SetUpdateTime(v time.Time) *LicenseUpdateOne { _u.mutation.SetUpdateTime(v) return _u } // Mutation returns the LicenseMutation object of the builder. func (_u *LicenseUpdateOne) Mutation() *LicenseMutation { return _u.mutation } // Where appends a list predicates to the LicenseUpdate builder. func (_u *LicenseUpdateOne) Where(ps ...predicate.License) *LicenseUpdateOne { _u.mutation.Where(ps...) return _u } // Select allows selecting one or more fields (columns) of the returned entity. // The default is selecting all fields defined in the entity schema. func (_u *LicenseUpdateOne) Select(field string, fields ...string) *LicenseUpdateOne { _u.fields = append([]string{field}, fields...) return _u } // Save executes the query and returns the updated License entity. func (_u *LicenseUpdateOne) Save(ctx context.Context) (*License, error) { _u.defaults() return withHooks(ctx, _u.gremlinSave, _u.mutation, _u.hooks) } // SaveX is like Save, but panics if an error occurs. func (_u *LicenseUpdateOne) SaveX(ctx context.Context) *License { node, err := _u.Save(ctx) if err != nil { panic(err) } return node } // Exec executes the query on the entity. func (_u *LicenseUpdateOne) Exec(ctx context.Context) error { _, err := _u.Save(ctx) return err } // ExecX is like Exec, but panics if an error occurs. func (_u *LicenseUpdateOne) ExecX(ctx context.Context) { if err := _u.Exec(ctx); err != nil { panic(err) } } // defaults sets the default values of the builder before save. func (_u *LicenseUpdateOne) defaults() { if _, ok := _u.mutation.UpdateTime(); !ok { v := license.UpdateDefaultUpdateTime() _u.mutation.SetUpdateTime(v) } } func (_u *LicenseUpdateOne) gremlinSave(ctx context.Context) (*License, error) { res := &gremlin.Response{} id, ok := _u.mutation.ID() if !ok { return nil, &ValidationError{Name: "id", err: errors.New(`ent: missing "License.id" for update`)} } query, bindings := _u.gremlin(id).Query() if err := _u.driver.Exec(ctx, query, bindings, res); err != nil { return nil, err } if err, ok := isConstantError(res); ok { return nil, err } _u.mutation.done = true _m := &License{config: _u.config} if err := _m.FromResponse(res); err != nil { return nil, err } return _m, nil } func (_u *LicenseUpdateOne) gremlin(id int) *dsl.Traversal { v := g.V(id) var ( trs []*dsl.Traversal ) if value, ok := _u.mutation.UpdateTime(); ok { v.Property(dsl.Single, license.FieldUpdateTime, value) } if len(_u.fields) > 0 { fields := make([]any, 0, len(_u.fields)+1) fields = append(fields, true) for _, f := range _u.fields { fields = append(fields, f) } v.ValueMap(fields...) } else { v.ValueMap(true) } trs = append(trs, v) return dsl.Join(trs...) }