dao.go 482 B

123456789101112131415161718192021222324252627282930313233343536
  1. package dao
  2. import (
  3. "context"
  4. "go-common/app/admin/main/up-rating/conf"
  5. "go-common/library/database/sql"
  6. )
  7. // Dao dao
  8. type Dao struct {
  9. c *conf.Config
  10. db *sql.DB
  11. }
  12. // New fn
  13. func New(c *conf.Config) (d *Dao) {
  14. d = &Dao{
  15. c: c,
  16. db: sql.NewMySQL(c.DB.Rating),
  17. }
  18. return
  19. }
  20. // Ping ping health.
  21. func (d *Dao) Ping(c context.Context) (err error) {
  22. return d.db.Ping(c)
  23. }
  24. // Close close connections of db.
  25. func (d *Dao) Close() {
  26. if d.db != nil {
  27. d.db.Close()
  28. }
  29. }