mysql_dao

Documentation

Index

• Variables
• type ChatParticipantsDAO
• type DialogsDAO
• type HashTagsDAO
  • func NewHashTagsDAO(db *sqlx.DB) *HashTagsDAO
  • func (dao *HashTagsDAO) DeleteHashTagMessageId(ctx context.Context, user_id int64, hash_tag_message_id int32) (rowsAffected int64, err error)
  • func (dao *HashTagsDAO) DeleteHashTagMessageIdTx(tx *sqlx.Tx, user_id int64, hash_tag_message_id int32) (rowsAffected int64, err error)
  • func (dao *HashTagsDAO) InsertOrUpdate(ctx context.Context, do *dataobject.HashTagsDO) (lastInsertId, rowsAffected int64, err error)
  • func (dao *HashTagsDAO) InsertOrUpdateTx(tx *sqlx.Tx, do *dataobject.HashTagsDO) (lastInsertId, rowsAffected int64, err error)
  • func (dao *HashTagsDAO) SelectPeerHashTagList(ctx context.Context, user_id int64, peer_type int32, peer_id int64, ...) (rList []int32, err error)
  • func (dao *HashTagsDAO) SelectPeerHashTagListWithCB(ctx context.Context, user_id int64, peer_type int32, peer_id int64, ...) (rList []int32, err error)
• type MessagesDAO

Variables

var (
	NewChatParticipantsDAO = chat_helper.NewChatParticipantsDAO
)

var (
	NewDialogsDAO = dialog_helper.NewDialogsDAO
)

var (
	NewMessagesDAO = message_helper.NewMessagesDAO
)

Types

type ChatParticipantsDAO

type ChatParticipantsDAO = chat_helper.ChatParticipantsDAO

type DialogsDAO

type DialogsDAO = dialog_helper.DialogsDAO

type HashTagsDAO

type HashTagsDAO struct {
	// contains filtered or unexported fields
}

func NewHashTagsDAO

func NewHashTagsDAO(db *sqlx.DB) *HashTagsDAO

func (*HashTagsDAO) DeleteHashTagMessageId

func (dao *HashTagsDAO) DeleteHashTagMessageId(ctx context.Context, user_id int64, hash_tag_message_id int32) (rowsAffected int64, err error)

DeleteHashTagMessageId update hash_tags set deleted = 1 where user_id = :user_id and hash_tag_message_id = :hash_tag_message_id TODO(@benqi): sqlmap

func (*HashTagsDAO) DeleteHashTagMessageIdTx

func (dao *HashTagsDAO) DeleteHashTagMessageIdTx(tx *sqlx.Tx, user_id int64, hash_tag_message_id int32) (rowsAffected int64, err error)

update hash_tags set deleted = 1 where user_id = :user_id and hash_tag_message_id = :hash_tag_message_id DeleteHashTagMessageIdTx TODO(@benqi): sqlmap

func (*HashTagsDAO) InsertOrUpdate

func (dao *HashTagsDAO) InsertOrUpdate(ctx context.Context, do *dataobject.HashTagsDO) (lastInsertId, rowsAffected int64, err error)

InsertOrUpdate insert into hash_tags(user_id, peer_type, peer_id, hash_tag, hash_tag_message_id) values (:user_id, :peer_type, :peer_id, :hash_tag, :hash_tag_message_id) on duplicate key update deleted = 0 TODO(@benqi): sqlmap

func (*HashTagsDAO) InsertOrUpdateTx

func (dao *HashTagsDAO) InsertOrUpdateTx(tx *sqlx.Tx, do *dataobject.HashTagsDO) (lastInsertId, rowsAffected int64, err error)

InsertOrUpdateTx insert into hash_tags(user_id, peer_type, peer_id, hash_tag, hash_tag_message_id) values (:user_id, :peer_type, :peer_id, :hash_tag, :hash_tag_message_id) on duplicate key update deleted = 0 TODO(@benqi): sqlmap

func (*HashTagsDAO) SelectPeerHashTagList

func (dao *HashTagsDAO) SelectPeerHashTagList(ctx context.Context, user_id int64, peer_type int32, peer_id int64, hash_tag string) (rList []int32, err error)

SelectPeerHashTagList select hash_tag_message_id from hash_tags where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id and hash_tag = :hash_tag and deleted = 0 TODO(@benqi): sqlmap

func (*HashTagsDAO) SelectPeerHashTagListWithCB

func (dao *HashTagsDAO) SelectPeerHashTagListWithCB(ctx context.Context, user_id int64, peer_type int32, peer_id int64, hash_tag string, cb func(i int, v int32)) (rList []int32, err error)

SelectPeerHashTagListWithCB select hash_tag_message_id from hash_tags where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id and hash_tag = :hash_tag and deleted = 0 TODO(@benqi): sqlmap

type MessagesDAO

type MessagesDAO = message_helper.MessagesDAO