|
|
|
@@ -37,7 +37,7 @@ type ( |
|
|
|
TaskVm struct { |
|
|
|
Id int64 `db:"id"` // id |
|
|
|
TaskId int64 `db:"task_id"` // 任务id |
|
|
|
Name string `db:"name"` // 虚拟机名称 |
|
|
|
Name string `db:"name"` // 任务名称 |
|
|
|
AdapterId int64 `db:"adapter_id"` // 执行任务的适配器id |
|
|
|
AdapterName string `db:"adapter_name"` // 适配器名称 |
|
|
|
ClusterId int64 `db:"cluster_id"` // 执行任务的集群id |
|
|
|
@@ -53,7 +53,10 @@ type ( |
|
|
|
StartTime string `db:"start_time"` // 开始时间 |
|
|
|
RunningTime string `db:"running_time"` // 运行时间 |
|
|
|
Result string `db:"result"` // 运行结果 |
|
|
|
Remark string `db:"remark"` // 备注 |
|
|
|
DeletedAt string `db:"deleted_at"` // 删除时间 |
|
|
|
VmName string `db:"vm_name"` // 虚拟机名称 |
|
|
|
Replicas int64 `db:"replicas"` // 副本数 |
|
|
|
} |
|
|
|
) |
|
|
|
|
|
|
|
@@ -92,14 +95,14 @@ func (m *defaultTaskVmModel) FindOne(ctx context.Context, id int64) (*TaskVm, er |
|
|
|
} |
|
|
|
|
|
|
|
func (m *defaultTaskVmModel) Insert(ctx context.Context, data *TaskVm) (sql.Result, error) { |
|
|
|
query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", m.table, taskVmRowsExpectAutoSet) |
|
|
|
ret, err := m.conn.ExecCtx(ctx, query, data.TaskId, data.Name, data.AdapterId, data.AdapterName, data.ClusterId, data.ClusterName, data.FlavorRef, data.ImageRef, data.Status, data.Platform, data.Description, data.AvailabilityZone, data.MinCount, data.Uuid, data.StartTime, data.RunningTime, data.Result, data.DeletedAt) |
|
|
|
query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", m.table, taskVmRowsExpectAutoSet) |
|
|
|
ret, err := m.conn.ExecCtx(ctx, query, data.TaskId, data.Name, data.AdapterId, data.AdapterName, data.ClusterId, data.ClusterName, data.FlavorRef, data.ImageRef, data.Status, data.Platform, data.Description, data.AvailabilityZone, data.MinCount, data.Uuid, data.StartTime, data.RunningTime, data.Result, data.Remark, data.DeletedAt, data.VmName, data.Replicas) |
|
|
|
return ret, err |
|
|
|
} |
|
|
|
|
|
|
|
func (m *defaultTaskVmModel) Update(ctx context.Context, data *TaskVm) error { |
|
|
|
query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, taskVmRowsWithPlaceHolder) |
|
|
|
_, err := m.conn.ExecCtx(ctx, query, data.TaskId, data.Name, data.AdapterId, data.AdapterName, data.ClusterId, data.ClusterName, data.FlavorRef, data.ImageRef, data.Status, data.Platform, data.Description, data.AvailabilityZone, data.MinCount, data.Uuid, data.StartTime, data.RunningTime, data.Result, data.DeletedAt, data.Id) |
|
|
|
_, err := m.conn.ExecCtx(ctx, query, data.TaskId, data.Name, data.AdapterId, data.AdapterName, data.ClusterId, data.ClusterName, data.FlavorRef, data.ImageRef, data.Status, data.Platform, data.Description, data.AvailabilityZone, data.MinCount, data.Uuid, data.StartTime, data.RunningTime, data.Result, data.Remark, data.DeletedAt, data.VmName, data.Replicas, data.Id) |
|
|
|
return err |
|
|
|
} |
|
|
|
|
|
|
|
|