# Go示例
#### 操作场景
DDS支持通过Go语言接口来操作数据，通过Go连接实例的方式有开启SSL认证连接和关闭SSL认证连接两种，其中开启SSL证书连接加密功能，具有更高的安全性。
DDS新实例默认关闭SSL数据加密，开启SSL请参考[开启SSL](https://support.huaweicloud.com/usermanual-dds/dds_03_0074.html#section1)。
本章节主要介绍使用Go语言连接副本集实例的方法。
#### 前提条件
1. 连接数据库的弹性云服务器必须和DDS实例之间网络互通，可以使用curl命令连接DDS实例服务端的IP和端口号，测试网络连通性。 curl ip:port
   返回"It looks like you are trying to access MongoDB over HTTP on the native driver port."，说明网络互通。
   
2. 如果开启SSL，需要在界面上下载根证书，并上传到弹性云服务器。
 
#### 环境配置及驱动获取
使用 Go Modules 添加 MongoDB 官方驱动，步骤如下：
1. 初始化模块（如尚未创建 go.mod）
   ```
   go mod init <项目模块名>
   ```
   
2. 安装驱动 推荐使用 go get 直接获取指定版本，命令会自动更新 go.mod 与 go.sum：
   ```
   go get go.mongodb.org/mongo-driver@v1.12.1
   ```
   若需手动声明依赖，可在 go.mod 中添加：
   ```
   require go.mongodb.org/mongo-driver v1.12.1
   ```
   之后执行 go mod tidy 完成下载。
   
3. 在 Go 代码中导入包
   ```
   import (
   "go.mongodb.org/mongo-driver/bson"    
   "go.mongodb.org/mongo-driver/mongo"    
   "go.mongodb.org/mongo-driver/mongo/options"    
   "go.mongodb.org/mongo-driver/mongo/readpref" 
   )
   ```
   
 
#### 开启和关闭SSL安全连接
- [SSL关闭]
  ```
  // 高可用连接 readPreference 取值 primary(默认)-只读主节点，primaryPreferred-主节点优先，如主节点不可用，则读从节点
  // secondary-只读从节点，如从节点不可用会报错,secondaryPreferred-从节点优先，如从节点不可用，则读主节点
  // 认证用的用户名和密码直接写到代码中有很大的安全风险，建议在配置文件或者环境变量中存放(密码应密文存放、使用时解密)，确保安全；
  // 本示例以用户名和密码保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量(环境变量名称请根据自身情况进行设置)EXAMPLE_USERNAME_ENV和EXAMPLE_PASSWORD_ENV。
  username = System.getenv("EXAMPLE_USERNAME_ENV")
  password = System.getenv("EXAMPLE_PASSWORD_ENV")
  highProxyUri := fmt.Sprintf("mongodb://%v:%v@host1:8635,host2:8635/?authSource=admin&replicaSet=replica&readPreference=secondaryPreferred",username,password)
  ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
  defer cancel()
  clientOpts := options.Client().ApplyURI(highProxyUri)
  client, err := mongo.Connect(ctx, clientOpts)
  // Ping 主节点
  ctx, cancel = context.WithTimeout(context.Background(), 2*time.Second)
  defer cancel()err = client.Ping(ctx, readpref.Primary())
  if err != nil {
     fmt.Println("ping 主节点失败：",err)
     return
  }
  // 选择数据库和集合
  collection := client.Database("test").Collection("numbers")
  // 插入单条数据
  ctx, cancel = context.WithTimeout(context.Background(), 5*time.Second)
  defer cancel()
  res, err := collection.InsertOne(ctx, bson.D{{"name", "e"}, {"value", 2.718}})
  if err != nil{
     fmt.Println("插入单条记录失败：",err)
     return
  }else {
     fmt.Println(res)
  }
  ```
- [SSL 开启]
  ```
  // 构建认证凭证
  // 认证用的用户名和密码直接写到代码中有很大的安全风险，建议在配置文件或者环境变量中存放(密码应密文存放、使用时解密)，确保安全；
  // 本示例以用户名和密码保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量(环境变量名称请根据自身情况进行设置)EXAMPLE_USERNAME_ENV和EXAMPLE_PASSWORD_ENV。
  username = System.getenv("EXAMPLE_USERNAME_ENV")
  password = System.getenv("EXAMPLE_PASSWORD_ENV")
  credential := options.Credential{
    AuthMechanism: "SCRAM-SHA-1",
    AuthSource:    "admin",
    Username:      username,
    Password:      password,
  }
  // 高可用 URI, 注意 SetDirect 设为 false
  highProxyUri := "mongodb://host1:8635,host2:8635/?ssl=true"
  clientOpts := options.Client().ApplyURI(highProxyUri)
  clientOpts = clientOpts.SetTLSConfig(&tls.Config {
  InsecureSkipVerify: true,
  }).SetDirect(false).SetAuth(credential)
  // 直连的 URI，注意 SetDirect 设为 true
  //directUri := "mongodb://host:8635/?ssl=true"
  //clientOpts := options.Client().ApplyURI(highProxyUri)
  //clientOpts = clientOpts.SetTLSConfig(&tls.Config {
  // InsecureSkipVerify: true,
  //}).SetDirect(true).SetAuth(credential)
  // 连接实例
  ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
  defer cancel()
  client, err := mongo.Connect(ctx, clientOpts)
  if err != nil {
     fmt.Println("mongo实例连接失败：", err)
     return
  }
  // Ping 主节点
  ctx, cancel = context.WithTimeout(context.Background(), 2*time.Second)
  defer cancel()err = client.Ping(ctx, readpref.Primary())
  if err != nil {fmt.Println("ping 主节点失败：",err)
     return
  }
  // 选择数据库和集合
  collection := client.Database("test").Collection("numbers")
  // 插入单条数据
  ctx, cancel = context.WithTimeout(context.Background(), 5*time.Second)
  defer cancel()
  oneRes, err := collection.InsertOne(ctx, bson.D{{"name", "e"}, {"value", 2.718}})
  if err != nil{fmt.Println("插入单条记录失败：",err)
     return
  }else {
     fmt.Println(oneRes)
  }
  // 批量插入
  ctx, cancel = context.WithTimeout(context.Background(), 100*time.Second)
  defer cancel()
  docs := make([]interface{}, 100)
  for i := 0; i < 100; i++{
     docs[i] = bson.D{{"name", "name"+strconv.Itoa(i)}, {"value", i}}
  }
  manyRes, err := collection.InsertMany(ctx, docs)
  if err != nil {
     fmt.Println("批量插入失败：",err)
     return
  }else {
     fmt.Println(manyRes)
  }
  ```
#### 相关文档
[设置SSL数据加密](https://support.huaweicloud.com/usermanual-dds/dds_03_0074.html)
[通过程序代码连接副本集实例](https://support.huaweicloud.com/usermanual-dds/dds_03_0339.html)