| 16 | } |
| 17 | |
| 18 | func InitMysqlConnPool() error { |
| 19 | var err error |
| 20 | var conn *sqlx.DB |
| 21 | conn, err = sqlx.Connect("mysql", fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8&parseTime=true&loc=Local", |
| 22 | GlobalConfig.MYSQL_USER, GlobalConfig.MYSQL_PASSWORD, GlobalConfig.MYSQL_ADDR, GlobalConfig.MYSQL_DBNAME)) |
| 23 | if err != nil { |
| 24 | return err |
| 25 | } |
| 26 | conn.SetMaxIdleConns(GlobalConfig.MYSQL_MAX_IDLE_CONN) |
| 27 | conn.SetMaxOpenConns(GlobalConfig.MYSQL_MAX_CONN) |
| 28 | mydb = &db{conn} |
| 29 | return nil |
| 30 | } |
| 31 | |
| 32 | func (this *db) GetProducts() []*types.Product { |
| 33 | products := []*types.Product{} |