dao

Documentation

Index

• type Dao
  • func NewDao(s *r.Session, c *redis.Client) *Dao
  • func (d *Dao) AddOnlineUser(user *model.OnlineUser) (err error)
  • func (d *Dao) DeleteMessageByID(mid string) error
  • func (d *Dao) DeleteUserByID(uid string) error
  • func (d *Dao) FindUserByEmail(email string) (*model.User, error)
  • func (d *Dao) FindUserByID(uid string) (*model.User, error)
  • func (d *Dao) FindUsersByName(name string) ([]*model.User, error)
  • func (d *Dao) FindmessageByID(mid string) (*model.Message, error)
  • func (d *Dao) GetOnlineUser(id string) (*model.OnlineUser, error)
  • func (d *Dao) InsertMessage(msg *model.Message) error
  • func (d *Dao) InsertUser(user *model.User) error
  • func (d *Dao) IsOnline(id string) bool
  • func (d *Dao) IstUserExis(uid string) bool
  • func (d *Dao) RealDeleteMessageByID(mid string) error
  • func (d *Dao) RealDeleteUserByID(uid string) error
  • func (d *Dao) RemoveOnlineUser(id string) (err error)
  • func (d *Dao) UpdateUserByID(uid string, dataptr *map[string]any) error
  • func (d *Dao) UpdatemessageByID(mid string, data map[string]any) error
  • func (d *Dao) UpdatemessageContentByID(mid, content string) error
  • func (d *Dao) UpdatemessageStatueByID(mid string, state model.MessageStatus) error

Types

type Dao

type Dao struct {
	*r.Session    // rethink 数据库 会话
	*redis.Client // redis 数据库 客户端
}

func NewDao

func NewDao(s *r.Session, c *redis.Client) *Dao

New 实例化 Dao 结构体

func (*Dao) AddOnlineUser

func (d *Dao) AddOnlineUser(user *model.OnlineUser) (err error)

------------------------------------- 增加 ------------------------------------- AddOnlineUser 添加在线用户

func (*Dao) DeleteMessageByID

func (d *Dao) DeleteMessageByID(mid string) error

------------------------------------- 删除 ------------------------------------- DeleteMessageByID 通过消息ID 删除消息 (底层：将消息 is_del 字段标记为 true)

func (*Dao) DeleteUserByID

func (d *Dao) DeleteUserByID(uid string) error

------------------------------------- 删除 ------------------------------------- DeleteUserByID 通过 ID 删除用户 (底层：将用户 字段 is_del 标记为 true)

func (*Dao) FindUserByEmail

func (d *Dao) FindUserByEmail(email string) (*model.User, error)

FindUserByEmail 通过 name 查找用户

func (*Dao) FindUserByID

func (d *Dao) FindUserByID(uid string) (*model.User, error)

------------------------------------- 查找 ------------------------------------- FindUserByID 通过 ID 查找用户

func (*Dao) FindUsersByName

func (d *Dao) FindUsersByName(name string) ([]*model.User, error)

FindUsersByName 通过 name 查找用户

func (*Dao) FindmessageByID

func (d *Dao) FindmessageByID(mid string) (*model.Message, error)

------------------------------------- 查找 ------------------------------------- FindmessageByID 通过 ID 查找消息

func (*Dao) GetOnlineUser

func (d *Dao) GetOnlineUser(id string) (*model.OnlineUser, error)

------------------------------------- 查询 -------------------------------------

func (*Dao) InsertMessage

func (d *Dao) InsertMessage(msg *model.Message) error

------------------------------------- 增加 ------------------------------------- Insertmessage 增加数据

func (*Dao) InsertUser

func (d *Dao) InsertUser(user *model.User) error

------------------------------------- 增加 ------------------------------------- InsertUser 增加用户数据

func (*Dao) IsOnline

func (d *Dao) IsOnline(id string) bool

------------------------------------- 其他 ------------------------------------- IsOnline 用户是否在线

func (*Dao) IstUserExis

func (d *Dao) IstUserExis(uid string) bool

IsExist 判断用户是否存在

func (*Dao) RealDeleteMessageByID

func (d *Dao) RealDeleteMessageByID(mid string) error

DeleteMessageByID 通过 ID 删除消息 (底层：从rethinkdb中删除消息)

func (*Dao) RealDeleteUserByID

func (d *Dao) RealDeleteUserByID(uid string) error

RealDeleteUserByID 通过 ID 删除用户 (底层：将用户从rethinkdb中永久删除)

func (*Dao) RemoveOnlineUser

func (d *Dao) RemoveOnlineUser(id string) (err error)

------------------------------------- 删除 ------------------------------------- RemoveOnlineUser 移除在线用户

func (*Dao) UpdateUserByID

func (d *Dao) UpdateUserByID(uid string, dataptr *map[string]any) error

------------------------------------- 更新 ------------------------------------- UpdateUserByID 通过 ID 更新用户

func (*Dao) UpdatemessageByID

func (d *Dao) UpdatemessageByID(mid string, data map[string]any) error

------------------------------------- 更新 ------------------------------------- UpdatemessageByID 通过 ID 更新消息信息

func (*Dao) UpdatemessageContentByID

func (d *Dao) UpdatemessageContentByID(mid, content string) error

UpdatemessageContentByID 通过消息ID更新消息内容

func (*Dao) UpdatemessageStatueByID

func (d *Dao) UpdatemessageStatueByID(mid string, state model.MessageStatus) error

UpdatemessageStatueByID 通过消息ID更新消息状态