diff --git a/server/internal/course_resource/internal/model/courseresourcemodel.go b/server/internal/course_resource/internal/model/courseresourcemodel.go new file mode 100644 index 00000000..413d7b53 --- /dev/null +++ b/server/internal/course_resource/internal/model/courseresourcemodel.go @@ -0,0 +1,29 @@ +package model + +import "github.com/zeromicro/go-zero/core/stores/sqlx" + +var _ CourseResourceModel = (*customCourseResourceModel)(nil) + +type ( + // CourseResourceModel is an interface to be customized, add more methods here, + // and implement the added methods in customCourseResourceModel. + CourseResourceModel interface { + courseResourceModel + withSession(session sqlx.Session) CourseResourceModel + } + + customCourseResourceModel struct { + *defaultCourseResourceModel + } +) + +// NewCourseResourceModel returns a model for the database table. +func NewCourseResourceModel(conn sqlx.SqlConn) CourseResourceModel { + return &customCourseResourceModel{ + defaultCourseResourceModel: newCourseResourceModel(conn), + } +} + +func (m *customCourseResourceModel) withSession(session sqlx.Session) CourseResourceModel { + return NewCourseResourceModel(sqlx.NewSqlConnFromSession(session)) +} diff --git a/server/internal/course_resource/internal/model/courseresourcemodel_gen.go b/server/internal/course_resource/internal/model/courseresourcemodel_gen.go new file mode 100644 index 00000000..d94900c3 --- /dev/null +++ b/server/internal/course_resource/internal/model/courseresourcemodel_gen.go @@ -0,0 +1,89 @@ +// Code generated by goctl. DO NOT EDIT. +// versions: +// goctl version: 1.9.1 + +package model + +import ( + "context" + "database/sql" + "fmt" + "strings" + + "github.com/zeromicro/go-zero/core/stores/builder" + "github.com/zeromicro/go-zero/core/stores/sqlx" + "github.com/zeromicro/go-zero/core/stringx" +) + +var ( + courseResourceFieldNames = builder.RawFieldNames(&CourseResource{}) + courseResourceRows = strings.Join(courseResourceFieldNames, ",") + courseResourceRowsExpectAutoSet = strings.Join(stringx.Remove(courseResourceFieldNames, "`id`", "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), ",") + courseResourceRowsWithPlaceHolder = strings.Join(stringx.Remove(courseResourceFieldNames, "`id`", "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), "=?,") + "=?" +) + +type ( + courseResourceModel interface { + Insert(ctx context.Context, data *CourseResource) (sql.Result, error) + FindOne(ctx context.Context, id int64) (*CourseResource, error) + Update(ctx context.Context, data *CourseResource) error + Delete(ctx context.Context, id int64) error + } + + defaultCourseResourceModel struct { + conn sqlx.SqlConn + table string + } + + CourseResource struct { + Id int64 `db:"id"` // 资源ID(主键,自增) + CourseId int64 `db:"course_id"` // 关联课程ID + Title string `db:"title"` // 资源标题(如“第1章课件.pdf”) + ResourceUrl string `db:"resource_url"` // 资源文件URL + Size int64 `db:"size"` // 文件大小(KB,默认0) + Sort int64 `db:"sort"` // 排序(数值越小越靠前) + } +) + +func newCourseResourceModel(conn sqlx.SqlConn) *defaultCourseResourceModel { + return &defaultCourseResourceModel{ + conn: conn, + table: "`course_resource`", + } +} + +func (m *defaultCourseResourceModel) 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 *defaultCourseResourceModel) FindOne(ctx context.Context, id int64) (*CourseResource, error) { + query := fmt.Sprintf("select %s from %s where `id` = ? limit 1", courseResourceRows, m.table) + var resp CourseResource + 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 *defaultCourseResourceModel) Insert(ctx context.Context, data *CourseResource) (sql.Result, error) { + query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?)", m.table, courseResourceRowsExpectAutoSet) + ret, err := m.conn.ExecCtx(ctx, query, data.CourseId, data.Title, data.ResourceUrl, data.Size, data.Sort) + return ret, err +} + +func (m *defaultCourseResourceModel) Update(ctx context.Context, data *CourseResource) error { + query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, courseResourceRowsWithPlaceHolder) + _, err := m.conn.ExecCtx(ctx, query, data.CourseId, data.Title, data.ResourceUrl, data.Size, data.Sort, data.Id) + return err +} + +func (m *defaultCourseResourceModel) tableName() string { + return m.table +} diff --git a/server/internal/course_resource/internal/model/vars.go b/server/internal/course_resource/internal/model/vars.go new file mode 100644 index 00000000..69ca814e --- /dev/null +++ b/server/internal/course_resource/internal/model/vars.go @@ -0,0 +1,5 @@ +package model + +import "github.com/zeromicro/go-zero/core/stores/sqlx" + +var ErrNotFound = sqlx.ErrNotFound