mysql_dao

package
v0.96.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 28, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DialogFiltersDAO 

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

func NewDialogFiltersDAO 

func NewDialogFiltersDAO(db *sqlx.DB) *DialogFiltersDAO

func (*DialogFiltersDAO) Clear 

func (dao *DialogFiltersDAO) Clear(ctx context.Context, user_id int64, dialog_filter_id int32) (rowsAffected int64, err error)

Clear update dialog_filters set deleted = 1, dialog_filter = 'null', order_value = 0 where user_id = :user_id and dialog_filter_id = :dialog_filter_id TODO(@benqi): sqlmap

func (*DialogFiltersDAO) ClearTx 

func (dao *DialogFiltersDAO) ClearTx(tx *sqlx.Tx, user_id int64, dialog_filter_id int32) (rowsAffected int64, err error)

update dialog_filters set deleted = 1, dialog_filter = 'null', order_value = 0 where user_id = :user_id and dialog_filter_id = :dialog_filter_id ClearTx TODO(@benqi): sqlmap

func (*DialogFiltersDAO) InsertOrUpdate 

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

InsertOrUpdate insert into dialog_filters(user_id, dialog_filter_id, dialog_filter, order_value) values (:user_id, :dialog_filter_id, :dialog_filter, :order_value) on duplicate key update dialog_filter = values(dialog_filter), order_value = values(order_value), deleted = 0 TODO(@benqi): sqlmap

func (*DialogFiltersDAO) InsertOrUpdateTx 

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

InsertOrUpdateTx insert into dialog_filters(user_id, dialog_filter_id, dialog_filter, order_value) values (:user_id, :dialog_filter_id, :dialog_filter, :order_value) on duplicate key update dialog_filter = values(dialog_filter), order_value = values(order_value), deleted = 0 TODO(@benqi): sqlmap

func (*DialogFiltersDAO) SelectList 

func (dao *DialogFiltersDAO) SelectList(ctx context.Context, user_id int64) (rList []dataobject.DialogFiltersDO, err error)

SelectList select user_id, dialog_filter_id, dialog_filter from dialog_filters where user_id = :user_id and deleted = 0 order by order_value desc TODO(@benqi): sqlmap

func (*DialogFiltersDAO) SelectListWithCB 

func (dao *DialogFiltersDAO) SelectListWithCB(ctx context.Context, user_id int64, cb func(i int, v *dataobject.DialogFiltersDO)) (rList []dataobject.DialogFiltersDO, err error)

SelectListWithCB select user_id, dialog_filter_id, dialog_filter from dialog_filters where user_id = :user_id and deleted = 0 order by order_value desc TODO(@benqi): sqlmap

func (*DialogFiltersDAO) UpdateOrder 

func (dao *DialogFiltersDAO) UpdateOrder(ctx context.Context, order_value int64, user_id int64, dialog_filter_id int32) (rowsAffected int64, err error)

UpdateOrder update dialog_filters set order_value = :order_value where user_id = :user_id and dialog_filter_id = :dialog_filter_id TODO(@benqi): sqlmap

func (*DialogFiltersDAO) UpdateOrderTx 

func (dao *DialogFiltersDAO) UpdateOrderTx(tx *sqlx.Tx, order_value int64, user_id int64, dialog_filter_id int32) (rowsAffected int64, err error)

update dialog_filters set order_value = :order_value where user_id = :user_id and dialog_filter_id = :dialog_filter_id UpdateOrderTx TODO(@benqi): sqlmap

type DialogsDAO 

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

func NewDialogsDAO 

func NewDialogsDAO(db *sqlx.DB) *DialogsDAO

func (*DialogsDAO) ClearAllDrafts 

func (dao *DialogsDAO) ClearAllDrafts(ctx context.Context, user_id int64) (rowsAffected int64, err error)

ClearAllDrafts update dialogs set draft_type = 0, draft_message_data = 'null' where user_id = :user_id and draft_type = 2 TODO(@benqi): sqlmap

func (*DialogsDAO) ClearAllDraftsTx 

func (dao *DialogsDAO) ClearAllDraftsTx(tx *sqlx.Tx, user_id int64) (rowsAffected int64, err error)

ClearAllDraftsTx update dialogs set draft_type = 0, draft_message_data = 'null' where user_id = :user_id and draft_type = 2 TODO(@benqi): sqlmap

func (*DialogsDAO) Delete 

func (dao *DialogsDAO) Delete(ctx context.Context, user_id int64, peer_type int32, peer_id int64) (rowsAffected int64, err error)

Delete delete from dialogs where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id TODO(@benqi): sqlmap

func (*DialogsDAO) DeleteTx 

func (dao *DialogsDAO) DeleteTx(tx *sqlx.Tx, user_id int64, peer_type int32, peer_id int64) (rowsAffected int64, err error)

DeleteTx delete from dialogs where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id TODO(@benqi): sqlmap

func (*DialogsDAO) InsertIgnore 

func (dao *DialogsDAO) InsertIgnore(ctx context.Context, do *dataobject.DialogsDO) (lastInsertId, rowsAffected int64, err error)

InsertIgnore insert ignore into dialogs(user_id, peer_type, peer_id, peer_dialog_id, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_message_data, date2) values (:user_id, :peer_type, :peer_id, :peer_dialog_id, :top_message, :pinned_msg_id, :read_inbox_max_id, :read_outbox_max_id, :unread_count, :unread_mark, :draft_message_data, :date2) TODO(@benqi): sqlmap

func (*DialogsDAO) InsertIgnoreTx 

func (dao *DialogsDAO) InsertIgnoreTx(tx *sqlx.Tx, do *dataobject.DialogsDO) (lastInsertId, rowsAffected int64, err error)

InsertIgnoreTx insert ignore into dialogs(user_id, peer_type, peer_id, peer_dialog_id, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_message_data, date2) values (:user_id, :peer_type, :peer_id, :peer_dialog_id, :top_message, :pinned_msg_id, :read_inbox_max_id, :read_outbox_max_id, :unread_count, :unread_mark, :draft_message_data, :date2) TODO(@benqi): sqlmap

func (*DialogsDAO) InsertOrUpdate 

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

InsertOrUpdate insert into dialogs(user_id, peer_type, peer_id, peer_dialog_id, top_message, pinned_msg_id, unread_count, draft_message_data, date2) values (:user_id, :peer_type, :peer_id, :peer_dialog_id, :top_message, :pinned_msg_id, :unread_count, :draft_message_data, :date2) on duplicate key update top_message = values(top_message), unread_count = unread_count + values(unread_count), date2 = values(date2) TODO(@benqi): sqlmap

func (*DialogsDAO) InsertOrUpdateDialog 

func (dao *DialogsDAO) InsertOrUpdateDialog(ctx context.Context, do *dataobject.DialogsDO) (lastInsertId, rowsAffected int64, err error)

InsertOrUpdateDialog insert into dialogs(user_id, peer_type, peer_id, peer_dialog_id, top_message, pinned_msg_id, peer_dialog_id, read_inbox_max_id, draft_message_data, date2) values (:user_id, :peer_type, :peer_id, :peer_dialog_id, :top_message, :pinned_msg_id, :peer_dialog_id, :read_inbox_max_id, :draft_message_data, :date2) on duplicate key update top_message = values(top_message), read_inbox_max_id = values(read_inbox_max_id), draft_message_data = values(draft_message_data), date2 = values(date2), deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) InsertOrUpdateDialogTx 

func (dao *DialogsDAO) InsertOrUpdateDialogTx(tx *sqlx.Tx, do *dataobject.DialogsDO) (lastInsertId, rowsAffected int64, err error)

InsertOrUpdateDialogTx insert into dialogs(user_id, peer_type, peer_id, peer_dialog_id, top_message, pinned_msg_id, peer_dialog_id, read_inbox_max_id, draft_message_data, date2) values (:user_id, :peer_type, :peer_id, :peer_dialog_id, :top_message, :pinned_msg_id, :peer_dialog_id, :read_inbox_max_id, :draft_message_data, :date2) on duplicate key update top_message = values(top_message), read_inbox_max_id = values(read_inbox_max_id), draft_message_data = values(draft_message_data), date2 = values(date2), deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) InsertOrUpdateTx 

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

InsertOrUpdateTx insert into dialogs(user_id, peer_type, peer_id, peer_dialog_id, top_message, pinned_msg_id, unread_count, draft_message_data, date2) values (:user_id, :peer_type, :peer_id, :peer_dialog_id, :top_message, :pinned_msg_id, :unread_count, :draft_message_data, :date2) on duplicate key update top_message = values(top_message), unread_count = unread_count + values(unread_count), date2 = values(date2) TODO(@benqi): sqlmap

func (*DialogsDAO) SaveDraft 

func (dao *DialogsDAO) SaveDraft(ctx context.Context, draft_type int32, draft_message_data string, user_id int64, peer_type int32, peer_id int64) (rowsAffected int64, err error)

SaveDraft update dialogs set draft_type = :draft_type, draft_message_data = :draft_message_data where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id TODO(@benqi): sqlmap

func (*DialogsDAO) SaveDraftTx 

func (dao *DialogsDAO) SaveDraftTx(tx *sqlx.Tx, draft_type int32, draft_message_data string, user_id int64, peer_type int32, peer_id int64) (rowsAffected int64, err error)

SaveDraftTx update dialogs set draft_type = :draft_type, draft_message_data = :draft_message_data where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id TODO(@benqi): sqlmap

func (*DialogsDAO) SelectAllDialogs added in v0.90.1 

func (dao *DialogsDAO) SelectAllDialogs(ctx context.Context, user_id int64) (rList []dataobject.DialogsDO, err error)

SelectAllDialogs select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectAllDialogsWithCB added in v0.90.1 

func (dao *DialogsDAO) SelectAllDialogsWithCB(ctx context.Context, user_id int64, cb func(i int, v *dataobject.DialogsDO)) (rList []dataobject.DialogsDO, err error)

SelectAllDialogsWithCB select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectAllDrafts 

func (dao *DialogsDAO) SelectAllDrafts(ctx context.Context, user_id int64) (rList []dataobject.DialogsDO, err error)

SelectAllDrafts select id, user_id, peer_type, peer_id, draft_message_data from dialogs where user_id = :user_id and draft_type > 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectAllDraftsWithCB 

func (dao *DialogsDAO) SelectAllDraftsWithCB(ctx context.Context, user_id int64, cb func(i int, v *dataobject.DialogsDO)) (rList []dataobject.DialogsDO, err error)

SelectAllDraftsWithCB select id, user_id, peer_type, peer_id, draft_message_data from dialogs where user_id = :user_id and draft_type > 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectByPeerDialogId added in v0.86.3 

func (dao *DialogsDAO) SelectByPeerDialogId(ctx context.Context, user_id int64, peer_dialog_id int64) (rValue *dataobject.DialogsDO, err error)

SelectByPeerDialogId select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and peer_dialog_id = :peer_dialog_id and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectDialog 

func (dao *DialogsDAO) SelectDialog(ctx context.Context, user_id int64, peer_type int32, peer_id int64) (rValue *dataobject.DialogsDO, err error)

SelectDialog select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectDialogs 

func (dao *DialogsDAO) SelectDialogs(ctx context.Context, user_id int64, folder_id int32) (rList []dataobject.DialogsDO, err error)

SelectDialogs select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and folder_id = :folder_id and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectDialogsByGTReadInboxMaxId 

func (dao *DialogsDAO) SelectDialogsByGTReadInboxMaxId(ctx context.Context, peer_type int32, peer_id int64, read_inbox_max_id int32, user_id int64) (rList []int64, err error)

SelectDialogsByGTReadInboxMaxId select user_id from dialogs where peer_type = :peer_type and peer_id = :peer_id and read_inbox_max_id >= :read_inbox_max_id and user_id != :user_id TODO(@benqi): sqlmap

func (*DialogsDAO) SelectDialogsByGTReadInboxMaxIdWithCB 

func (dao *DialogsDAO) SelectDialogsByGTReadInboxMaxIdWithCB(ctx context.Context, peer_type int32, peer_id int64, read_inbox_max_id int32, user_id int64, cb func(i int, v int64)) (rList []int64, err error)

SelectDialogsByGTReadInboxMaxIdWithCB select user_id from dialogs where peer_type = :peer_type and peer_id = :peer_id and read_inbox_max_id >= :read_inbox_max_id and user_id != :user_id TODO(@benqi): sqlmap

func (*DialogsDAO) SelectDialogsByPeerType added in v0.90.1 

func (dao *DialogsDAO) SelectDialogsByPeerType(ctx context.Context, user_id int64, peerTypeList []int32) (rList []dataobject.DialogsDO, err error)

SelectDialogsByPeerType select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and peer_type in (:peerTypeList) and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectDialogsByPeerTypeWithCB added in v0.90.1 

func (dao *DialogsDAO) SelectDialogsByPeerTypeWithCB(ctx context.Context, user_id int64, peerTypeList []int32, cb func(i int, v *dataobject.DialogsDO)) (rList []dataobject.DialogsDO, err error)

SelectDialogsByPeerTypeWithCB select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and peer_type in (:peerTypeList) and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectDialogsWithCB 

func (dao *DialogsDAO) SelectDialogsWithCB(ctx context.Context, user_id int64, folder_id int32, cb func(i int, v *dataobject.DialogsDO)) (rList []dataobject.DialogsDO, err error)

SelectDialogsWithCB select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and folder_id = :folder_id and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectExcludeFolderPinnedDialogs 

func (dao *DialogsDAO) SelectExcludeFolderPinnedDialogs(ctx context.Context, user_id int64) (rList []dataobject.DialogsDO, err error)

SelectExcludeFolderPinnedDialogs select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and folder_id = 1 and folder_pinned = 0 and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectExcludeFolderPinnedDialogsWithCB 

func (dao *DialogsDAO) SelectExcludeFolderPinnedDialogsWithCB(ctx context.Context, user_id int64, cb func(i int, v *dataobject.DialogsDO)) (rList []dataobject.DialogsDO, err error)

SelectExcludeFolderPinnedDialogsWithCB select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and folder_id = 1 and folder_pinned = 0 and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectExcludePinnedDialogs 

func (dao *DialogsDAO) SelectExcludePinnedDialogs(ctx context.Context, user_id int64) (rList []dataobject.DialogsDO, err error)

SelectExcludePinnedDialogs select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and folder_id = 0 and pinned = 0 and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectExcludePinnedDialogsWithCB 

func (dao *DialogsDAO) SelectExcludePinnedDialogsWithCB(ctx context.Context, user_id int64, cb func(i int, v *dataobject.DialogsDO)) (rList []dataobject.DialogsDO, err error)

SelectExcludePinnedDialogsWithCB select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and folder_id = 0 and pinned = 0 and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectFolderPinnedDialogs 

func (dao *DialogsDAO) SelectFolderPinnedDialogs(ctx context.Context, user_id int64) (rList []dataobject.DialogsDO, err error)

SelectFolderPinnedDialogs select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and folder_id = 1 and folder_pinned > 0 and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectFolderPinnedDialogsWithCB 

func (dao *DialogsDAO) SelectFolderPinnedDialogsWithCB(ctx context.Context, user_id int64, cb func(i int, v *dataobject.DialogsDO)) (rList []dataobject.DialogsDO, err error)

SelectFolderPinnedDialogsWithCB select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and folder_id = 1 and folder_pinned > 0 and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectPeerDialogList 

func (dao *DialogsDAO) SelectPeerDialogList(ctx context.Context, user_id int64, idList []int64) (rList []dataobject.DialogsDO, err error)

SelectPeerDialogList select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and peer_dialog_id in (:idList) and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectPeerDialogListWithCB 

func (dao *DialogsDAO) SelectPeerDialogListWithCB(ctx context.Context, user_id int64, idList []int64, cb func(i int, v *dataobject.DialogsDO)) (rList []dataobject.DialogsDO, err error)

SelectPeerDialogListWithCB select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and peer_dialog_id in (:idList) and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectPinnedDialogs 

func (dao *DialogsDAO) SelectPinnedDialogs(ctx context.Context, user_id int64) (rList []dataobject.DialogsDO, err error)

SelectPinnedDialogs select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and folder_id = 0 and pinned > 0 and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) SelectPinnedDialogsWithCB 

func (dao *DialogsDAO) SelectPinnedDialogsWithCB(ctx context.Context, user_id int64, cb func(i int, v *dataobject.DialogsDO)) (rList []dataobject.DialogsDO, err error)

SelectPinnedDialogsWithCB select id, user_id, peer_type, peer_id, peer_dialog_id, pinned, top_message, pinned_msg_id, read_inbox_max_id, read_outbox_max_id, unread_count, unread_mark, draft_type, draft_message_data, folder_id, folder_pinned, has_scheduled, ttl_period, theme_emoticon, date2 from dialogs where user_id = :user_id and folder_id = 0 and pinned > 0 and deleted = 0 TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateCustomMap 

func (dao *DialogsDAO) UpdateCustomMap(ctx context.Context, cMap map[string]interface{}, user_id int64, peer_type int32, peer_id int64) (rowsAffected int64, err error)

UpdateCustomMap update dialogs set %s where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateCustomMapTx 

func (dao *DialogsDAO) UpdateCustomMapTx(tx *sqlx.Tx, cMap map[string]interface{}, user_id int64, peer_type int32, peer_id int64) (rowsAffected int64, err error)

UpdateCustomMapTx update dialogs set %s where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateFolderPeerDialogListPinned 

func (dao *DialogsDAO) UpdateFolderPeerDialogListPinned(ctx context.Context, folder_pinned int64, user_id int64, idList []int64) (rowsAffected int64, err error)

UpdateFolderPeerDialogListPinned update dialogs set folder_pinned = :folder_pinned where user_id = :user_id and folder_id = 1 and peer_dialog_id in (:idList) TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateFolderPeerDialogListPinnedTx 

func (dao *DialogsDAO) UpdateFolderPeerDialogListPinnedTx(tx *sqlx.Tx, folder_pinned int64, user_id int64, idList []int64) (rowsAffected int64, err error)

UpdateFolderPeerDialogListPinnedTx update dialogs set folder_pinned = :folder_pinned where user_id = :user_id and folder_id = 1 and peer_dialog_id in (:idList) TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateFolderUnPinnedNotIdList added in v0.86.3 

func (dao *DialogsDAO) UpdateFolderUnPinnedNotIdList(ctx context.Context, user_id int64, idList []int64) (rowsAffected int64, err error)

UpdateFolderUnPinnedNotIdList update dialogs set folder_pinned = 0 where user_id = :user_id and folder_id = 1 and folder_pinned > 0 and peer_dialog_id not in (:idList) TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateFolderUnPinnedNotIdListTx added in v0.86.3 

func (dao *DialogsDAO) UpdateFolderUnPinnedNotIdListTx(tx *sqlx.Tx, user_id int64, idList []int64) (rowsAffected int64, err error)

UpdateFolderUnPinnedNotIdListTx update dialogs set folder_pinned = 0 where user_id = :user_id and folder_id = 1 and folder_pinned > 0 and peer_dialog_id not in (:idList) TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateInboxDialog 

func (dao *DialogsDAO) UpdateInboxDialog(ctx context.Context, cMap map[string]interface{}, user_id int64, peer_type int32, peer_id int64) (rowsAffected int64, err error)

UpdateInboxDialog update dialogs set unread_count = unread_count + 1, deleted = 0, %s where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateInboxDialogTx 

func (dao *DialogsDAO) UpdateInboxDialogTx(tx *sqlx.Tx, cMap map[string]interface{}, user_id int64, peer_type int32, peer_id int64) (rowsAffected int64, err error)

UpdateInboxDialogTx update dialogs set unread_count = unread_count + 1, deleted = 0, %s where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateOutboxDialog 

func (dao *DialogsDAO) UpdateOutboxDialog(ctx context.Context, top_message int32, date2 int64, user_id int64, peer_type int32, peer_id int64) (rowsAffected int64, err error)

UpdateOutboxDialog update dialogs set unread_count = 0, deleted = 0, top_message = :top_message, date2 = :date2, unread_mark = 0, draft_message_data = 'null' where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateOutboxDialogTx 

func (dao *DialogsDAO) UpdateOutboxDialogTx(tx *sqlx.Tx, top_message int32, date2 int64, user_id int64, peer_type int32, peer_id int64) (rowsAffected int64, err error)

UpdateOutboxDialogTx update dialogs set unread_count = 0, deleted = 0, top_message = :top_message, date2 = :date2, unread_mark = 0, draft_message_data = 'null' where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdatePeerDialogListFolderId 

func (dao *DialogsDAO) UpdatePeerDialogListFolderId(ctx context.Context, folder_id int32, user_id int64, idList []int64) (rowsAffected int64, err error)

UpdatePeerDialogListFolderId update dialogs set folder_id = :folder_id where user_id = :user_id and peer_dialog_id in (:idList) TODO(@benqi): sqlmap

func (*DialogsDAO) UpdatePeerDialogListFolderIdTx 

func (dao *DialogsDAO) UpdatePeerDialogListFolderIdTx(tx *sqlx.Tx, folder_id int32, user_id int64, idList []int64) (rowsAffected int64, err error)

UpdatePeerDialogListFolderIdTx update dialogs set folder_id = :folder_id where user_id = :user_id and peer_dialog_id in (:idList) TODO(@benqi): sqlmap

func (*DialogsDAO) UpdatePeerDialogListPinned 

func (dao *DialogsDAO) UpdatePeerDialogListPinned(ctx context.Context, pinned int64, user_id int64, idList []int64) (rowsAffected int64, err error)

UpdatePeerDialogListPinned update dialogs set pinned = :pinned where user_id = :user_id and folder_id = 0 and peer_dialog_id in (:idList) TODO(@benqi): sqlmap

func (*DialogsDAO) UpdatePeerDialogListPinnedTx 

func (dao *DialogsDAO) UpdatePeerDialogListPinnedTx(tx *sqlx.Tx, pinned int64, user_id int64, idList []int64) (rowsAffected int64, err error)

UpdatePeerDialogListPinnedTx update dialogs set pinned = :pinned where user_id = :user_id and folder_id = 0 and peer_dialog_id in (:idList) TODO(@benqi): sqlmap

func (*DialogsDAO) UpdatePeerFolderId 

func (dao *DialogsDAO) UpdatePeerFolderId(ctx context.Context, folder_id int32, user_id int64, peer_type int32, peer_id int64) (rowsAffected int64, err error)

UpdatePeerFolderId update dialogs set folder_id = :folder_id where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdatePeerFolderIdTx 

func (dao *DialogsDAO) UpdatePeerFolderIdTx(tx *sqlx.Tx, folder_id int32, user_id int64, peer_type int32, peer_id int64) (rowsAffected int64, err error)

UpdatePeerFolderIdTx update dialogs set folder_id = :folder_id where user_id = :user_id and peer_type = :peer_type and peer_id = :peer_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdatePinnedMsgId 

func (dao *DialogsDAO) UpdatePinnedMsgId(ctx context.Context, pinned_msg_id int32, user_id int64, peer_dialog_id int64) (rowsAffected int64, err error)

UpdatePinnedMsgId update dialogs set pinned_msg_id = :pinned_msg_id where user_id = :user_id and peer_dialog_id = :peer_dialog_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdatePinnedMsgIdTx 

func (dao *DialogsDAO) UpdatePinnedMsgIdTx(tx *sqlx.Tx, pinned_msg_id int32, user_id int64, peer_dialog_id int64) (rowsAffected int64, err error)

UpdatePinnedMsgIdTx update dialogs set pinned_msg_id = :pinned_msg_id where user_id = :user_id and peer_dialog_id = :peer_dialog_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateReadInboxMaxId 

func (dao *DialogsDAO) UpdateReadInboxMaxId(ctx context.Context, unread_count int32, read_inbox_max_id int32, user_id int64, peer_dialog_id int64) (rowsAffected int64, err error)

UpdateReadInboxMaxId update dialogs set unread_count = :unread_count, unread_mark = 0, read_inbox_max_id = :read_inbox_max_id where user_id = :user_id and peer_dialog_id = :peer_dialog_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateReadInboxMaxIdTx 

func (dao *DialogsDAO) UpdateReadInboxMaxIdTx(tx *sqlx.Tx, unread_count int32, read_inbox_max_id int32, user_id int64, peer_dialog_id int64) (rowsAffected int64, err error)

UpdateReadInboxMaxIdTx update dialogs set unread_count = :unread_count, unread_mark = 0, read_inbox_max_id = :read_inbox_max_id where user_id = :user_id and peer_dialog_id = :peer_dialog_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateReadOutboxMaxId 

func (dao *DialogsDAO) UpdateReadOutboxMaxId(ctx context.Context, read_outbox_max_id int32, user_id int64, peer_dialog_id int64) (rowsAffected int64, err error)

UpdateReadOutboxMaxId update dialogs set read_outbox_max_id = :read_outbox_max_id where user_id = :user_id and peer_dialog_id = :peer_dialog_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateReadOutboxMaxIdTx 

func (dao *DialogsDAO) UpdateReadOutboxMaxIdTx(tx *sqlx.Tx, read_outbox_max_id int32, user_id int64, peer_dialog_id int64) (rowsAffected int64, err error)

UpdateReadOutboxMaxIdTx update dialogs set read_outbox_max_id = :read_outbox_max_id where user_id = :user_id and peer_dialog_id = :peer_dialog_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateTopMessage 

func (dao *DialogsDAO) UpdateTopMessage(ctx context.Context, top_message int32, user_id int64, peer_dialog_id int64) (rowsAffected int64, err error)

UpdateTopMessage update dialogs set top_message = :top_message where user_id = :user_id and peer_dialog_id = :peer_dialog_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateTopMessageTx 

func (dao *DialogsDAO) UpdateTopMessageTx(tx *sqlx.Tx, top_message int32, user_id int64, peer_dialog_id int64) (rowsAffected int64, err error)

UpdateTopMessageTx update dialogs set top_message = :top_message where user_id = :user_id and peer_dialog_id = :peer_dialog_id TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateUnPinnedNotIdList added in v0.86.3 

func (dao *DialogsDAO) UpdateUnPinnedNotIdList(ctx context.Context, user_id int64, idList []int64) (rowsAffected int64, err error)

UpdateUnPinnedNotIdList update dialogs set pinned = 0 where user_id = :user_id and folder_id = 0 and pinned > 0 and peer_dialog_id not in (:idList) TODO(@benqi): sqlmap

func (*DialogsDAO) UpdateUnPinnedNotIdListTx added in v0.86.3 

func (dao *DialogsDAO) UpdateUnPinnedNotIdListTx(tx *sqlx.Tx, user_id int64, idList []int64) (rowsAffected int64, err error)

UpdateUnPinnedNotIdListTx update dialogs set pinned = 0 where user_id = :user_id and folder_id = 0 and pinned > 0 and peer_dialog_id not in (:idList) TODO(@benqi): sqlmap

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.