mysql_dao

package

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

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/teamgram/teamgram-server

Links

Open Source Insights

Documentation ¶

Index ¶

type DialogFiltersDAO
- func NewDialogFiltersDAO(db *sqlx.DB) *DialogFiltersDAO
type DialogsDAO
- func NewDialogsDAO(db *sqlx.DB) *DialogsDAO

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL