dao

Documentation

Index

• type Dao
  • func New(c *conf.Config) (dao *Dao)
  • func (d *Dao) AddSnsLog(c context.Context, a *model.SnsLog) (affected int64, err error)
  • func (d *Dao) AddSnsUser(c context.Context, mid, expires int64, unionID string, platform int) (affected int64, err error)
  • func (d *Dao) AsoAccountSns(c context.Context, start int64) (res []*model.AsoAccountSns, err error)
  • func (d *Dao) AsoAccountSnsAll(c context.Context, start int64) (res []*model.AsoAccountSns, err error)
  • func (d *Dao) BeginSnsTran(c context.Context) (tx *sql.Tx, err error)
  • func (d *Dao) Close() (err error)
  • func (d *Dao) DelSnsCache(c context.Context, mid int64, platform string) (err error)
  • func (d *Dao) DelSnsUser(c context.Context, mid int64, platform int) (affected int64, err error)
  • func (d *Dao) GetUnionIDCache(c context.Context, key string) (v string, err error)
  • func (d *Dao) Ping(c context.Context) error
  • func (d *Dao) QQUnionID(c context.Context, openID string) (unionID string, err error)
  • func (d *Dao) SetSnsCache(c context.Context, mid int64, platform string, sns *model.SnsProto) (err error)
  • func (d *Dao) SnsUserByMid(c context.Context, mid int64, platform int) (res *model.SnsUser, err error)
  • func (d *Dao) SnsUserByUnionID(c context.Context, unionID string, platform int) (res *model.SnsUser, err error)
  • func (d *Dao) TxAddSnsOpenID(tx *xsql.Tx, a *model.SnsOpenID) (affected int64, err error)
  • func (d *Dao) TxAddSnsToken(tx *xsql.Tx, a *model.SnsToken) (affected int64, err error)
  • func (d *Dao) TxAddSnsUser(tx *xsql.Tx, a *model.SnsUser) (affected int64, err error)
  • func (d *Dao) TxUpdateSnsToken(tx *xsql.Tx, a *model.SnsToken) (affected int64, err error)
  • func (d *Dao) TxUpdateSnsUser(tx *xsql.Tx, mid, expires int64, unionID string, platform int) (affected int64, err error)
  • func (d *Dao) TxUpdateSnsUserExpires(tx *xsql.Tx, a *model.SnsUser) (affected int64, err error)
  • func (d *Dao) UpdateSnsToken(c context.Context, a *model.SnsToken) (affected int64, err error)
  • func (d *Dao) UpdateSnsUser(c context.Context, mid, expires int64, unionID string, platform int) (affected int64, err error)

Types

type Dao

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

Dao dao

func New

func New(c *conf.Config) (dao *Dao)

New init mysql db

func (*Dao) AddSnsLog

func (d *Dao) AddSnsLog(c context.Context, a *model.SnsLog) (affected int64, err error)

AddSnsLog add sns log.

func (*Dao) AddSnsUser

func (d *Dao) AddSnsUser(c context.Context, mid, expires int64, unionID string, platform int) (affected int64, err error)

AddSnsUser add sns user.

func (*Dao) AsoAccountSns

func (d *Dao) AsoAccountSns(c context.Context, start int64) (res []*model.AsoAccountSns, err error)

AsoAccountSns get account sns by id.

func (*Dao) AsoAccountSnsAll

func (d *Dao) AsoAccountSnsAll(c context.Context, start int64) (res []*model.AsoAccountSns, err error)

AsoAccountSnsAll get account sns

func (*Dao) BeginSnsTran

func (d *Dao) BeginSnsTran(c context.Context) (tx *sql.Tx, err error)

BeginSnsTran begin sns transcation.

func (*Dao) Close

func (d *Dao) Close() (err error)

Close close the resource.

func (*Dao) DelSnsCache

func (d *Dao) DelSnsCache(c context.Context, mid int64, platform string) (err error)

DelSnsCache del sns cache

func (*Dao) DelSnsUser

func (d *Dao) DelSnsUser(c context.Context, mid int64, platform int) (affected int64, err error)

DelSnsUser del sns user.

func (*Dao) GetUnionIDCache

func (d *Dao) GetUnionIDCache(c context.Context, key string) (v string, err error)

GetUnionIDCache .

func (*Dao) Ping

func (d *Dao) Ping(c context.Context) error

Ping dao ping

func (*Dao) QQUnionID

func (d *Dao) QQUnionID(c context.Context, openID string) (unionID string, err error)

QQUnionID .

func (*Dao) SetSnsCache

func (d *Dao) SetSnsCache(c context.Context, mid int64, platform string, sns *model.SnsProto) (err error)

SetSnsCache set sns to cache

func (*Dao) SnsUserByMid

func (d *Dao) SnsUserByMid(c context.Context, mid int64, platform int) (res *model.SnsUser, err error)

SnsUserByMid get sns user by mid and platform

func (*Dao) SnsUserByUnionID

func (d *Dao) SnsUserByUnionID(c context.Context, unionID string, platform int) (res *model.SnsUser, err error)

SnsUserByUnionID get sns user by unionID and platform

func (*Dao) TxAddSnsOpenID

func (d *Dao) TxAddSnsOpenID(tx *xsql.Tx, a *model.SnsOpenID) (affected int64, err error)

TxAddSnsOpenID add sns openid.

func (*Dao) TxAddSnsToken

func (d *Dao) TxAddSnsToken(tx *xsql.Tx, a *model.SnsToken) (affected int64, err error)

TxAddSnsToken add sns token.

func (*Dao) TxAddSnsUser

func (d *Dao) TxAddSnsUser(tx *xsql.Tx, a *model.SnsUser) (affected int64, err error)

TxAddSnsUser add sns user.

func (*Dao) TxUpdateSnsToken

func (d *Dao) TxUpdateSnsToken(tx *xsql.Tx, a *model.SnsToken) (affected int64, err error)

TxUpdateSnsToken update sns token.

func (*Dao) TxUpdateSnsUser

func (d *Dao) TxUpdateSnsUser(tx *xsql.Tx, mid, expires int64, unionID string, platform int) (affected int64, err error)

TxUpdateSnsUser update sns user.

func (*Dao) TxUpdateSnsUserExpires

func (d *Dao) TxUpdateSnsUserExpires(tx *xsql.Tx, a *model.SnsUser) (affected int64, err error)

TxUpdateSnsUserExpires update sns user expires.

func (*Dao) UpdateSnsToken

func (d *Dao) UpdateSnsToken(c context.Context, a *model.SnsToken) (affected int64, err error)

UpdateSnsToken update sns token.

func (*Dao) UpdateSnsUser

func (d *Dao) UpdateSnsUser(c context.Context, mid, expires int64, unionID string, platform int) (affected int64, err error)

UpdateSnsUser update sns user.