|
|
|
@@ -37,6 +37,7 @@ type ( |
|
|
|
ComputeCluster struct { |
|
|
|
Id int64 `db:"id"` // 集群id |
|
|
|
Name sql.NullString `db:"name"` // 集群名 |
|
|
|
Type sql.NullString `db:"type"` // 集群类型 |
|
|
|
CenterId sql.NullInt64 `db:"center_id"` // 数据中心id |
|
|
|
CenterName sql.NullString `db:"center_name"` // 数据中心名称 |
|
|
|
JcceDomainId sql.NullInt64 `db:"jcce_domain_id"` // JCCE侧域ID |
|
|
|
@@ -75,14 +76,14 @@ func (m *defaultComputeClusterModel) FindOne(ctx context.Context, id int64) (*Co |
|
|
|
} |
|
|
|
|
|
|
|
func (m *defaultComputeClusterModel) Insert(ctx context.Context, data *ComputeCluster) (sql.Result, error) { |
|
|
|
query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?)", m.table, computeClusterRowsExpectAutoSet) |
|
|
|
ret, err := m.conn.ExecCtx(ctx, query, data.Name, data.CenterId, data.CenterName, data.JcceDomainId, data.JcceDomainName, data.Longitude, data.Latitude, data.Description) |
|
|
|
query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?, ?)", m.table, computeClusterRowsExpectAutoSet) |
|
|
|
ret, err := m.conn.ExecCtx(ctx, query, data.Name, data.Type, data.CenterId, data.CenterName, data.JcceDomainId, data.JcceDomainName, data.Longitude, data.Latitude, data.Description) |
|
|
|
return ret, err |
|
|
|
} |
|
|
|
|
|
|
|
func (m *defaultComputeClusterModel) Update(ctx context.Context, data *ComputeCluster) error { |
|
|
|
query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, computeClusterRowsWithPlaceHolder) |
|
|
|
_, err := m.conn.ExecCtx(ctx, query, data.Name, data.CenterId, data.CenterName, data.JcceDomainId, data.JcceDomainName, data.Longitude, data.Latitude, data.Description, data.Id) |
|
|
|
_, err := m.conn.ExecCtx(ctx, query, data.Name, data.Type, data.CenterId, data.CenterName, data.JcceDomainId, data.JcceDomainName, data.Longitude, data.Latitude, data.Description, data.Id) |
|
|
|
return err |
|
|
|
} |
|
|
|
|
|
|
|
|