同时操作部署在不同服务器的多种数据库

1.本项目骨架在单元测试已经提供了同时操作多服务器、多种数据库的示例代码,为了将此功能更清晰地展现出来，本篇将单独进行介绍.
2.面对复杂场景，需要多个客户端连接到部署在多个不同服务器的 mysql、sqlserver、postgresql 等数据库时, 由于配置文件（config/gorm_v2.yml）只提供了一份数据库连接，无法满足需求，这时您可以通过自定义参数直接连接任意数据库，获取一个数据库句柄，供业务使用.

相关代码

在线代码预览， 251 行处。

  2. func TestCustomeParamsConnMysql(t *testing.T) {
  3.     // 定义一个查询结果接受结构体
  4.     type DataList struct {
  5.         Id            int
  6.         Username      string
  7.         LastLoginIp string
  8.         Status        int
  9.     }
  10.     // 设置动态参数连接任意多个数据库，以mysql为例进行单元测试
  11.     // 参数结构体 Write 和 Read 只有设置了具体值，才会生效，否则程序自动使用配置目录（config/gorm_v2.yml）中的参数
  12.     confPrams := gorm_v2.ConfigParams{
  13.         Write: struct {
  14.             Host     string
  15.             DataBase string
  16.             Port     int
  17.             Prefix   string
  18.             User     string
  19.             Pass     string
  20.             Charset  string
  21.         }{Host: "127.0.0.1", DataBase: "db_test", Port: 3306, Prefix: "tb_", User: "root", Pass: "DRsXT5ZJ6Oi55LPQ", Charset: "utf8"},
  22.         Read: struct {
  23.             Host     string
  24.             DataBase string
  25.             Port     int
  26.             Prefix   string
  27.             User     string
  28.             Pass     string
  29.             Charset  string
  30.         }{Host: "127.0.0.1", DataBase: "db_stocks", Port: 3306, Prefix: "tb_", User: "root", Pass: "DRsXT5ZJ6Oi55LPQ", Charset: "utf8"}}
  32.     var vDataList []DataList
  34.     //gorm_v2.GetSqlDriver 参数介绍
  35.     // sqlType ： mysql 、sqlserver、postgresql 等数据库库类型
  36.     // readDbIsOpen ： 是否开启读写分离，1表示开启读数据库的配置，那么 confPrams.Read 参数部分才会生效； 0 则表示 confPrams.Read 部分参数直接忽略（即 读、写同库）
  37.     // confPrams 动态配置的数据库参数
  38.     // 此外，其他参数，例如数据库连接池参数等，则直接调用配置项数据库连接池参数，基本不需要配置，这部分对实际操作影响不大
  39.     if gormDbMysql, err := gorm_v2.GetSqlDriver("mysql", 0, confPrams); err == nil {
  40.         gormDbMysql.Raw("select id,username,status,last_login_ip from tb_users").Find(&vDataList)
  41.         fmt.Printf("Read 数据库查询结果：%v\n", vDataList)
  42.         res := gormDbMysql.Exec("update tb_users  set  real_name='Write数据库更新' where   id<=2 ")
  43.         if res.Error==nil{
  44.             fmt.Println("write 数据库更新成功")
  45.         }else{
  46.             t.Errorf("单元测试失败，相关错误：%s\n",res.Error.Error())
  47.         }
  48.     }
  49. }