floraachy
/
pcm-coordinator
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

model 节点表修改 

Former-commit-id: e13578349e9d7372f6ce249f70d40a1d0fc68e0b
This commit is contained in:
zhangwei 2023-07-21 10:50:04 +08:00
parent 32c43a936f
commit 479765110e
4 changed files with 30 additions and 71 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
model/scnodeavailinfomodel_gen.go
View File

@ -40,21 +40,21 @@ type (
ScNodeAvailInfo struct { ScNodeAvailInfo struct {
Id int64 `db:"id"` // id Id int64 `db:"id"` // id
NodeName sql.NullString `db:"node_name"` // 节点名称 NodeName string `db:"node_name"` // 节点名称
CpuTotal sql.NullInt64 `db:"cpu_total"` // cpu核数 CpuTotal int64 `db:"cpu_total"` // cpu核数
CpuAvail sql.NullInt64 `db:"cpu_avail"` // cpu可用核数 CpuAvail int64 `db:"cpu_avail"` // cpu可用核数
DiskTotal sql.NullInt64 `db:"disk_total"` // 磁盘空间 DiskTotal int64 `db:"disk_total"` // 磁盘空间
DiskAvail sql.NullInt64 `db:"disk_avail"` // 磁盘可用空间 DiskAvail int64 `db:"disk_avail"` // 磁盘可用空间
MemTotal sql.NullInt64 `db:"mem_total"` // 内存总数 MemTotal int64 `db:"mem_total"` // 内存总数
MemAvail sql.NullInt64 `db:"mem_avail"` // 内存可用数 MemAvail int64 `db:"mem_avail"` // 内存可用数
GpuTotal sql.NullInt64 `db:"gpu_total"` // gpu总数 GpuTotal int64 `db:"gpu_total"` // gpu总数
GpuAvail sql.NullInt64 `db:"gpu_avail"` // gpu可用数 GpuAvail int64 `db:"gpu_avail"` // gpu可用数
ClusterLogicId int64 `db:"cluster_logic_id"` // 集群静态信息id ClusterLogicId int64 `db:"cluster_logic_id"` // 集群静态信息id
DeletedFlag int64 `db:"deleted_flag"` // 是否删除 DeletedFlag int64 `db:"deleted_flag"` // 是否删除
CreatedBy sql.NullInt64 `db:"created_by"` // 创建人 CreatedBy int64 `db:"created_by"` // 创建人
CreatedTime time.Time `db:"created_time"` // 创建时间 CreatedTime time.Time `db:"created_time"` // 创建时间
UpdatedBy sql.NullInt64 `db:"updated_by"` // 更新人 UpdatedBy int64 `db:"updated_by"` // 更新人
UpdatedTime sql.NullTime `db:"updated_time"` // 更新时间 UpdatedTime time.Time `db:"updated_time"` // 更新时间
} }
) )

14
model/scnodephyinfomodel.go
View File

@ -1,12 +1,5 @@
package model package model
import (
"github.com/zeromicro/go-zero/core/stores/cache"
"github.com/zeromicro/go-zero/core/stores/sqlx"
)
var _ ScNodePhyInfoModel = (*customScNodePhyInfoModel)(nil)
type ( type (
// ScNodePhyInfoModel is an interface to be customized, add more methods here, // ScNodePhyInfoModel is an interface to be customized, add more methods here,
// and implement the added methods in customScNodePhyInfoModel. // and implement the added methods in customScNodePhyInfoModel.
@ -18,10 +11,3 @@ type (
*defaultScNodePhyInfoModel *defaultScNodePhyInfoModel
} }
) )
// NewScNodePhyInfoModel returns a model for the database table.
func NewScNodePhyInfoModel(conn sqlx.SqlConn, c cache.CacheConf, opts ...cache.Option) ScNodePhyInfoModel {
return &customScNodePhyInfoModel{
defaultScNodePhyInfoModel: newScNodePhyInfoModel(conn, c, opts...),
}
}

35
model/scnodephyinfomodel_gen.go
View File

@ -46,12 +46,12 @@ type (
ArchType string `db:"arch_type"` // 架构类型 ArchType string `db:"arch_type"` // 架构类型
ArchName string `db:"arch_name"` // 架构名称 ArchName string `db:"arch_name"` // 架构名称
ArchFreq string `db:"arch_freq"` // 架构频率 ArchFreq string `db:"arch_freq"` // 架构频率
ClusterId sql.NullInt64 `db:"cluster_id"` // 集群静态信息id ParticipantId int64 `db:"cluster_id"` // 集群静态信息id
DeletedFlag int64 `db:"deleted_flag"` // 是否删除 DeletedFlag int64 `db:"deleted_flag"` // 是否删除
CreatedBy sql.NullInt64 `db:"created_by"` // 创建人 CreatedBy int64 `db:"created_by"` // 创建人
CreatedTime time.Time `db:"created_time"` // 创建时间 CreatedTime time.Time `db:"created_time"` // 创建时间
UpdatedBy sql.NullInt64 `db:"updated_by"` // 更新人 UpdatedBy int64 `db:"updated_by"` // 更新人
UpdatedTime sql.NullTime `db:"updated_time"` // 更新时间 UpdatedTime time.Time `db:"updated_time"` // 更新时间
} }
) )
@ -95,33 +95,6 @@ func (m *defaultScNodePhyInfoModel) FindOne(ctx context.Context, id int64) (*ScN
} }
} }
func (m *defaultScNodePhyInfoModel) Insert(ctx context.Context, data *ScNodePhyInfo) (sql.Result, error) {
pcmScNodePhyInfoIdKey := fmt.Sprintf("%s%v", cachePcmScNodePhyInfoIdPrefix, data.Id)
ret, err := m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) {
query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", m.table, scNodePhyInfoRowsExpectAutoSet)
return conn.ExecCtx(ctx, query, data.Id, data.NodeName, data.OsName, data.OsVersion, data.ArchType, data.ArchName, data.ArchFreq, data.ClusterId, data.DeletedFlag, data.CreatedBy, data.CreatedTime, data.UpdatedBy, data.UpdatedTime)
}, pcmScNodePhyInfoIdKey)
return ret, err
}
func (m *defaultScNodePhyInfoModel) Update(ctx context.Context, data *ScNodePhyInfo) error {
pcmScNodePhyInfoIdKey := fmt.Sprintf("%s%v", cachePcmScNodePhyInfoIdPrefix, data.Id)
_, err := m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) {
query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, scNodePhyInfoRowsWithPlaceHolder)
return conn.ExecCtx(ctx, query, data.NodeName, data.OsName, data.OsVersion, data.ArchType, data.ArchName, data.ArchFreq, data.ClusterId, data.DeletedFlag, data.CreatedBy, data.CreatedTime, data.UpdatedBy, data.UpdatedTime, data.Id)
}, pcmScNodePhyInfoIdKey)
return err
}
func (m *defaultScNodePhyInfoModel) formatPrimary(primary any) string {
return fmt.Sprintf("%s%v", cachePcmScNodePhyInfoIdPrefix, primary)
}
func (m *defaultScNodePhyInfoModel) queryPrimary(ctx context.Context, conn sqlx.SqlConn, v, primary any) error {
query := fmt.Sprintf("select %s from %s where `id` = ? limit 1", scNodePhyInfoRows, m.table)
return conn.QueryRowCtx(ctx, v, query, primary)
}
func (m *defaultScNodePhyInfoModel) tableName() string { func (m *defaultScNodePhyInfoModel) tableName() string {
return m.table return m.table
} }

2
rpc/pcmcore.go
View File

@ -17,7 +17,7 @@ import (
"google.golang.org/grpc/reflection" "google.golang.org/grpc/reflection"
) )
var configFile = flag.String("f", "etc/pcmcore.yaml", "the config file") var configFile = flag.String("f", "rpc/etc/pcmcore.yaml", "the config file")
func main() { func main() {