// Code generated by goctl. DO NOT EDIT. // versions: // goctl version: 1.10.2 package model import ( "context" "database/sql" "fmt" "strings" "time" "github.com/zeromicro/go-zero/core/stores/builder" "github.com/zeromicro/go-zero/core/stores/sqlx" "github.com/zeromicro/go-zero/core/stringx" ) var ( tServiceFieldNames = builder.RawFieldNames(&TService{}) tServiceRows = strings.Join(tServiceFieldNames, ",") tServiceRowsExpectAutoSet = strings.Join(stringx.Remove(tServiceFieldNames, "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), ",") tServiceRowsWithPlaceHolder = strings.Join(stringx.Remove(tServiceFieldNames, "`id`", "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), "=?,") + "=?" ) type ( tServiceModel interface { Insert(ctx context.Context, data *TService) (sql.Result, error) FindOne(ctx context.Context, id int64) (*TService, error) Update(ctx context.Context, data *TService) error Delete(ctx context.Context, id int64) error } defaultTServiceModel struct { conn sqlx.SqlConn table string } TService struct { Id int64 `db:"id"` Name sql.NullString `db:"name"` // 服务名称 Ip sql.NullString `db:"ip"` // 外挂服务ip Port sql.NullString `db:"port"` // 外挂服务端口 Iden sql.NullString `db:"iden"` // 唯一标识 KeyIden sql.NullString `db:"key_iden"` // 密钥标识 KeyAlgo sql.NullString `db:"key_algo"` // 密钥算法 Status sql.NullString `db:"status"` // 服务状态 CreateAt time.Time `db:"create_at"` // 创建时间 } ) func newTServiceModel(conn sqlx.SqlConn) *defaultTServiceModel { return &defaultTServiceModel{ conn: conn, table: "`t_service`", } } func (m *defaultTServiceModel) Delete(ctx context.Context, id int64) error { query := fmt.Sprintf("delete from %s where `id` = ?", m.table) _, err := m.conn.ExecCtx(ctx, query, id) return err } func (m *defaultTServiceModel) FindOne(ctx context.Context, id int64) (*TService, error) { query := fmt.Sprintf("select %s from %s where `id` = ? limit 1", tServiceRows, m.table) var resp TService err := m.conn.QueryRowCtx(ctx, &resp, query, id) switch err { case nil: return &resp, nil case sqlx.ErrNotFound: return nil, ErrNotFound default: return nil, err } } func (m *defaultTServiceModel) Insert(ctx context.Context, data *TService) (sql.Result, error) { query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?)", m.table, tServiceRowsExpectAutoSet) ret, err := m.conn.ExecCtx(ctx, query, data.Id, data.Name, data.Ip, data.Port, data.Iden, data.KeyIden, data.KeyAlgo, data.Status) return ret, err } func (m *defaultTServiceModel) Update(ctx context.Context, data *TService) error { query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, tServiceRowsWithPlaceHolder) _, err := m.conn.ExecCtx(ctx, query, data.Name, data.Ip, data.Port, data.Iden, data.KeyIden, data.KeyAlgo, data.Status, data.Id) return err } func (m *defaultTServiceModel) tableName() string { return m.table }