|
@@ -0,0 +1,1421 @@
|
|
|
|
+// Code generated by ent, DO NOT EDIT.
|
|
|
|
+
|
|
|
|
+package ent
|
|
|
|
+
|
|
|
|
+import (
|
|
|
|
+ "context"
|
|
|
|
+ "errors"
|
|
|
|
+ "fmt"
|
|
|
|
+ "time"
|
|
|
|
+ "wechat-api/ent/compapiasynctask"
|
|
|
|
+
|
|
|
|
+ "entgo.io/ent/dialect/sql"
|
|
|
|
+ "entgo.io/ent/dialect/sql/sqlgraph"
|
|
|
|
+ "entgo.io/ent/schema/field"
|
|
|
|
+)
|
|
|
|
+
|
|
|
|
+// CompapiAsynctaskCreate is the builder for creating a CompapiAsynctask entity.
|
|
|
|
+type CompapiAsynctaskCreate struct {
|
|
|
|
+ config
|
|
|
|
+ mutation *CompapiAsynctaskMutation
|
|
|
|
+ hooks []Hook
|
|
|
|
+ conflict []sql.ConflictOption
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetCreatedAt sets the "created_at" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetCreatedAt(t time.Time) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetCreatedAt(t)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetNillableCreatedAt sets the "created_at" field if the given value is not nil.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetNillableCreatedAt(t *time.Time) *CompapiAsynctaskCreate {
|
|
|
|
+ if t != nil {
|
|
|
|
+ cac.SetCreatedAt(*t)
|
|
|
|
+ }
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetUpdatedAt sets the "updated_at" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetUpdatedAt(t time.Time) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetUpdatedAt(t)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetNillableUpdatedAt sets the "updated_at" field if the given value is not nil.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetNillableUpdatedAt(t *time.Time) *CompapiAsynctaskCreate {
|
|
|
|
+ if t != nil {
|
|
|
|
+ cac.SetUpdatedAt(*t)
|
|
|
|
+ }
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetAuthToken sets the "auth_token" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetAuthToken(s string) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetAuthToken(s)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetEventType sets the "event_type" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetEventType(s string) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetEventType(s)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetNillableEventType sets the "event_type" field if the given value is not nil.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetNillableEventType(s *string) *CompapiAsynctaskCreate {
|
|
|
|
+ if s != nil {
|
|
|
|
+ cac.SetEventType(*s)
|
|
|
|
+ }
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetChatID sets the "chat_id" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetChatID(s string) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetChatID(s)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetNillableChatID sets the "chat_id" field if the given value is not nil.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetNillableChatID(s *string) *CompapiAsynctaskCreate {
|
|
|
|
+ if s != nil {
|
|
|
|
+ cac.SetChatID(*s)
|
|
|
|
+ }
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetWorkidIdx sets the "workid_idx" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetWorkidIdx(i int8) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetWorkidIdx(i)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetNillableWorkidIdx sets the "workid_idx" field if the given value is not nil.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetNillableWorkidIdx(i *int8) *CompapiAsynctaskCreate {
|
|
|
|
+ if i != nil {
|
|
|
|
+ cac.SetWorkidIdx(*i)
|
|
|
|
+ }
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetOpenaiBase sets the "openai_base" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetOpenaiBase(s string) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetOpenaiBase(s)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetOpenaiKey sets the "openai_key" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetOpenaiKey(s string) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetOpenaiKey(s)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetRequestRaw sets the "request_raw" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetRequestRaw(s string) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetRequestRaw(s)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetResponseRaw sets the "response_raw" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetResponseRaw(s string) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetResponseRaw(s)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetNillableResponseRaw sets the "response_raw" field if the given value is not nil.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetNillableResponseRaw(s *string) *CompapiAsynctaskCreate {
|
|
|
|
+ if s != nil {
|
|
|
|
+ cac.SetResponseRaw(*s)
|
|
|
|
+ }
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetCallbackURL sets the "callback_url" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetCallbackURL(s string) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetCallbackURL(s)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetTaskStatus sets the "task_status" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetTaskStatus(i int8) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetTaskStatus(i)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetNillableTaskStatus sets the "task_status" field if the given value is not nil.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetNillableTaskStatus(i *int8) *CompapiAsynctaskCreate {
|
|
|
|
+ if i != nil {
|
|
|
|
+ cac.SetTaskStatus(*i)
|
|
|
|
+ }
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetRetryCount sets the "retry_count" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetRetryCount(i int8) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetRetryCount(i)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetNillableRetryCount sets the "retry_count" field if the given value is not nil.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetNillableRetryCount(i *int8) *CompapiAsynctaskCreate {
|
|
|
|
+ if i != nil {
|
|
|
|
+ cac.SetRetryCount(*i)
|
|
|
|
+ }
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetLastError sets the "last_error" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetLastError(s string) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetLastError(s)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetNillableLastError sets the "last_error" field if the given value is not nil.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetNillableLastError(s *string) *CompapiAsynctaskCreate {
|
|
|
|
+ if s != nil {
|
|
|
|
+ cac.SetLastError(*s)
|
|
|
|
+ }
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetID sets the "id" field.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SetID(u uint64) *CompapiAsynctaskCreate {
|
|
|
|
+ cac.mutation.SetID(u)
|
|
|
|
+ return cac
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// Mutation returns the CompapiAsynctaskMutation object of the builder.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) Mutation() *CompapiAsynctaskMutation {
|
|
|
|
+ return cac.mutation
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// Save creates the CompapiAsynctask in the database.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) Save(ctx context.Context) (*CompapiAsynctask, error) {
|
|
|
|
+ cac.defaults()
|
|
|
|
+ return withHooks(ctx, cac.sqlSave, cac.mutation, cac.hooks)
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SaveX calls Save and panics if Save returns an error.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) SaveX(ctx context.Context) *CompapiAsynctask {
|
|
|
|
+ v, err := cac.Save(ctx)
|
|
|
|
+ if err != nil {
|
|
|
|
+ panic(err)
|
|
|
|
+ }
|
|
|
|
+ return v
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// Exec executes the query.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) Exec(ctx context.Context) error {
|
|
|
|
+ _, err := cac.Save(ctx)
|
|
|
|
+ return err
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ExecX is like Exec, but panics if an error occurs.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) ExecX(ctx context.Context) {
|
|
|
|
+ if err := cac.Exec(ctx); err != nil {
|
|
|
|
+ panic(err)
|
|
|
|
+ }
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// defaults sets the default values of the builder before save.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) defaults() {
|
|
|
|
+ if _, ok := cac.mutation.CreatedAt(); !ok {
|
|
|
|
+ v := compapiasynctask.DefaultCreatedAt()
|
|
|
|
+ cac.mutation.SetCreatedAt(v)
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.UpdatedAt(); !ok {
|
|
|
|
+ v := compapiasynctask.DefaultUpdatedAt()
|
|
|
|
+ cac.mutation.SetUpdatedAt(v)
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.EventType(); !ok {
|
|
|
|
+ v := compapiasynctask.DefaultEventType
|
|
|
|
+ cac.mutation.SetEventType(v)
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.ChatID(); !ok {
|
|
|
|
+ v := compapiasynctask.DefaultChatID
|
|
|
|
+ cac.mutation.SetChatID(v)
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.WorkidIdx(); !ok {
|
|
|
|
+ v := compapiasynctask.DefaultWorkidIdx
|
|
|
|
+ cac.mutation.SetWorkidIdx(v)
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.ResponseRaw(); !ok {
|
|
|
|
+ v := compapiasynctask.DefaultResponseRaw
|
|
|
|
+ cac.mutation.SetResponseRaw(v)
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.TaskStatus(); !ok {
|
|
|
|
+ v := compapiasynctask.DefaultTaskStatus
|
|
|
|
+ cac.mutation.SetTaskStatus(v)
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.RetryCount(); !ok {
|
|
|
|
+ v := compapiasynctask.DefaultRetryCount
|
|
|
|
+ cac.mutation.SetRetryCount(v)
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.LastError(); !ok {
|
|
|
|
+ v := compapiasynctask.DefaultLastError
|
|
|
|
+ cac.mutation.SetLastError(v)
|
|
|
|
+ }
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// check runs all checks and user-defined validators on the builder.
|
|
|
|
+func (cac *CompapiAsynctaskCreate) check() error {
|
|
|
|
+ if _, ok := cac.mutation.CreatedAt(); !ok {
|
|
|
|
+ return &ValidationError{Name: "created_at", err: errors.New(`ent: missing required field "CompapiAsynctask.created_at"`)}
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.UpdatedAt(); !ok {
|
|
|
|
+ return &ValidationError{Name: "updated_at", err: errors.New(`ent: missing required field "CompapiAsynctask.updated_at"`)}
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.AuthToken(); !ok {
|
|
|
|
+ return &ValidationError{Name: "auth_token", err: errors.New(`ent: missing required field "CompapiAsynctask.auth_token"`)}
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.EventType(); !ok {
|
|
|
|
+ return &ValidationError{Name: "event_type", err: errors.New(`ent: missing required field "CompapiAsynctask.event_type"`)}
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.OpenaiBase(); !ok {
|
|
|
|
+ return &ValidationError{Name: "openai_base", err: errors.New(`ent: missing required field "CompapiAsynctask.openai_base"`)}
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.OpenaiKey(); !ok {
|
|
|
|
+ return &ValidationError{Name: "openai_key", err: errors.New(`ent: missing required field "CompapiAsynctask.openai_key"`)}
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.RequestRaw(); !ok {
|
|
|
|
+ return &ValidationError{Name: "request_raw", err: errors.New(`ent: missing required field "CompapiAsynctask.request_raw"`)}
|
|
|
|
+ }
|
|
|
|
+ if _, ok := cac.mutation.CallbackURL(); !ok {
|
|
|
|
+ return &ValidationError{Name: "callback_url", err: errors.New(`ent: missing required field "CompapiAsynctask.callback_url"`)}
|
|
|
|
+ }
|
|
|
|
+ if v, ok := cac.mutation.CallbackURL(); ok {
|
|
|
|
+ if err := compapiasynctask.CallbackURLValidator(v); err != nil {
|
|
|
|
+ return &ValidationError{Name: "callback_url", err: fmt.Errorf(`ent: validator failed for field "CompapiAsynctask.callback_url": %w`, err)}
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ return nil
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+func (cac *CompapiAsynctaskCreate) sqlSave(ctx context.Context) (*CompapiAsynctask, error) {
|
|
|
|
+ if err := cac.check(); err != nil {
|
|
|
|
+ return nil, err
|
|
|
|
+ }
|
|
|
|
+ _node, _spec := cac.createSpec()
|
|
|
|
+ if err := sqlgraph.CreateNode(ctx, cac.driver, _spec); err != nil {
|
|
|
|
+ if sqlgraph.IsConstraintError(err) {
|
|
|
|
+ err = &ConstraintError{msg: err.Error(), wrap: err}
|
|
|
|
+ }
|
|
|
|
+ return nil, err
|
|
|
|
+ }
|
|
|
|
+ if _spec.ID.Value != _node.ID {
|
|
|
|
+ id := _spec.ID.Value.(int64)
|
|
|
|
+ _node.ID = uint64(id)
|
|
|
|
+ }
|
|
|
|
+ cac.mutation.id = &_node.ID
|
|
|
|
+ cac.mutation.done = true
|
|
|
|
+ return _node, nil
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+func (cac *CompapiAsynctaskCreate) createSpec() (*CompapiAsynctask, *sqlgraph.CreateSpec) {
|
|
|
|
+ var (
|
|
|
|
+ _node = &CompapiAsynctask{config: cac.config}
|
|
|
|
+ _spec = sqlgraph.NewCreateSpec(compapiasynctask.Table, sqlgraph.NewFieldSpec(compapiasynctask.FieldID, field.TypeUint64))
|
|
|
|
+ )
|
|
|
|
+ _spec.OnConflict = cac.conflict
|
|
|
|
+ if id, ok := cac.mutation.ID(); ok {
|
|
|
|
+ _node.ID = id
|
|
|
|
+ _spec.ID.Value = id
|
|
|
|
+ }
|
|
|
|
+ if value, ok := cac.mutation.CreatedAt(); ok {
|
|
|
|
+ _spec.SetField(compapiasynctask.FieldCreatedAt, field.TypeTime, value)
|
|
|
|
+ _node.CreatedAt = value
|
|
|
|
+ }
|
|
|
|
+ if value, ok := cac.mutation.UpdatedAt(); ok {
|
|
|
|
+ _spec.SetField(compapiasynctask.FieldUpdatedAt, field.TypeTime, value)
|
|
|
|
+ _node.UpdatedAt = value
|
|
|
|
+ }
|
|
|
|
+ if value, ok := cac.mutation.AuthToken(); ok {
|
|
|
|
+ _spec.SetField(compapiasynctask.FieldAuthToken, field.TypeString, value)
|
|
|
|
+ _node.AuthToken = value
|
|
|
|
+ }
|
|
|
|
+ if value, ok := cac.mutation.EventType(); ok {
|
|
|
|
+ _spec.SetField(compapiasynctask.FieldEventType, field.TypeString, value)
|
|
|
|
+ _node.EventType = value
|
|
|
|
+ }
|
|
|
|
+ if value, ok := cac.mutation.ChatID(); ok {
|
|
|
|
+ _spec.SetField(compapiasynctask.FieldChatID, field.TypeString, value)
|
|
|
|
+ _node.ChatID = value
|
|
|
|
+ }
|
|
|
|
+ if value, ok := cac.mutation.WorkidIdx(); ok {
|
|
|
|
+ _spec.SetField(compapiasynctask.FieldWorkidIdx, field.TypeInt8, value)
|
|
|
|
+ _node.WorkidIdx = value
|
|
|
|
+ }
|
|
|
|
+ if value, ok := cac.mutation.OpenaiBase(); ok {
|
|
|
|
+ _spec.SetField(compapiasynctask.FieldOpenaiBase, field.TypeString, value)
|
|
|
|
+ _node.OpenaiBase = value
|
|
|
|
+ }
|
|
|
|
+ if value, ok := cac.mutation.OpenaiKey(); ok {
|
|
|
|
+ _spec.SetField(compapiasynctask.FieldOpenaiKey, field.TypeString, value)
|
|
|
|
+ _node.OpenaiKey = value
|
|
|
|
+ }
|
|
|
|
+ if value, ok := cac.mutation.RequestRaw(); ok {
|
|
|
|
+ _spec.SetField(compapiasynctask.FieldRequestRaw, field.TypeString, value)
|
|
|
|
+ _node.RequestRaw = value
|
|
|
|
+ }
|
|
|
|
+ if value, ok := cac.mutation.ResponseRaw(); ok {
|
|
|
|
+ _spec.SetField(compapiasynctask.FieldResponseRaw, field.TypeString, value)
|
|
|
|
+ _node.ResponseRaw = value
|
|
|
|
+ }
|
|
|
|
+ if value, ok := cac.mutation.CallbackURL(); ok {
|
|
|
|
+ _spec.SetField(compapiasynctask.FieldCallbackURL, field.TypeString, value)
|
|
|
|
+ _node.CallbackURL = value
|
|
|
|
+ }
|
|
|
|
+ if value, ok := cac.mutation.TaskStatus(); ok {
|
|
|
|
+ _spec.SetField(compapiasynctask.FieldTaskStatus, field.TypeInt8, value)
|
|
|
|
+ _node.TaskStatus = value
|
|
|
|
+ }
|
|
|
|
+ if value, ok := cac.mutation.RetryCount(); ok {
|
|
|
|
+ _spec.SetField(compapiasynctask.FieldRetryCount, field.TypeInt8, value)
|
|
|
|
+ _node.RetryCount = value
|
|
|
|
+ }
|
|
|
|
+ if value, ok := cac.mutation.LastError(); ok {
|
|
|
|
+ _spec.SetField(compapiasynctask.FieldLastError, field.TypeString, value)
|
|
|
|
+ _node.LastError = value
|
|
|
|
+ }
|
|
|
|
+ return _node, _spec
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// OnConflict allows configuring the `ON CONFLICT` / `ON DUPLICATE KEY` clause
|
|
|
|
+// of the `INSERT` statement. For example:
|
|
|
|
+//
|
|
|
|
+// client.CompapiAsynctask.Create().
|
|
|
|
+// SetCreatedAt(v).
|
|
|
|
+// OnConflict(
|
|
|
|
+// // Update the row with the new values
|
|
|
|
+// // the was proposed for insertion.
|
|
|
|
+// sql.ResolveWithNewValues(),
|
|
|
|
+// ).
|
|
|
|
+// // Override some of the fields with custom
|
|
|
|
+// // update values.
|
|
|
|
+// Update(func(u *ent.CompapiAsynctaskUpsert) {
|
|
|
|
+// SetCreatedAt(v+v).
|
|
|
|
+// }).
|
|
|
|
+// Exec(ctx)
|
|
|
|
+func (cac *CompapiAsynctaskCreate) OnConflict(opts ...sql.ConflictOption) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ cac.conflict = opts
|
|
|
|
+ return &CompapiAsynctaskUpsertOne{
|
|
|
|
+ create: cac,
|
|
|
|
+ }
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// OnConflictColumns calls `OnConflict` and configures the columns
|
|
|
|
+// as conflict target. Using this option is equivalent to using:
|
|
|
|
+//
|
|
|
|
+// client.CompapiAsynctask.Create().
|
|
|
|
+// OnConflict(sql.ConflictColumns(columns...)).
|
|
|
|
+// Exec(ctx)
|
|
|
|
+func (cac *CompapiAsynctaskCreate) OnConflictColumns(columns ...string) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ cac.conflict = append(cac.conflict, sql.ConflictColumns(columns...))
|
|
|
|
+ return &CompapiAsynctaskUpsertOne{
|
|
|
|
+ create: cac,
|
|
|
|
+ }
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+type (
|
|
|
|
+ // CompapiAsynctaskUpsertOne is the builder for "upsert"-ing
|
|
|
|
+ // one CompapiAsynctask node.
|
|
|
|
+ CompapiAsynctaskUpsertOne struct {
|
|
|
|
+ create *CompapiAsynctaskCreate
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ // CompapiAsynctaskUpsert is the "OnConflict" setter.
|
|
|
|
+ CompapiAsynctaskUpsert struct {
|
|
|
|
+ *sql.UpdateSet
|
|
|
|
+ }
|
|
|
|
+)
|
|
|
|
+
|
|
|
|
+// SetUpdatedAt sets the "updated_at" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) SetUpdatedAt(v time.Time) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Set(compapiasynctask.FieldUpdatedAt, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateUpdatedAt sets the "updated_at" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) UpdateUpdatedAt() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetExcluded(compapiasynctask.FieldUpdatedAt)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetAuthToken sets the "auth_token" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) SetAuthToken(v string) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Set(compapiasynctask.FieldAuthToken, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateAuthToken sets the "auth_token" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) UpdateAuthToken() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetExcluded(compapiasynctask.FieldAuthToken)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetEventType sets the "event_type" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) SetEventType(v string) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Set(compapiasynctask.FieldEventType, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateEventType sets the "event_type" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) UpdateEventType() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetExcluded(compapiasynctask.FieldEventType)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetChatID sets the "chat_id" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) SetChatID(v string) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Set(compapiasynctask.FieldChatID, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateChatID sets the "chat_id" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) UpdateChatID() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetExcluded(compapiasynctask.FieldChatID)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearChatID clears the value of the "chat_id" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) ClearChatID() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetNull(compapiasynctask.FieldChatID)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetWorkidIdx sets the "workid_idx" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) SetWorkidIdx(v int8) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Set(compapiasynctask.FieldWorkidIdx, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateWorkidIdx sets the "workid_idx" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) UpdateWorkidIdx() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetExcluded(compapiasynctask.FieldWorkidIdx)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// AddWorkidIdx adds v to the "workid_idx" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) AddWorkidIdx(v int8) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Add(compapiasynctask.FieldWorkidIdx, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearWorkidIdx clears the value of the "workid_idx" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) ClearWorkidIdx() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetNull(compapiasynctask.FieldWorkidIdx)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetOpenaiBase sets the "openai_base" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) SetOpenaiBase(v string) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Set(compapiasynctask.FieldOpenaiBase, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateOpenaiBase sets the "openai_base" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) UpdateOpenaiBase() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetExcluded(compapiasynctask.FieldOpenaiBase)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetOpenaiKey sets the "openai_key" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) SetOpenaiKey(v string) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Set(compapiasynctask.FieldOpenaiKey, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateOpenaiKey sets the "openai_key" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) UpdateOpenaiKey() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetExcluded(compapiasynctask.FieldOpenaiKey)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetRequestRaw sets the "request_raw" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) SetRequestRaw(v string) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Set(compapiasynctask.FieldRequestRaw, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateRequestRaw sets the "request_raw" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) UpdateRequestRaw() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetExcluded(compapiasynctask.FieldRequestRaw)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetResponseRaw sets the "response_raw" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) SetResponseRaw(v string) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Set(compapiasynctask.FieldResponseRaw, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateResponseRaw sets the "response_raw" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) UpdateResponseRaw() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetExcluded(compapiasynctask.FieldResponseRaw)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearResponseRaw clears the value of the "response_raw" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) ClearResponseRaw() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetNull(compapiasynctask.FieldResponseRaw)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetCallbackURL sets the "callback_url" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) SetCallbackURL(v string) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Set(compapiasynctask.FieldCallbackURL, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateCallbackURL sets the "callback_url" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) UpdateCallbackURL() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetExcluded(compapiasynctask.FieldCallbackURL)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetTaskStatus sets the "task_status" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) SetTaskStatus(v int8) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Set(compapiasynctask.FieldTaskStatus, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateTaskStatus sets the "task_status" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) UpdateTaskStatus() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetExcluded(compapiasynctask.FieldTaskStatus)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// AddTaskStatus adds v to the "task_status" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) AddTaskStatus(v int8) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Add(compapiasynctask.FieldTaskStatus, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearTaskStatus clears the value of the "task_status" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) ClearTaskStatus() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetNull(compapiasynctask.FieldTaskStatus)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetRetryCount sets the "retry_count" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) SetRetryCount(v int8) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Set(compapiasynctask.FieldRetryCount, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateRetryCount sets the "retry_count" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) UpdateRetryCount() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetExcluded(compapiasynctask.FieldRetryCount)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// AddRetryCount adds v to the "retry_count" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) AddRetryCount(v int8) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Add(compapiasynctask.FieldRetryCount, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearRetryCount clears the value of the "retry_count" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) ClearRetryCount() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetNull(compapiasynctask.FieldRetryCount)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetLastError sets the "last_error" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) SetLastError(v string) *CompapiAsynctaskUpsert {
|
|
|
|
+ u.Set(compapiasynctask.FieldLastError, v)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateLastError sets the "last_error" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) UpdateLastError() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetExcluded(compapiasynctask.FieldLastError)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearLastError clears the value of the "last_error" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsert) ClearLastError() *CompapiAsynctaskUpsert {
|
|
|
|
+ u.SetNull(compapiasynctask.FieldLastError)
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateNewValues updates the mutable fields using the new values that were set on create except the ID field.
|
|
|
|
+// Using this option is equivalent to using:
|
|
|
|
+//
|
|
|
|
+// client.CompapiAsynctask.Create().
|
|
|
|
+// OnConflict(
|
|
|
|
+// sql.ResolveWithNewValues(),
|
|
|
|
+// sql.ResolveWith(func(u *sql.UpdateSet) {
|
|
|
|
+// u.SetIgnore(compapiasynctask.FieldID)
|
|
|
|
+// }),
|
|
|
|
+// ).
|
|
|
|
+// Exec(ctx)
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) UpdateNewValues() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ u.create.conflict = append(u.create.conflict, sql.ResolveWithNewValues())
|
|
|
|
+ u.create.conflict = append(u.create.conflict, sql.ResolveWith(func(s *sql.UpdateSet) {
|
|
|
|
+ if _, exists := u.create.mutation.ID(); exists {
|
|
|
|
+ s.SetIgnore(compapiasynctask.FieldID)
|
|
|
|
+ }
|
|
|
|
+ if _, exists := u.create.mutation.CreatedAt(); exists {
|
|
|
|
+ s.SetIgnore(compapiasynctask.FieldCreatedAt)
|
|
|
|
+ }
|
|
|
|
+ }))
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// Ignore sets each column to itself in case of conflict.
|
|
|
|
+// Using this option is equivalent to using:
|
|
|
|
+//
|
|
|
|
+// client.CompapiAsynctask.Create().
|
|
|
|
+// OnConflict(sql.ResolveWithIgnore()).
|
|
|
|
+// Exec(ctx)
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) Ignore() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ u.create.conflict = append(u.create.conflict, sql.ResolveWithIgnore())
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// DoNothing configures the conflict_action to `DO NOTHING`.
|
|
|
|
+// Supported only by SQLite and PostgreSQL.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) DoNothing() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ u.create.conflict = append(u.create.conflict, sql.DoNothing())
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// Update allows overriding fields `UPDATE` values. See the CompapiAsynctaskCreate.OnConflict
|
|
|
|
+// documentation for more info.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) Update(set func(*CompapiAsynctaskUpsert)) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ u.create.conflict = append(u.create.conflict, sql.ResolveWith(func(update *sql.UpdateSet) {
|
|
|
|
+ set(&CompapiAsynctaskUpsert{UpdateSet: update})
|
|
|
|
+ }))
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetUpdatedAt sets the "updated_at" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) SetUpdatedAt(v time.Time) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetUpdatedAt(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateUpdatedAt sets the "updated_at" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) UpdateUpdatedAt() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateUpdatedAt()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetAuthToken sets the "auth_token" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) SetAuthToken(v string) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetAuthToken(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateAuthToken sets the "auth_token" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) UpdateAuthToken() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateAuthToken()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetEventType sets the "event_type" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) SetEventType(v string) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetEventType(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateEventType sets the "event_type" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) UpdateEventType() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateEventType()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetChatID sets the "chat_id" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) SetChatID(v string) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetChatID(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateChatID sets the "chat_id" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) UpdateChatID() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateChatID()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearChatID clears the value of the "chat_id" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) ClearChatID() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.ClearChatID()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetWorkidIdx sets the "workid_idx" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) SetWorkidIdx(v int8) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetWorkidIdx(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// AddWorkidIdx adds v to the "workid_idx" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) AddWorkidIdx(v int8) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.AddWorkidIdx(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateWorkidIdx sets the "workid_idx" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) UpdateWorkidIdx() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateWorkidIdx()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearWorkidIdx clears the value of the "workid_idx" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) ClearWorkidIdx() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.ClearWorkidIdx()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetOpenaiBase sets the "openai_base" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) SetOpenaiBase(v string) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetOpenaiBase(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateOpenaiBase sets the "openai_base" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) UpdateOpenaiBase() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateOpenaiBase()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetOpenaiKey sets the "openai_key" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) SetOpenaiKey(v string) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetOpenaiKey(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateOpenaiKey sets the "openai_key" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) UpdateOpenaiKey() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateOpenaiKey()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetRequestRaw sets the "request_raw" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) SetRequestRaw(v string) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetRequestRaw(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateRequestRaw sets the "request_raw" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) UpdateRequestRaw() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateRequestRaw()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetResponseRaw sets the "response_raw" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) SetResponseRaw(v string) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetResponseRaw(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateResponseRaw sets the "response_raw" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) UpdateResponseRaw() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateResponseRaw()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearResponseRaw clears the value of the "response_raw" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) ClearResponseRaw() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.ClearResponseRaw()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetCallbackURL sets the "callback_url" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) SetCallbackURL(v string) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetCallbackURL(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateCallbackURL sets the "callback_url" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) UpdateCallbackURL() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateCallbackURL()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetTaskStatus sets the "task_status" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) SetTaskStatus(v int8) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetTaskStatus(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// AddTaskStatus adds v to the "task_status" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) AddTaskStatus(v int8) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.AddTaskStatus(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateTaskStatus sets the "task_status" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) UpdateTaskStatus() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateTaskStatus()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearTaskStatus clears the value of the "task_status" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) ClearTaskStatus() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.ClearTaskStatus()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetRetryCount sets the "retry_count" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) SetRetryCount(v int8) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetRetryCount(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// AddRetryCount adds v to the "retry_count" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) AddRetryCount(v int8) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.AddRetryCount(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateRetryCount sets the "retry_count" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) UpdateRetryCount() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateRetryCount()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearRetryCount clears the value of the "retry_count" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) ClearRetryCount() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.ClearRetryCount()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetLastError sets the "last_error" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) SetLastError(v string) *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetLastError(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateLastError sets the "last_error" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) UpdateLastError() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateLastError()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearLastError clears the value of the "last_error" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) ClearLastError() *CompapiAsynctaskUpsertOne {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.ClearLastError()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// Exec executes the query.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) Exec(ctx context.Context) error {
|
|
|
|
+ if len(u.create.conflict) == 0 {
|
|
|
|
+ return errors.New("ent: missing options for CompapiAsynctaskCreate.OnConflict")
|
|
|
|
+ }
|
|
|
|
+ return u.create.Exec(ctx)
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ExecX is like Exec, but panics if an error occurs.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) ExecX(ctx context.Context) {
|
|
|
|
+ if err := u.create.Exec(ctx); err != nil {
|
|
|
|
+ panic(err)
|
|
|
|
+ }
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// Exec executes the UPSERT query and returns the inserted/updated ID.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) ID(ctx context.Context) (id uint64, err error) {
|
|
|
|
+ node, err := u.create.Save(ctx)
|
|
|
|
+ if err != nil {
|
|
|
|
+ return id, err
|
|
|
|
+ }
|
|
|
|
+ return node.ID, nil
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// IDX is like ID, but panics if an error occurs.
|
|
|
|
+func (u *CompapiAsynctaskUpsertOne) IDX(ctx context.Context) uint64 {
|
|
|
|
+ id, err := u.ID(ctx)
|
|
|
|
+ if err != nil {
|
|
|
|
+ panic(err)
|
|
|
|
+ }
|
|
|
|
+ return id
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// CompapiAsynctaskCreateBulk is the builder for creating many CompapiAsynctask entities in bulk.
|
|
|
|
+type CompapiAsynctaskCreateBulk struct {
|
|
|
|
+ config
|
|
|
|
+ err error
|
|
|
|
+ builders []*CompapiAsynctaskCreate
|
|
|
|
+ conflict []sql.ConflictOption
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// Save creates the CompapiAsynctask entities in the database.
|
|
|
|
+func (cacb *CompapiAsynctaskCreateBulk) Save(ctx context.Context) ([]*CompapiAsynctask, error) {
|
|
|
|
+ if cacb.err != nil {
|
|
|
|
+ return nil, cacb.err
|
|
|
|
+ }
|
|
|
|
+ specs := make([]*sqlgraph.CreateSpec, len(cacb.builders))
|
|
|
|
+ nodes := make([]*CompapiAsynctask, len(cacb.builders))
|
|
|
|
+ mutators := make([]Mutator, len(cacb.builders))
|
|
|
|
+ for i := range cacb.builders {
|
|
|
|
+ func(i int, root context.Context) {
|
|
|
|
+ builder := cacb.builders[i]
|
|
|
|
+ builder.defaults()
|
|
|
|
+ var mut Mutator = MutateFunc(func(ctx context.Context, m Mutation) (Value, error) {
|
|
|
|
+ mutation, ok := m.(*CompapiAsynctaskMutation)
|
|
|
|
+ if !ok {
|
|
|
|
+ return nil, fmt.Errorf("unexpected mutation type %T", m)
|
|
|
|
+ }
|
|
|
|
+ if err := builder.check(); err != nil {
|
|
|
|
+ return nil, err
|
|
|
|
+ }
|
|
|
|
+ builder.mutation = mutation
|
|
|
|
+ var err error
|
|
|
|
+ nodes[i], specs[i] = builder.createSpec()
|
|
|
|
+ if i < len(mutators)-1 {
|
|
|
|
+ _, err = mutators[i+1].Mutate(root, cacb.builders[i+1].mutation)
|
|
|
|
+ } else {
|
|
|
|
+ spec := &sqlgraph.BatchCreateSpec{Nodes: specs}
|
|
|
|
+ spec.OnConflict = cacb.conflict
|
|
|
|
+ // Invoke the actual operation on the latest mutation in the chain.
|
|
|
|
+ if err = sqlgraph.BatchCreate(ctx, cacb.driver, spec); err != nil {
|
|
|
|
+ if sqlgraph.IsConstraintError(err) {
|
|
|
|
+ err = &ConstraintError{msg: err.Error(), wrap: err}
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if err != nil {
|
|
|
|
+ return nil, err
|
|
|
|
+ }
|
|
|
|
+ mutation.id = &nodes[i].ID
|
|
|
|
+ if specs[i].ID.Value != nil && nodes[i].ID == 0 {
|
|
|
|
+ id := specs[i].ID.Value.(int64)
|
|
|
|
+ nodes[i].ID = uint64(id)
|
|
|
|
+ }
|
|
|
|
+ mutation.done = true
|
|
|
|
+ return nodes[i], nil
|
|
|
|
+ })
|
|
|
|
+ for i := len(builder.hooks) - 1; i >= 0; i-- {
|
|
|
|
+ mut = builder.hooks[i](mut)
|
|
|
|
+ }
|
|
|
|
+ mutators[i] = mut
|
|
|
|
+ }(i, ctx)
|
|
|
|
+ }
|
|
|
|
+ if len(mutators) > 0 {
|
|
|
|
+ if _, err := mutators[0].Mutate(ctx, cacb.builders[0].mutation); err != nil {
|
|
|
|
+ return nil, err
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ return nodes, nil
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SaveX is like Save, but panics if an error occurs.
|
|
|
|
+func (cacb *CompapiAsynctaskCreateBulk) SaveX(ctx context.Context) []*CompapiAsynctask {
|
|
|
|
+ v, err := cacb.Save(ctx)
|
|
|
|
+ if err != nil {
|
|
|
|
+ panic(err)
|
|
|
|
+ }
|
|
|
|
+ return v
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// Exec executes the query.
|
|
|
|
+func (cacb *CompapiAsynctaskCreateBulk) Exec(ctx context.Context) error {
|
|
|
|
+ _, err := cacb.Save(ctx)
|
|
|
|
+ return err
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ExecX is like Exec, but panics if an error occurs.
|
|
|
|
+func (cacb *CompapiAsynctaskCreateBulk) ExecX(ctx context.Context) {
|
|
|
|
+ if err := cacb.Exec(ctx); err != nil {
|
|
|
|
+ panic(err)
|
|
|
|
+ }
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// OnConflict allows configuring the `ON CONFLICT` / `ON DUPLICATE KEY` clause
|
|
|
|
+// of the `INSERT` statement. For example:
|
|
|
|
+//
|
|
|
|
+// client.CompapiAsynctask.CreateBulk(builders...).
|
|
|
|
+// OnConflict(
|
|
|
|
+// // Update the row with the new values
|
|
|
|
+// // the was proposed for insertion.
|
|
|
|
+// sql.ResolveWithNewValues(),
|
|
|
|
+// ).
|
|
|
|
+// // Override some of the fields with custom
|
|
|
|
+// // update values.
|
|
|
|
+// Update(func(u *ent.CompapiAsynctaskUpsert) {
|
|
|
|
+// SetCreatedAt(v+v).
|
|
|
|
+// }).
|
|
|
|
+// Exec(ctx)
|
|
|
|
+func (cacb *CompapiAsynctaskCreateBulk) OnConflict(opts ...sql.ConflictOption) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ cacb.conflict = opts
|
|
|
|
+ return &CompapiAsynctaskUpsertBulk{
|
|
|
|
+ create: cacb,
|
|
|
|
+ }
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// OnConflictColumns calls `OnConflict` and configures the columns
|
|
|
|
+// as conflict target. Using this option is equivalent to using:
|
|
|
|
+//
|
|
|
|
+// client.CompapiAsynctask.Create().
|
|
|
|
+// OnConflict(sql.ConflictColumns(columns...)).
|
|
|
|
+// Exec(ctx)
|
|
|
|
+func (cacb *CompapiAsynctaskCreateBulk) OnConflictColumns(columns ...string) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ cacb.conflict = append(cacb.conflict, sql.ConflictColumns(columns...))
|
|
|
|
+ return &CompapiAsynctaskUpsertBulk{
|
|
|
|
+ create: cacb,
|
|
|
|
+ }
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// CompapiAsynctaskUpsertBulk is the builder for "upsert"-ing
|
|
|
|
+// a bulk of CompapiAsynctask nodes.
|
|
|
|
+type CompapiAsynctaskUpsertBulk struct {
|
|
|
|
+ create *CompapiAsynctaskCreateBulk
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateNewValues updates the mutable fields using the new values that
|
|
|
|
+// were set on create. Using this option is equivalent to using:
|
|
|
|
+//
|
|
|
|
+// client.CompapiAsynctask.Create().
|
|
|
|
+// OnConflict(
|
|
|
|
+// sql.ResolveWithNewValues(),
|
|
|
|
+// sql.ResolveWith(func(u *sql.UpdateSet) {
|
|
|
|
+// u.SetIgnore(compapiasynctask.FieldID)
|
|
|
|
+// }),
|
|
|
|
+// ).
|
|
|
|
+// Exec(ctx)
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) UpdateNewValues() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ u.create.conflict = append(u.create.conflict, sql.ResolveWithNewValues())
|
|
|
|
+ u.create.conflict = append(u.create.conflict, sql.ResolveWith(func(s *sql.UpdateSet) {
|
|
|
|
+ for _, b := range u.create.builders {
|
|
|
|
+ if _, exists := b.mutation.ID(); exists {
|
|
|
|
+ s.SetIgnore(compapiasynctask.FieldID)
|
|
|
|
+ }
|
|
|
|
+ if _, exists := b.mutation.CreatedAt(); exists {
|
|
|
|
+ s.SetIgnore(compapiasynctask.FieldCreatedAt)
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }))
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// Ignore sets each column to itself in case of conflict.
|
|
|
|
+// Using this option is equivalent to using:
|
|
|
|
+//
|
|
|
|
+// client.CompapiAsynctask.Create().
|
|
|
|
+// OnConflict(sql.ResolveWithIgnore()).
|
|
|
|
+// Exec(ctx)
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) Ignore() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ u.create.conflict = append(u.create.conflict, sql.ResolveWithIgnore())
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// DoNothing configures the conflict_action to `DO NOTHING`.
|
|
|
|
+// Supported only by SQLite and PostgreSQL.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) DoNothing() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ u.create.conflict = append(u.create.conflict, sql.DoNothing())
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// Update allows overriding fields `UPDATE` values. See the CompapiAsynctaskCreateBulk.OnConflict
|
|
|
|
+// documentation for more info.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) Update(set func(*CompapiAsynctaskUpsert)) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ u.create.conflict = append(u.create.conflict, sql.ResolveWith(func(update *sql.UpdateSet) {
|
|
|
|
+ set(&CompapiAsynctaskUpsert{UpdateSet: update})
|
|
|
|
+ }))
|
|
|
|
+ return u
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetUpdatedAt sets the "updated_at" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) SetUpdatedAt(v time.Time) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetUpdatedAt(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateUpdatedAt sets the "updated_at" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) UpdateUpdatedAt() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateUpdatedAt()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetAuthToken sets the "auth_token" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) SetAuthToken(v string) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetAuthToken(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateAuthToken sets the "auth_token" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) UpdateAuthToken() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateAuthToken()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetEventType sets the "event_type" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) SetEventType(v string) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetEventType(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateEventType sets the "event_type" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) UpdateEventType() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateEventType()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetChatID sets the "chat_id" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) SetChatID(v string) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetChatID(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateChatID sets the "chat_id" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) UpdateChatID() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateChatID()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearChatID clears the value of the "chat_id" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) ClearChatID() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.ClearChatID()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetWorkidIdx sets the "workid_idx" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) SetWorkidIdx(v int8) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetWorkidIdx(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// AddWorkidIdx adds v to the "workid_idx" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) AddWorkidIdx(v int8) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.AddWorkidIdx(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateWorkidIdx sets the "workid_idx" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) UpdateWorkidIdx() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateWorkidIdx()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearWorkidIdx clears the value of the "workid_idx" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) ClearWorkidIdx() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.ClearWorkidIdx()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetOpenaiBase sets the "openai_base" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) SetOpenaiBase(v string) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetOpenaiBase(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateOpenaiBase sets the "openai_base" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) UpdateOpenaiBase() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateOpenaiBase()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetOpenaiKey sets the "openai_key" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) SetOpenaiKey(v string) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetOpenaiKey(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateOpenaiKey sets the "openai_key" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) UpdateOpenaiKey() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateOpenaiKey()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetRequestRaw sets the "request_raw" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) SetRequestRaw(v string) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetRequestRaw(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateRequestRaw sets the "request_raw" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) UpdateRequestRaw() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateRequestRaw()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetResponseRaw sets the "response_raw" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) SetResponseRaw(v string) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetResponseRaw(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateResponseRaw sets the "response_raw" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) UpdateResponseRaw() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateResponseRaw()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearResponseRaw clears the value of the "response_raw" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) ClearResponseRaw() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.ClearResponseRaw()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetCallbackURL sets the "callback_url" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) SetCallbackURL(v string) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetCallbackURL(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateCallbackURL sets the "callback_url" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) UpdateCallbackURL() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateCallbackURL()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetTaskStatus sets the "task_status" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) SetTaskStatus(v int8) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetTaskStatus(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// AddTaskStatus adds v to the "task_status" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) AddTaskStatus(v int8) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.AddTaskStatus(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateTaskStatus sets the "task_status" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) UpdateTaskStatus() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateTaskStatus()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearTaskStatus clears the value of the "task_status" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) ClearTaskStatus() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.ClearTaskStatus()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetRetryCount sets the "retry_count" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) SetRetryCount(v int8) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetRetryCount(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// AddRetryCount adds v to the "retry_count" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) AddRetryCount(v int8) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.AddRetryCount(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateRetryCount sets the "retry_count" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) UpdateRetryCount() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateRetryCount()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearRetryCount clears the value of the "retry_count" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) ClearRetryCount() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.ClearRetryCount()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// SetLastError sets the "last_error" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) SetLastError(v string) *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.SetLastError(v)
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// UpdateLastError sets the "last_error" field to the value that was provided on create.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) UpdateLastError() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.UpdateLastError()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ClearLastError clears the value of the "last_error" field.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) ClearLastError() *CompapiAsynctaskUpsertBulk {
|
|
|
|
+ return u.Update(func(s *CompapiAsynctaskUpsert) {
|
|
|
|
+ s.ClearLastError()
|
|
|
|
+ })
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// Exec executes the query.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) Exec(ctx context.Context) error {
|
|
|
|
+ if u.create.err != nil {
|
|
|
|
+ return u.create.err
|
|
|
|
+ }
|
|
|
|
+ for i, b := range u.create.builders {
|
|
|
|
+ if len(b.conflict) != 0 {
|
|
|
|
+ return fmt.Errorf("ent: OnConflict was set for builder %d. Set it on the CompapiAsynctaskCreateBulk instead", i)
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if len(u.create.conflict) == 0 {
|
|
|
|
+ return errors.New("ent: missing options for CompapiAsynctaskCreateBulk.OnConflict")
|
|
|
|
+ }
|
|
|
|
+ return u.create.Exec(ctx)
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+// ExecX is like Exec, but panics if an error occurs.
|
|
|
|
+func (u *CompapiAsynctaskUpsertBulk) ExecX(ctx context.Context) {
|
|
|
|
+ if err := u.create.Exec(ctx); err != nil {
|
|
|
|
+ panic(err)
|
|
|
|
+ }
|
|
|
|
+}
|