1234567891011121314151617181920212223242526272829303132333435363738394041424344454647 |
- package dao
- import (
- "context"
- "time"
- "go-common/app/service/main/passport-auth/conf"
- "go-common/library/cache/memcache"
- "go-common/library/database/sql"
- )
- // Dao dao struct
- type Dao struct {
- db *sql.DB
- mc *memcache.Pool
- mcExpire int32
- c *conf.Config
- }
- // New create new dao
- func New(c *conf.Config) (d *Dao) {
- d = &Dao{
- c: c,
- db: sql.NewMySQL(c.Mysql),
- mc: memcache.NewPool(c.Memcache.Config),
- mcExpire: int32(time.Duration(c.Memcache.Expire) / time.Second),
- }
- return
- }
- // Ping check db and mc health.
- func (d *Dao) Ping(c context.Context) (err error) {
- if err = d.db.Ping(c); err != nil {
- return
- }
- return d.pingMC(c)
- }
- // Close close connections of mc, redis, db.
- func (d *Dao) Close() {
- if d.mc != nil {
- d.mc.Close()
- }
- if d.db != nil {
- d.db.Close()
- }
- }
|