dao

Documentation

Index

• func Database(connString string) error
• func InitDB()
• func NewDBClient(ctx context.Context) *gorm.DB
• type TaskDao
  • func NewTaskDao(ctx context.Context) *TaskDao
  • func (dao *TaskDao) CreateTask(in *model.Task) error
  • func (dao *TaskDao) DeleteTaskByIdAndUserId(id, uId uint64) error
  • func (dao *TaskDao) GetTaskByTaskIdAndUserId(taskId, userId uint64) (r *model.Task, err error)
  • func (dao *TaskDao) ListTaskByUserId(userId uint64, start, limit int) (r []*model.Task, count int64, err error)
  • func (dao *TaskDao) UpdateTask(req *pb.TaskRequest) (r *model.Task, err error)

Functions

func Database

func Database(connString string) error

func InitDB

func InitDB()

func NewDBClient

func NewDBClient(ctx context.Context) *gorm.DB

Types

type TaskDao

type TaskDao struct {
	*gorm.DB
}

func NewTaskDao

func NewTaskDao(ctx context.Context) *TaskDao

func (*TaskDao) CreateTask

func (dao *TaskDao) CreateTask(in *model.Task) error

func (*TaskDao) DeleteTaskByIdAndUserId

func (dao *TaskDao) DeleteTaskByIdAndUserId(id, uId uint64) error

func (*TaskDao) GetTaskByTaskIdAndUserId

func (dao *TaskDao) GetTaskByTaskIdAndUserId(taskId, userId uint64) (r *model.Task, err error)

GetTaskByTaskIdAndUserId 通过 task id 和 user id 获取task

func (*TaskDao) ListTaskByUserId

func (dao *TaskDao) ListTaskByUserId(userId uint64, start, limit int) (r []*model.Task, count int64, err error)

ListTaskByUserId 获取user id

func (*TaskDao) UpdateTask

func (dao *TaskDao) UpdateTask(req *pb.TaskRequest) (r *model.Task, err error)

UpdateTask 更新task