Browse Source

Merge pull request '创建数据库engine后,进行连接测试,测试不通过返回错误' (#56) from feature_db into develop

Reviewed-on: http://101.201.121.115:3000/leo/LAPP_GAAS_GFrame_BACKEND/pulls/56
Reviewed-by: weichenglei <chenglei.wei@le-it.com.cn>
pull/58/head
weichenglei 3 years ago
parent
commit
a75c5083ef
1 changed files with 13 additions and 0 deletions
  1. +13
    -0
      db/db.go

+ 13
- 0
db/db.go View File

@ -46,6 +46,9 @@ func InitDb() error {
fmt.Printf("err1 is %v", err)
return err
}
if err = master.Ping(); err != nil {
return err
}
case "mysql":
driveSource := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?charset=utf8",
v.User, v.Pwd, v.Host, v.Port, v.DbName)
@ -54,6 +57,10 @@ func InitDb() error {
fmt.Printf("err2 is %v", err)
return err
}
if err = master.Ping(); err != nil {
return err
}
}
} else {
switch v.DriverName {
@ -66,6 +73,9 @@ func InitDb() error {
fmt.Printf("err1 is %v", err)
return err
}
if err = slave.Ping(); err != nil {
return err
}
slaves = append(slaves, slave)
case "mysql":
driveSource := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?charset=utf8",
@ -75,6 +85,9 @@ func InitDb() error {
fmt.Printf("err2 is %v", err)
return err
}
if err = slave.Ping(); err != nil {
return err
}
slaves = append(slaves, slave)
}
}


Loading…
Cancel
Save