mongodb - Mgo 插入命令不创建数据库或插入文档

Question

我的目标是实现这个 code .除了不使用 sql，我想使用 mongoDB。我认为我处理 session 的方式存在问题。

我正在尝试使用 mgo 通过 Rest API 将一些用户数据插入到 MongoDB 中。每当我打开 mongo shell 并运行 show dbs 命令时，都不会显示 poll DB。我正在使用 Postman 来测试 Rest API。任何想法我在插入过程中可能做错了什么？我尝试先在 mongo shell 中创建集合，然后运行 ​​CreateUser 函数，但我仍然没有看到创建了 poll DB。

用户

type User struct {
    Id bson.ObjectId `json:"id" bson:"_id,omitempty"`
    Username string `json:"username"`
    Password string  `json:"password"`
    Email string `json:"email"`
}

UserDAO

type UserDAO struct {
    session *mgo.Session
}

创建 session

func GetMongoSession() *mgo.Session {
    if mgoSession == nil {
        var err error
        mgoSession, err = mgo.Dial("localhost")
        mgoSession.SetMode(mgo.Monotonic, true)

        if err != nil {
            log.Fatal("Failed to start the Mongo session.")
        }
    }
    return mgoSession.Clone()
}

我将一个用户结构传递到我使用 Postman 创建的 CreateUser 函数中:

{
    "username":"uname",
    "password":"pass",
    "email":"test@mail.com"
}

然后我只用相同的结构响应并接收此输出:

{
    "id": "",
    "username": "uname",
    "password": "pass",
    "email": "test@mail.com"
}

创建用户

func (dao *UserDAO) CreateUser(u *User) (*User, error) {
    //return errors.New("Not implemented")

    // Get "users" collection

    dao.session = GetMongoSession()

    c := dao.session.DB("poll").C("user")

    defer dao.session.Close()

    //u.Id = bson.NewObjectId()
    err :=  c.Insert(u)

    if err != nil { 
        return nil, err
    }

    return u, nil
}

HTTP 处理函数

func (h *Handler) CreateUserReq(w http.ResponseWriter, r *http.Request) {

    // create new user using information from the Request object
    var user User
    decoder := json.NewDecoder(r.Body)

    if err := decoder.Decode(&user); err != nil {
        panic(err)
    }

    defer r.Body.Close()

    // Create new User
    u, err := h.UserService.CreateUser(&user)
    if err != nil {
        panic(err)
    }
    json.NewEncoder(w).Encode(*u)
}

显示数据库的输出

> show dbs
admin   0.000GB
config  0.000GB
local   0.000GB

Answer 1

因为我没有您的应用程序的完整上下文，所以无法诊断您的代码到底有什么问题。但我想出了一个接近的例子，它按预期工作。

请看下面的代码。

package main

import (
    "gopkg.in/mgo.v2"
    "log"
    "gopkg.in/mgo.v2/bson"
)

type User struct {
    Id       bson.ObjectId `json:"id" bson:"_id,omitempty"`
    Username string        `json:"username"`
    Password string        `json:"password"`
    Email    string        `json:"email"`
}

func GetMongoSession() *mgo.Session {

    mgoSession, err := mgo.Dial("localhost")
    mgoSession.SetMode(mgo.Monotonic, true)

    if err != nil {
        log.Fatal("Failed to start the Mongo session.")
    }

    return mgoSession.Clone()
}

func CreateUser(u *User) (*User, error) {

    session := GetMongoSession()

    c := session.DB("poll").C("user")
    defer session.Close()

    err := c.Insert(u)

    if err != nil {
        return nil, err
    }

    return u, nil
}

func main() {

    var user = User{
        Email:    "abc@somewhere.come",
        Password: "My-secret",
        Username: "YouGuess",
    }

    _, e := CreateUser(&user)
    if e != nil {
        panic(e)
    }

    log.Println("Done...")
}

一旦你执行它，你应该会在 MongoDB 中看到一个文档，前提是你使用正确的凭据成功建立了连接。

我可以在我的收藏中看到以下文档:

{
    "_id": ObjectId("5a80941de0a0f75123aeb435"),
    "username": "YouGuess",
    "password": "My-secret",
    "email": "abc@somewhere.come"
}