连接数据库

前提条件

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，需要在界面上下载根证书，并上传到弹性云服务器。

连接代码

• 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关闭

  // 高可用连接 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)
  }