使用 Go 编程语言的 MongoDB 驱动程序将用户插入到 MongoDB 数据库

本篇文章主要是结合我之前面试的各种经历和实战开发中遇到的问题解决经验整理的，希望这篇《使用 Go 编程语言的 MongoDB 驱动程序将用户插入到 MongoDB 数据库》对你有很大帮助！欢迎收藏，分享给更多的需要的朋友学习~

我想向 mongodb 添加一个 mongo 用户。我尝试了以下方法：

import (
    "context"
    "fmt"
    "go.mongodb.org/mongo-driver/bson"
    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
    "log"
    "os"
    "time"
)
type user struct {
    user  string `json:"user"`
    db    string `json:"db"`
    roles []role`json:"roles"`
    passworddigestor string `json:"passworddigestor"`
    pwd string `json:"pwd"`
}

type role struct {
    role string `json:"role"`
    db   string `json:"db"`
}
func createuser() {
    client, err := mongo.newclient(options.client().applyuri(fmt.sprintf("mongodb://%s:%s@%s/test?authsource=%s&replicaset=%s",
        mongoconf.user,mongoconf.password,mongoconf.host,mongoconf.authdb,mongoconf.replicaset)))
    if err != nil {
        log.fatal(err)
    }
    ctx, _ := context.withtimeout(context.background(), 10*time.second)
    err = client.connect(ctx)
    if err != nil {
        log.fatal(err)
    }
    defer client.disconnect(ctx)

    //pass :=  password(8)
    pass := "test123!"
    if _, err = client.database("admin").collection("system.users").insertone(context.background(),user{
        user: "test",
        db:   "admin",
        roles: []role{
            {role: "readwriteanydatabase",
                db: "admin",
            },
        },
        passworddigestor: "server",
        pwd:              pass,
    }); err != nil {
        panic(err)
    }

}

但这不起作用。对于 shell，db.createuser() 不是问题。但我应该如何用 go 做到这一点呢？我能够列出 system.users 表中的所有用户。当我将这样的用户插入数据库时​​，它可以正常工作，但无法使用创建的用户登录。

编辑： runnint db.createuser：

function (userObj, writeConcern) {
        var name = userObj["user"];
        var cmdObj = {createUser: name};
        cmdObj = Object.extend(cmdObj, userObj);
        delete cmdObj["user"];

        this._modifyCommandToDigestPasswordIfNecessary(cmdObj, name);

        cmdObj["writeConcern"] = writeConcern ? writeConcern : _defaultWriteConcern;

        var res = this.runCommand(cmdObj);

        if (res.ok) {
            print("Successfully added user: " + getUserObjString(userObj));
            return;
        }

        if (res.errmsg == "no such cmd: createUser") {
            throw Error("'createUser' command not found.  This is most likely because you are " +
                        "talking to an old (pre v2.6) MongoDB server");
        }

        if (res.errmsg == "timeout") {
            throw Error("timed out while waiting for user authentication to replicate - " +
                        "database will not be fully secured until replication finishes");
        }

        throw _getErrorWithCode(res, "couldn't add user: " + res.errmsg);
    }

解决方案

感谢@joe，我可以解决运行以下命令的问题：

r := client.Database(dbName).RunCommand(context.Background(),bson.D{{"createUser", userName},
    {"pwd", pass}, {"roles", []bson.M{{"role": roleName,"db":roldeDB}}}})
if r.Err() != nil {
    panic(r.Err())
}

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。