// Code generated by sqlc. DO NOT EDIT. // versions: // sqlc v1.30.0 // source: courses.sql package dbgen import ( "context" "github.com/jackc/pgx/v5/pgtype" ) const CreateCourse = `-- name: CreateCourse :one INSERT INTO courses ( category_id, title, description, thumbnail, intro_video_url, is_active ) VALUES ($1, $2, $3, $4, $5, COALESCE($6, true)) RETURNING id, category_id, title, description, is_active, thumbnail, intro_video_url, display_order, sub_category_id ` type CreateCourseParams struct { CategoryID int64 `json:"category_id"` Title string `json:"title"` Description pgtype.Text `json:"description"` Thumbnail pgtype.Text `json:"thumbnail"` IntroVideoUrl pgtype.Text `json:"intro_video_url"` Column6 interface{} `json:"column_6"` } func (q *Queries) CreateCourse(ctx context.Context, arg CreateCourseParams) (Course, error) { row := q.db.QueryRow(ctx, CreateCourse, arg.CategoryID, arg.Title, arg.Description, arg.Thumbnail, arg.IntroVideoUrl, arg.Column6, ) var i Course err := row.Scan( &i.ID, &i.CategoryID, &i.Title, &i.Description, &i.IsActive, &i.Thumbnail, &i.IntroVideoUrl, &i.DisplayOrder, &i.SubCategoryID, ) return i, err } const DeleteCourse = `-- name: DeleteCourse :exec DELETE FROM courses WHERE id = $1 ` func (q *Queries) DeleteCourse(ctx context.Context, id int64) error { _, err := q.db.Exec(ctx, DeleteCourse, id) return err } const GetAllCourses = `-- name: GetAllCourses :many SELECT COUNT(*) OVER () AS total_count, c.id, c.category_id, c.sub_category_id, c.title, c.description, c.thumbnail, c.intro_video_url, c.is_active FROM courses c ORDER BY c.display_order ASC, c.id ASC LIMIT $2::INT OFFSET $1::INT ` type GetAllCoursesParams struct { Offset pgtype.Int4 `json:"offset"` Limit pgtype.Int4 `json:"limit"` } type GetAllCoursesRow struct { TotalCount int64 `json:"total_count"` ID int64 `json:"id"` CategoryID int64 `json:"category_id"` SubCategoryID pgtype.Int8 `json:"sub_category_id"` Title string `json:"title"` Description pgtype.Text `json:"description"` Thumbnail pgtype.Text `json:"thumbnail"` IntroVideoUrl pgtype.Text `json:"intro_video_url"` IsActive bool `json:"is_active"` } func (q *Queries) GetAllCourses(ctx context.Context, arg GetAllCoursesParams) ([]GetAllCoursesRow, error) { rows, err := q.db.Query(ctx, GetAllCourses, arg.Offset, arg.Limit) if err != nil { return nil, err } defer rows.Close() var items []GetAllCoursesRow for rows.Next() { var i GetAllCoursesRow if err := rows.Scan( &i.TotalCount, &i.ID, &i.CategoryID, &i.SubCategoryID, &i.Title, &i.Description, &i.Thumbnail, &i.IntroVideoUrl, &i.IsActive, ); err != nil { return nil, err } items = append(items, i) } if err := rows.Err(); err != nil { return nil, err } return items, nil } const GetCourseByID = `-- name: GetCourseByID :one SELECT id, category_id, title, description, is_active, thumbnail, intro_video_url, display_order, sub_category_id FROM courses WHERE id = $1 ` func (q *Queries) GetCourseByID(ctx context.Context, id int64) (Course, error) { row := q.db.QueryRow(ctx, GetCourseByID, id) var i Course err := row.Scan( &i.ID, &i.CategoryID, &i.Title, &i.Description, &i.IsActive, &i.Thumbnail, &i.IntroVideoUrl, &i.DisplayOrder, &i.SubCategoryID, ) return i, err } const GetCoursesByCategory = `-- name: GetCoursesByCategory :many SELECT COUNT(*) OVER () AS total_count, id, category_id, title, description, thumbnail, intro_video_url, is_active FROM courses WHERE category_id = $1 ORDER BY display_order ASC, id ASC LIMIT $3::INT OFFSET $2::INT ` type GetCoursesByCategoryParams struct { CategoryID int64 `json:"category_id"` Offset pgtype.Int4 `json:"offset"` Limit pgtype.Int4 `json:"limit"` } type GetCoursesByCategoryRow struct { TotalCount int64 `json:"total_count"` ID int64 `json:"id"` CategoryID int64 `json:"category_id"` Title string `json:"title"` Description pgtype.Text `json:"description"` Thumbnail pgtype.Text `json:"thumbnail"` IntroVideoUrl pgtype.Text `json:"intro_video_url"` IsActive bool `json:"is_active"` } func (q *Queries) GetCoursesByCategory(ctx context.Context, arg GetCoursesByCategoryParams) ([]GetCoursesByCategoryRow, error) { rows, err := q.db.Query(ctx, GetCoursesByCategory, arg.CategoryID, arg.Offset, arg.Limit) if err != nil { return nil, err } defer rows.Close() var items []GetCoursesByCategoryRow for rows.Next() { var i GetCoursesByCategoryRow if err := rows.Scan( &i.TotalCount, &i.ID, &i.CategoryID, &i.Title, &i.Description, &i.Thumbnail, &i.IntroVideoUrl, &i.IsActive, ); err != nil { return nil, err } items = append(items, i) } if err := rows.Err(); err != nil { return nil, err } return items, nil } const GetCoursesBySubCategory = `-- name: GetCoursesBySubCategory :many SELECT COUNT(*) OVER () AS total_count, c.id, c.category_id, c.sub_category_id, c.title, c.description, c.thumbnail, c.intro_video_url, c.is_active FROM courses c WHERE c.sub_category_id = $1 ORDER BY c.display_order ASC, c.id ASC LIMIT $3::INT OFFSET $2::INT ` type GetCoursesBySubCategoryParams struct { SubCategoryID pgtype.Int8 `json:"sub_category_id"` Offset pgtype.Int4 `json:"offset"` Limit pgtype.Int4 `json:"limit"` } type GetCoursesBySubCategoryRow struct { TotalCount int64 `json:"total_count"` ID int64 `json:"id"` CategoryID int64 `json:"category_id"` SubCategoryID pgtype.Int8 `json:"sub_category_id"` Title string `json:"title"` Description pgtype.Text `json:"description"` Thumbnail pgtype.Text `json:"thumbnail"` IntroVideoUrl pgtype.Text `json:"intro_video_url"` IsActive bool `json:"is_active"` } func (q *Queries) GetCoursesBySubCategory(ctx context.Context, arg GetCoursesBySubCategoryParams) ([]GetCoursesBySubCategoryRow, error) { rows, err := q.db.Query(ctx, GetCoursesBySubCategory, arg.SubCategoryID, arg.Offset, arg.Limit) if err != nil { return nil, err } defer rows.Close() var items []GetCoursesBySubCategoryRow for rows.Next() { var i GetCoursesBySubCategoryRow if err := rows.Scan( &i.TotalCount, &i.ID, &i.CategoryID, &i.SubCategoryID, &i.Title, &i.Description, &i.Thumbnail, &i.IntroVideoUrl, &i.IsActive, ); err != nil { return nil, err } items = append(items, i) } if err := rows.Err(); err != nil { return nil, err } return items, nil } const GetHumanLanguageCourses = `-- name: GetHumanLanguageCourses :many SELECT COUNT(*) OVER () AS total_count, c.id, c.category_id, c.sub_category_id, c.title, c.description, c.thumbnail, c.intro_video_url, c.is_active FROM courses c JOIN course_categories cc ON cc.id = c.category_id WHERE lower(trim(cc.name)) = 'human language' ORDER BY c.display_order ASC, c.id ASC LIMIT $2::INT OFFSET $1::INT ` type GetHumanLanguageCoursesParams struct { Offset pgtype.Int4 `json:"offset"` Limit pgtype.Int4 `json:"limit"` } type GetHumanLanguageCoursesRow struct { TotalCount int64 `json:"total_count"` ID int64 `json:"id"` CategoryID int64 `json:"category_id"` SubCategoryID pgtype.Int8 `json:"sub_category_id"` Title string `json:"title"` Description pgtype.Text `json:"description"` Thumbnail pgtype.Text `json:"thumbnail"` IntroVideoUrl pgtype.Text `json:"intro_video_url"` IsActive bool `json:"is_active"` } func (q *Queries) GetHumanLanguageCourses(ctx context.Context, arg GetHumanLanguageCoursesParams) ([]GetHumanLanguageCoursesRow, error) { rows, err := q.db.Query(ctx, GetHumanLanguageCourses, arg.Offset, arg.Limit) if err != nil { return nil, err } defer rows.Close() var items []GetHumanLanguageCoursesRow for rows.Next() { var i GetHumanLanguageCoursesRow if err := rows.Scan( &i.TotalCount, &i.ID, &i.CategoryID, &i.SubCategoryID, &i.Title, &i.Description, &i.Thumbnail, &i.IntroVideoUrl, &i.IsActive, ); err != nil { return nil, err } items = append(items, i) } if err := rows.Err(); err != nil { return nil, err } return items, nil } const ReorderCourses = `-- name: ReorderCourses :exec UPDATE courses SET display_order = bulk.position FROM ( SELECT unnest($1::BIGINT[]) AS id, unnest($2::INT[]) AS position ) AS bulk WHERE courses.id = bulk.id ` type ReorderCoursesParams struct { Ids []int64 `json:"ids"` Positions []int32 `json:"positions"` } func (q *Queries) ReorderCourses(ctx context.Context, arg ReorderCoursesParams) error { _, err := q.db.Exec(ctx, ReorderCourses, arg.Ids, arg.Positions) return err } const UpdateCourse = `-- name: UpdateCourse :exec UPDATE courses SET title = COALESCE($1, title), description = COALESCE($2, description), thumbnail = COALESCE($3, thumbnail), intro_video_url = COALESCE($4, intro_video_url), is_active = COALESCE($5, is_active) WHERE id = $6 ` type UpdateCourseParams struct { Title string `json:"title"` Description pgtype.Text `json:"description"` Thumbnail pgtype.Text `json:"thumbnail"` IntroVideoUrl pgtype.Text `json:"intro_video_url"` IsActive bool `json:"is_active"` ID int64 `json:"id"` } func (q *Queries) UpdateCourse(ctx context.Context, arg UpdateCourseParams) error { _, err := q.db.Exec(ctx, UpdateCourse, arg.Title, arg.Description, arg.Thumbnail, arg.IntroVideoUrl, arg.IsActive, arg.ID, ) return err }