创建go版本下database/sql包sql.DB数据源，进行mysql操作。

1. 在go.mod文件中引入依赖，即引入MAS-GO-SDK。

   github.com/huaweicloud/devcloud-go

   

2. 结合配置项说明，添加配置文件或者配置信息。
   • 配置文件示例config_mysql.yaml。

     props:  version: v1  appId: xxx  monitorId: xxxx  databaseName: xxxxetcd:  address: xxx.xxx.xxx.xxx:xxxx  apiVersion: v3  username: xxxx  password: xxxx  httpsEnable: false# requiredatasource:  ds0:    url: tcp(xxx.xxx.xxx.xxx:xxxx)/ds0    username: xxxx    password: xxxx  ds0-slave0:    url: tcp(xxx.xxx.xxx.xxx:xxxx)/ds0-slave0    username: xxxx    password: xxxx  ds0-slave1:    url: tcp(xxx.xxx.xxx.xxx:xxxx)/ds0-slave1    username: xxxx    password: xxxx  ds1:    url: tcp(xxx.xxx.xxx.xxx:xxxx)/ds1    username: xxxx    password: xxxx  ds1-slave0:    url: tcp(xxx.xxx.xxx.xxx:xxxx)/ds1-slave0    username: xxxx    password: xxxx  ds1-slave1:    url: tcp(xxx.xxx.xxx.xxx:xxxx)/ds1-slave1    username: xxxx    password: xxxx# requirerouter:  active: c0  routeAlgorithm: single-read-write  retry:    times: 10    delay: 50# ms  nodes:    c0:      master: ds0      loadBalance: RANDOM      slaves:        - ds0-slave0        - ds0-slave1    c1:      master: ds1      loadBalance: ROUND_ROBIN      slaves:        - ds1-slave0        - ds1-slave1

   • 配置信息。

     func mysqlConfiguration() *config.ClusterConfiguration {    return &config.ClusterConfiguration{        Props: &mas.PropertiesConfiguration{            Version: "v1",            AppID: "xxx",            MonitorID: "xxxx",            DatabaseName: "xxx",        },        EtcdConfig: &etcd.EtcdConfiguration{            Address: "xxx.xxx.xxx.xxx:xxxx",            APIVersion: "v3",            Username: "xxxx",            Password: "xxxx",            HTTPSEnable: false,        },        RouterConfig: &config.RouterConfiguration{            Nodes: map[string]*config.NodeConfiguration{              "dc0": {                    Master: "ds0",                    LoadBalance: "RANDOM",                    Slaves: []string{"ds0-slave0","ds0-slave1"},                },            "dc1": {                    Master: "ds1",                    LoadBalance: "ROUND_ROBIN",                    Slaves: []string{"ds1-slave0","ds1-slave1"},                },            },            Active: "dc0",            Retry: &config.RetryConfiguration{                Times: "10",                Delay: "50",            },            RouteAlgorithm: "single-read-write",        },        DataSource: map[string]*config.DataSourceConfiguration{            "ds0": {                URL:      "tcp(xxx.xxx.xxx.xxx:xxxx)/ds0",                Username: "xxxx",                Password: "xxxx",            },            "ds0-slave0": {                URL:      "tcp(xxx.xxx.xxx.xxx:xxxx)/ds0-slave0",                Username: "xxxx",                Password: "xxxx",            },            "ds0-slave1": {                URL:      "tcp(xxx.xxx.xxx.xxx:xxxx)/ds0-slave1",                Username: "xxxx",                Password: "xxxx",            },            "ds1": {                URL:      "tcp(xxx.xxx.xxx.xxx:xxxx)/ds1",                Username: "xxxx",                Password: "xxxx",            },            "ds1-slave0": {                URL:      "tcp(xxx.xxx.xxx.xxx:xxxx)/ds1-slave0",                Username: "xxxx",                Password: "xxxx",            },            "ds1-slave1": {                URL:      "tcp(xxx.xxx.xxx.xxx:xxxx)/ds1-slave1",                Username: "xxxx",                Password: "xxxx",            },        },    }}

3. 初始化创建sql.DB数据源DevSporeDb。
   • 配置文件方式创建

     import (    "database/sql"    "log"    _ "github.com/huaweicloud/devcloud-go/sql-driver/mysql")var (    DevSporeDb *sql.DB    err error)func init() {    DevSporeDb, err = sql.Open("devspore_mysql", "./conf/resources/config_mysql.yaml")    if err != nil {        log.Fatalln(err)    }}

   • 配置信息方式创建。

     import (    "database/sql"    "log"    devspore "github.com/huaweicloud/devcloud-go/sql-driver/mysql")var (    DevSporeDb *sql.DB    err error)func init() {    devspore.SetClusterConfiguration(mysqlConfiguration())    DevSporeDb, err = sql.Open("devspore_mysql", "")    if err != nil {        log.Fatalln(err)    }}

4. 在需要执行Mysql操作的地方使用DevSporeDb执行Mysql操作，具体执行因业务各异，执行对应的sql.DB命令。