Documentation ¶
Index ¶
- type AuthSeqUpdatesDAO
- func (dao *AuthSeqUpdatesDAO) Insert(ctx context.Context, do *dataobject.AuthSeqUpdatesDO) (lastInsertId, rowsAffected int64, err error)
- func (dao *AuthSeqUpdatesDAO) InsertTx(tx *sqlx.Tx, do *dataobject.AuthSeqUpdatesDO) (lastInsertId, rowsAffected int64, err error)
- func (dao *AuthSeqUpdatesDAO) SelectByGtDate(ctx context.Context, auth_id int64, user_id int64, date2 int64) (rList []dataobject.AuthSeqUpdatesDO, err error)
- func (dao *AuthSeqUpdatesDAO) SelectByGtDateWithCB(ctx context.Context, auth_id int64, user_id int64, date2 int64, ...) (rList []dataobject.AuthSeqUpdatesDO, err error)
- func (dao *AuthSeqUpdatesDAO) SelectByGtSeq(ctx context.Context, auth_id int64, user_id int64, seq int32) (rList []dataobject.AuthSeqUpdatesDO, err error)
- func (dao *AuthSeqUpdatesDAO) SelectByGtSeqWithCB(ctx context.Context, auth_id int64, user_id int64, seq int32, ...) (rList []dataobject.AuthSeqUpdatesDO, err error)
- func (dao *AuthSeqUpdatesDAO) SelectLastSeq(ctx context.Context, auth_id int64, user_id int64) (rValue *dataobject.AuthSeqUpdatesDO, err error)
- type BotUpdatesDAO
- func (dao *BotUpdatesDAO) Insert(ctx context.Context, do *dataobject.BotUpdatesDO) (lastInsertId, rowsAffected int64, err error)
- func (dao *BotUpdatesDAO) InsertTx(tx *sqlx.Tx, do *dataobject.BotUpdatesDO) (lastInsertId, rowsAffected int64, err error)
- func (dao *BotUpdatesDAO) SelectByGtUpdateId(ctx context.Context, bot_id int64, update_id int32, limit int32) (rList []dataobject.BotUpdatesDO, err error)
- func (dao *BotUpdatesDAO) SelectByGtUpdateIdWithCB(ctx context.Context, bot_id int64, update_id int32, limit int32, ...) (rList []dataobject.BotUpdatesDO, err error)
- func (dao *BotUpdatesDAO) SelectByLastUpdateId(ctx context.Context, bot_id int64) (rValue *dataobject.BotUpdatesDO, err error)
- type ChannelPtsUpdatesDAO
- func (dao *ChannelPtsUpdatesDAO) Insert(ctx context.Context, do *dataobject.ChannelPtsUpdatesDO) (lastInsertId, rowsAffected int64, err error)
- func (dao *ChannelPtsUpdatesDAO) InsertTx(tx *sqlx.Tx, do *dataobject.ChannelPtsUpdatesDO) (lastInsertId, rowsAffected int64, err error)
- func (dao *ChannelPtsUpdatesDAO) SelectByGtPts(ctx context.Context, channel_id int64, pts int32) (rList []dataobject.ChannelPtsUpdatesDO, err error)
- func (dao *ChannelPtsUpdatesDAO) SelectByGtPtsWithCB(ctx context.Context, channel_id int64, pts int32, ...) (rList []dataobject.ChannelPtsUpdatesDO, err error)
- func (dao *ChannelPtsUpdatesDAO) SelectLastPts(ctx context.Context, channel_id int64) (rValue *dataobject.ChannelPtsUpdatesDO, err error)
- type UserPtsUpdatesDAO
- func (dao *UserPtsUpdatesDAO) Insert(ctx context.Context, do *dataobject.UserPtsUpdatesDO) (lastInsertId, rowsAffected int64, err error)
- func (dao *UserPtsUpdatesDAO) InsertTx(tx *sqlx.Tx, do *dataobject.UserPtsUpdatesDO) (lastInsertId, rowsAffected int64, err error)
- func (dao *UserPtsUpdatesDAO) SelectByGtPts(ctx context.Context, user_id int64, pts int32) (rList []dataobject.UserPtsUpdatesDO, err error)
- func (dao *UserPtsUpdatesDAO) SelectByGtPtsWithCB(ctx context.Context, user_id int64, pts int32, ...) (rList []dataobject.UserPtsUpdatesDO, err error)
- func (dao *UserPtsUpdatesDAO) SelectLastPts(ctx context.Context, user_id int64) (rValue *dataobject.UserPtsUpdatesDO, err error)
- type UserQtsUpdatesDAO
- func (dao *UserQtsUpdatesDAO) Insert(ctx context.Context, do *dataobject.UserQtsUpdatesDO) (lastInsertId, rowsAffected int64, err error)
- func (dao *UserQtsUpdatesDAO) InsertTx(tx *sqlx.Tx, do *dataobject.UserQtsUpdatesDO) (lastInsertId, rowsAffected int64, err error)
- func (dao *UserQtsUpdatesDAO) SelectByGtQts(ctx context.Context, user_id int64, qts int32) (rList []dataobject.UserQtsUpdatesDO, err error)
- func (dao *UserQtsUpdatesDAO) SelectByGtQtsWithCB(ctx context.Context, user_id int64, qts int32, ...) (rList []dataobject.UserQtsUpdatesDO, err error)
- func (dao *UserQtsUpdatesDAO) SelectLastQts(ctx context.Context, user_id int64) (rValue *dataobject.UserQtsUpdatesDO, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AuthSeqUpdatesDAO ¶
type AuthSeqUpdatesDAO struct {
// contains filtered or unexported fields
}
func NewAuthSeqUpdatesDAO ¶
func NewAuthSeqUpdatesDAO(db *sqlx.DB) *AuthSeqUpdatesDAO
func (*AuthSeqUpdatesDAO) Insert ¶
func (dao *AuthSeqUpdatesDAO) Insert(ctx context.Context, do *dataobject.AuthSeqUpdatesDO) (lastInsertId, rowsAffected int64, err error)
Insert insert into auth_seq_updates(auth_id, user_id, seq, update_type, update_data, date2) values (:auth_id, :user_id, :seq, :update_type, :update_data, :date2) TODO(@benqi): sqlmap
func (*AuthSeqUpdatesDAO) InsertTx ¶
func (dao *AuthSeqUpdatesDAO) InsertTx(tx *sqlx.Tx, do *dataobject.AuthSeqUpdatesDO) (lastInsertId, rowsAffected int64, err error)
InsertTx insert into auth_seq_updates(auth_id, user_id, seq, update_type, update_data, date2) values (:auth_id, :user_id, :seq, :update_type, :update_data, :date2) TODO(@benqi): sqlmap
func (*AuthSeqUpdatesDAO) SelectByGtDate ¶
func (dao *AuthSeqUpdatesDAO) SelectByGtDate(ctx context.Context, auth_id int64, user_id int64, date2 int64) (rList []dataobject.AuthSeqUpdatesDO, err error)
SelectByGtDate select auth_id, user_id, seq, update_type, update_data, date2 from auth_seq_updates where auth_id = :auth_id and user_id = :user_id and date2 > :date2 order by seq asc TODO(@benqi): sqlmap
func (*AuthSeqUpdatesDAO) SelectByGtDateWithCB ¶
func (dao *AuthSeqUpdatesDAO) SelectByGtDateWithCB(ctx context.Context, auth_id int64, user_id int64, date2 int64, cb func(i int, v *dataobject.AuthSeqUpdatesDO)) (rList []dataobject.AuthSeqUpdatesDO, err error)
SelectByGtDateWithCB select auth_id, user_id, seq, update_type, update_data, date2 from auth_seq_updates where auth_id = :auth_id and user_id = :user_id and date2 > :date2 order by seq asc TODO(@benqi): sqlmap
func (*AuthSeqUpdatesDAO) SelectByGtSeq ¶
func (dao *AuthSeqUpdatesDAO) SelectByGtSeq(ctx context.Context, auth_id int64, user_id int64, seq int32) (rList []dataobject.AuthSeqUpdatesDO, err error)
SelectByGtSeq select auth_id, user_id, seq, update_type, update_data, date2 from auth_seq_updates where auth_id = :auth_id and user_id = :user_id and seq > :seq order by seq asc TODO(@benqi): sqlmap
func (*AuthSeqUpdatesDAO) SelectByGtSeqWithCB ¶
func (dao *AuthSeqUpdatesDAO) SelectByGtSeqWithCB(ctx context.Context, auth_id int64, user_id int64, seq int32, cb func(i int, v *dataobject.AuthSeqUpdatesDO)) (rList []dataobject.AuthSeqUpdatesDO, err error)
SelectByGtSeqWithCB select auth_id, user_id, seq, update_type, update_data, date2 from auth_seq_updates where auth_id = :auth_id and user_id = :user_id and seq > :seq order by seq asc TODO(@benqi): sqlmap
func (*AuthSeqUpdatesDAO) SelectLastSeq ¶
func (dao *AuthSeqUpdatesDAO) SelectLastSeq(ctx context.Context, auth_id int64, user_id int64) (rValue *dataobject.AuthSeqUpdatesDO, err error)
SelectLastSeq select seq from auth_seq_updates where auth_id = :auth_id and user_id = :user_id order by seq desc limit 1 TODO(@benqi): sqlmap
type BotUpdatesDAO ¶
type BotUpdatesDAO struct {
// contains filtered or unexported fields
}
func NewBotUpdatesDAO ¶
func NewBotUpdatesDAO(db *sqlx.DB) *BotUpdatesDAO
func (*BotUpdatesDAO) Insert ¶
func (dao *BotUpdatesDAO) Insert(ctx context.Context, do *dataobject.BotUpdatesDO) (lastInsertId, rowsAffected int64, err error)
Insert insert into bot_updates(bot_id, update_id, update_type, update_data, date2) values (:bot_id, :update_id, :update_type, :update_data, :date2) TODO(@benqi): sqlmap
func (*BotUpdatesDAO) InsertTx ¶
func (dao *BotUpdatesDAO) InsertTx(tx *sqlx.Tx, do *dataobject.BotUpdatesDO) (lastInsertId, rowsAffected int64, err error)
InsertTx insert into bot_updates(bot_id, update_id, update_type, update_data, date2) values (:bot_id, :update_id, :update_type, :update_data, :date2) TODO(@benqi): sqlmap
func (*BotUpdatesDAO) SelectByGtUpdateId ¶
func (dao *BotUpdatesDAO) SelectByGtUpdateId(ctx context.Context, bot_id int64, update_id int32, limit int32) (rList []dataobject.BotUpdatesDO, err error)
SelectByGtUpdateId select bot_id, update_id, update_type, update_data, date2 from bot_updates where bot_id = :bot_id and update_id > :update_id order by update_id asc limit :limit TODO(@benqi): sqlmap
func (*BotUpdatesDAO) SelectByGtUpdateIdWithCB ¶
func (dao *BotUpdatesDAO) SelectByGtUpdateIdWithCB(ctx context.Context, bot_id int64, update_id int32, limit int32, cb func(i int, v *dataobject.BotUpdatesDO)) (rList []dataobject.BotUpdatesDO, err error)
SelectByGtUpdateIdWithCB select bot_id, update_id, update_type, update_data, date2 from bot_updates where bot_id = :bot_id and update_id > :update_id order by update_id asc limit :limit TODO(@benqi): sqlmap
func (*BotUpdatesDAO) SelectByLastUpdateId ¶
func (dao *BotUpdatesDAO) SelectByLastUpdateId(ctx context.Context, bot_id int64) (rValue *dataobject.BotUpdatesDO, err error)
SelectByLastUpdateId select bot_id, update_id, update_type, update_data, date2 from bot_updates where bot_id = :bot_id order by update_id desc limit 1 TODO(@benqi): sqlmap
type ChannelPtsUpdatesDAO ¶
type ChannelPtsUpdatesDAO struct {
// contains filtered or unexported fields
}
func NewChannelPtsUpdatesDAO ¶
func NewChannelPtsUpdatesDAO(db *sqlx.DB) *ChannelPtsUpdatesDAO
func (*ChannelPtsUpdatesDAO) Insert ¶
func (dao *ChannelPtsUpdatesDAO) Insert(ctx context.Context, do *dataobject.ChannelPtsUpdatesDO) (lastInsertId, rowsAffected int64, err error)
Insert insert into channel_pts_updates(channel_id, pts, pts_count, update_type, update_data, date2) values (:channel_id, :pts, :pts_count, :update_type, :update_data, :date2) TODO(@benqi): sqlmap
func (*ChannelPtsUpdatesDAO) InsertTx ¶
func (dao *ChannelPtsUpdatesDAO) InsertTx(tx *sqlx.Tx, do *dataobject.ChannelPtsUpdatesDO) (lastInsertId, rowsAffected int64, err error)
InsertTx insert into channel_pts_updates(channel_id, pts, pts_count, update_type, update_data, date2) values (:channel_id, :pts, :pts_count, :update_type, :update_data, :date2) TODO(@benqi): sqlmap
func (*ChannelPtsUpdatesDAO) SelectByGtPts ¶
func (dao *ChannelPtsUpdatesDAO) SelectByGtPts(ctx context.Context, channel_id int64, pts int32) (rList []dataobject.ChannelPtsUpdatesDO, err error)
SelectByGtPts select channel_id, pts, pts_count, update_type, update_data from channel_pts_updates where channel_id = :channel_id and pts > :pts order by pts asc TODO(@benqi): sqlmap
func (*ChannelPtsUpdatesDAO) SelectByGtPtsWithCB ¶
func (dao *ChannelPtsUpdatesDAO) SelectByGtPtsWithCB(ctx context.Context, channel_id int64, pts int32, cb func(i int, v *dataobject.ChannelPtsUpdatesDO)) (rList []dataobject.ChannelPtsUpdatesDO, err error)
SelectByGtPtsWithCB select channel_id, pts, pts_count, update_type, update_data from channel_pts_updates where channel_id = :channel_id and pts > :pts order by pts asc TODO(@benqi): sqlmap
func (*ChannelPtsUpdatesDAO) SelectLastPts ¶
func (dao *ChannelPtsUpdatesDAO) SelectLastPts(ctx context.Context, channel_id int64) (rValue *dataobject.ChannelPtsUpdatesDO, err error)
SelectLastPts select pts from channel_pts_updates where channel_id = :channel_id order by pts desc limit 1 TODO(@benqi): sqlmap
type UserPtsUpdatesDAO ¶
type UserPtsUpdatesDAO struct {
// contains filtered or unexported fields
}
func NewUserPtsUpdatesDAO ¶
func NewUserPtsUpdatesDAO(db *sqlx.DB) *UserPtsUpdatesDAO
func (*UserPtsUpdatesDAO) Insert ¶
func (dao *UserPtsUpdatesDAO) Insert(ctx context.Context, do *dataobject.UserPtsUpdatesDO) (lastInsertId, rowsAffected int64, err error)
Insert insert into user_pts_updates(user_id, pts, pts_count, update_type, update_data, date2) values (:user_id, :pts, :pts_count, :update_type, :update_data, :date2) TODO(@benqi): sqlmap
func (*UserPtsUpdatesDAO) InsertTx ¶
func (dao *UserPtsUpdatesDAO) InsertTx(tx *sqlx.Tx, do *dataobject.UserPtsUpdatesDO) (lastInsertId, rowsAffected int64, err error)
InsertTx insert into user_pts_updates(user_id, pts, pts_count, update_type, update_data, date2) values (:user_id, :pts, :pts_count, :update_type, :update_data, :date2) TODO(@benqi): sqlmap
func (*UserPtsUpdatesDAO) SelectByGtPts ¶
func (dao *UserPtsUpdatesDAO) SelectByGtPts(ctx context.Context, user_id int64, pts int32) (rList []dataobject.UserPtsUpdatesDO, err error)
SelectByGtPts select user_id, pts, pts_count, update_type, update_data from user_pts_updates where user_id = :user_id and pts > :pts order by pts asc TODO(@benqi): sqlmap
func (*UserPtsUpdatesDAO) SelectByGtPtsWithCB ¶
func (dao *UserPtsUpdatesDAO) SelectByGtPtsWithCB(ctx context.Context, user_id int64, pts int32, cb func(i int, v *dataobject.UserPtsUpdatesDO)) (rList []dataobject.UserPtsUpdatesDO, err error)
SelectByGtPtsWithCB select user_id, pts, pts_count, update_type, update_data from user_pts_updates where user_id = :user_id and pts > :pts order by pts asc TODO(@benqi): sqlmap
func (*UserPtsUpdatesDAO) SelectLastPts ¶
func (dao *UserPtsUpdatesDAO) SelectLastPts(ctx context.Context, user_id int64) (rValue *dataobject.UserPtsUpdatesDO, err error)
SelectLastPts select pts from user_pts_updates where user_id = :user_id order by pts desc limit 1 TODO(@benqi): sqlmap
type UserQtsUpdatesDAO ¶
type UserQtsUpdatesDAO struct {
// contains filtered or unexported fields
}
func NewUserQtsUpdatesDAO ¶
func NewUserQtsUpdatesDAO(db *sqlx.DB) *UserQtsUpdatesDAO
func (*UserQtsUpdatesDAO) Insert ¶
func (dao *UserQtsUpdatesDAO) Insert(ctx context.Context, do *dataobject.UserQtsUpdatesDO) (lastInsertId, rowsAffected int64, err error)
Insert insert into user_qts_updates(user_id, qts, update_type, update_data, date2) values (:user_id, :qts, :update_type, :update_data, :date2) TODO(@benqi): sqlmap
func (*UserQtsUpdatesDAO) InsertTx ¶
func (dao *UserQtsUpdatesDAO) InsertTx(tx *sqlx.Tx, do *dataobject.UserQtsUpdatesDO) (lastInsertId, rowsAffected int64, err error)
InsertTx insert into user_qts_updates(user_id, qts, update_type, update_data, date2) values (:user_id, :qts, :update_type, :update_data, :date2) TODO(@benqi): sqlmap
func (*UserQtsUpdatesDAO) SelectByGtQts ¶
func (dao *UserQtsUpdatesDAO) SelectByGtQts(ctx context.Context, user_id int64, qts int32) (rList []dataobject.UserQtsUpdatesDO, err error)
SelectByGtQts select user_id, qts, update_type, update_data, date2 from user_qts_updates where user_id = :user_id and qts > :qts order by qts asc TODO(@benqi): sqlmap
func (*UserQtsUpdatesDAO) SelectByGtQtsWithCB ¶
func (dao *UserQtsUpdatesDAO) SelectByGtQtsWithCB(ctx context.Context, user_id int64, qts int32, cb func(i int, v *dataobject.UserQtsUpdatesDO)) (rList []dataobject.UserQtsUpdatesDO, err error)
SelectByGtQtsWithCB select user_id, qts, update_type, update_data, date2 from user_qts_updates where user_id = :user_id and qts > :qts order by qts asc TODO(@benqi): sqlmap
func (*UserQtsUpdatesDAO) SelectLastQts ¶
func (dao *UserQtsUpdatesDAO) SelectLastQts(ctx context.Context, user_id int64) (rValue *dataobject.UserQtsUpdatesDO, err error)
SelectLastQts select qts from user_qts_updates where user_id = :user_id order by qts desc limit 1 TODO(@benqi): sqlmap