1234567891011121314151617181920212223242526272829303132333435363738394041 |
- package main
- import (
- "flag"
- "fmt"
- "log"
- "app.yhyue.com/moapp/jybase/common"
- "app.yhyue.com/moapp/jybase/mysql"
- "github.com/robfig/cron"
- )
- var (
- cfg = new(Config)
- TiDb *mysql.Mysql
- mode = flag.Int("m", 1, "")
- )
- func main() {
- flag.Parse()
- common.ReadConfig(&cfg)
- log.Println("cfg ", cfg)
- TiDb = &mysql.Mysql{
- Address: cfg.TiDb.Host + ":" + fmt.Sprint(cfg.TiDb.Port),
- UserName: cfg.TiDb.User,
- PassWord: cfg.TiDb.Password,
- DBName: cfg.TiDb.Database,
- MaxOpenConns: cfg.TiDb.PollSize,
- MaxIdleConns: cfg.TiDb.MaxIdle,
- }
- TiDb.Init()
- if *mode == 1 {
- job()
- a := cron.New()
- a.AddFunc(cfg.CornExp1, func() {
- job()
- })
- a.Start()
- select {}
- }
- }
|