如何从Ballerina连接到MongoDB Atlas集群？

你的mongodb+srv://格式连接字符串是符合Ballerina MongoDB客户端要求的，问题出在代码的配置结构和操作调用上，以下是修正方案：

修正后的代码 #

import ballerinax/mongodb;
import ballerina/io;

configurable string app = ?;
configurable string pwd = ?;

// 移除多余的connection嵌套，直接将url放在客户端配置顶层
mongodb:Client mongoCli = check new ({
    url: string `mongodb+srv://${app}:${pwd}@fina-a-journey.ugfjnsm.mongodb.net/?retryWrites=true&w=majority`
});

public function main() {
    // insert方法需传入：文档对象、数据库名、集合名三个参数
    mongodb:Error? insertResult = mongoCli->insert({name: "Jhon", age: 16}, "your_database_name", "users");
    
    // 添加错误处理便于排查问题
    if insertResult is mongodb:Error {
        io:println("插入操作失败: ", insertResult.message());
    } else {
        io:println("数据插入成功");
    }
}

关键说明 #

• MongoDB Atlas提供的mongodb+srv://连接字符串完全兼容Ballerina MongoDB客户端，无需修改字符串格式。
• 客户端初始化时，配置对象直接包含url字段即可，不需要嵌套在connection子对象中。
• insert方法的参数顺序为：待插入的文档对象、目标数据库名称、目标集合名称，之前的代码缺少数据库名参数，会导致调用失败。
• 建议添加错误处理逻辑，方便定位连接或数据操作中的问题。

内容的提问来源于stack exchange，提问作者Malintha Ranasinghe