func OpenDB(mysql_conf string) *sql.DB {
db, err := sql.Open("mysql", mysql_conf) // user:password@tcp(127.0.0.1:3306)/dbname
if err != nil {
beego.Error("open mysql fail:", err)
return nil
}
db.SetConnMaxLifetime(time.Minute * 3)
db.SetMaxOpenConns(10)
db.SetMaxIdleConns(10)
return db
}
func CreateTable(DB *sql.DB) error {
sql := `CREATE TABLE IF NOT EXISTS test_table(
id INT UNSIGNED AUTO_INCREMENT,
conf_key VARCHAR(256) NOT NULL,
conf_value TEXT(65536) NOT NULL,
misc VARCHAR(512),
PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;`
if _, err := DB.Exec(sql); err != nil {
beego.Error("create table failed:", err)
return err
}
beego.Notice("create table successed")
return nil
}
