在使用go-gin和mgo从MongoDB获取投票列表时出现错误。

huangapple go评论179阅读模式
英文:

Errors Getting list of polls from mongoDB with go-gin and mgo

问题

你好,以下是翻译好的内容:

嗨,我正在尝试使用Go语言的go-gin和mgo构建一个Web服务,我有一个带有MongoDB的数据库,但每次我尝试从数据库中获取投票时,我都会从Go Web服务器中获得以下错误。

我的代码如下:

package main

import (
    "fmt"
    "log"
    "net/http"
    "os"

    "gopkg.in/gin-gonic/gin.v1"
    "gopkg.in/mgo.v2"
)

type Poll struct {
    ID        string `json:"id,omitempty"`
    Firstname string `json:"firstname,omitempty"`
    Lastname  string `json:"lastname,omitempty"`
    Poll      string `json:"poll,omitempty"`
}

var (
    // Session stores mongo session
    Session *mgo.Session

    // Mongo stores the mongodb connection string information
    Mongo *mgo.DialInfo
)

const (
    // MongoDBUrl is the default mongodb url that will be used to connect to the
    // database.
    MongoDBUrl = "mongodb://localhost:27017/smartpoll"

    // CollectionPoll holds the name of the articles collection
    CollectionPoll = "polls"
)

// Connect connects to mongodb
func Connect() {
    uri := os.Getenv("MONGODB_URL")

    if len(uri) == 0 {
        uri = MongoDBUrl
    }

    mongo, err := mgo.ParseURL(uri)
    s, err := mgo.Dial(uri)
    if err != nil {
        fmt.Printf("Can't connect to mongo, go error %v\n", err)
        panic(err.Error())
    }
    s.SetSafe(&mgo.Safe{})
    fmt.Println("Connected to", uri)
    Session = s
    Mongo = mongo
}

func init() {
    Connect()
}

func main() {
    port := os.Getenv("PORT")

    if port == "" {
        log.Fatal("$PORT must be set")
    }

    router := gin.Default()

    router.GET("/", func(c *gin.Context) {
        c.JSON(http.StatusOK, gin.H{"message": "OK"})
    })

    router.GET("/polls", allPolls)
    router.Run(":" + port)
}

func allPolls(c *gin.Context) {
    db := c.MustGet("db").(*mgo.Database)
    polls := []Poll{}
    poll := db.C(CollectionPoll).Find(&polls)

    c.JSON(http.StatusOK, gin.H{
        "_id":       "ID",
        "firstname": "Firstname",
        "lastname":  "Lastname",
        "poll":      poll,
    })
}

我的数据库如下:

{
    "_id" : ObjectId("58d9cf1cdf353f3d2f5951b4"),
    "id" : "1",
    "firstname" : "Sam",
    "lastname" : "Smith",
    "poll" : "Who is the Richest Man in the World"
}

希望对你有帮助!

英文:

Hi trying to build a web service with go-gin and mgo on the Go language, i have a database with mongoDB but each time i try to GET polls from the database I get errors from the folowing errors from the Go webserver.

    2:00:16 PM web.1 |  	gopanic: reflectcall(nil, unsafe.Pointer(d.fn), deferArgs(d), uint32(d.siz), uint32(d.siz))
    2:00:16 PM web.1 |  /home/go/src/gopkg.in/gin-gonic/gin.v1/context.go:180 (0x4e1eb1)
    2:00:16 PM web.1 |  	(*Context).MustGet: panic("Key \"" + key + "\" does not exist")
    2:00:16 PM web.1 |  /home/go/src/smartpoll/main.go:139 (0x401655)
    2:00:16 PM web.1 |  	allPolls: db := c.MustGet("db").(*mgo.Database)
    2:00:16 PM web.1 |  /home/go/src/gopkg.in/gin-gonic/gin.v1/context.go:97 (0x4e187a)
    2:00:16 PM web.1 |  	(*Context).Next: c.handlers[c.index](c)
    2:00:16 PM web.1 |  /home/go/src/gopkg.in/gin-gonic/gin.v1/recovery.go:45 (0x4f165a)
    2:00:16 PM web.1 |  	RecoveryWithWriter.func1: c.Next()
    2:00:16 PM web.1 |  /home/go/src/gopkg.in/gin-gonic/gin.v1/context.go:97 (0x4e187a)
    2:00:16 PM web.1 |  	(*Context).Next: c.handlers[c.index](c)
    2:00:16 PM web.1 |  /home/go/src/gopkg.in/gin-gonic/gin.v1/logger.go:72 (0x4f074f)
    2:00:16 PM web.1 |  	LoggerWithWriter.func1: c.Next()
    2:00:16 PM web.1 |  /home/go/src/gopkg.in/gin-gonic/gin.v1/context.go:97 (0x4e187a)
    2:00:16 PM web.1 |  	(*Context).Next: c.handlers[c.index](c)
    2:00:16 PM web.1 |  /home/go/src/gopkg.in/gin-gonic/gin.v1/gin.go:284 (0x4e7c0e)
    2:00:16 PM web.1 |  	(*Engine).handleHTTPRequest: context.Next()
    2:00:16 PM web.1 |  /home/go/src/gopkg.in/gin-gonic/gin.v1/gin.go:265 (0x4e74f0)
    2:00:16 PM web.1 |  	(*Engine).ServeHTTP: engine.handleHTTPRequest(c)
    2:00:16 PM web.1 |  /home/kebe/golang/go/src/net/http/server.go:2202 (0x4b249d)
    2:00:16 PM web.1 |  	serverHandler.ServeHTTP: handler.ServeHTTP(rw, req)
    2:00:16 PM web.1 |  /home/kebe/golang/go/src/net/http/server.go:1579 (0x4aee07)
    2:00:16 PM web.1 |  	(*conn).serve: serverHandler{c.server}.ServeHTTP(w, w.req)
    2:00:16 PM web.1 |  /home/kebe/golang/go/src/runtime/asm_amd64.s:2086 (0x45a081)
    2:00:16 PM web.1 |  	goexit: BYTE	$0x90	// NOP
    2:00:16 PM web.1 |  
    2:00:16 PM web.1 |  [GIN] 2017/06/20 - 14:00:16 | 500 |  753.521212ms | 127.0.0.1 |   GET     /polls

My Code is as follows

package main

import (
	
	"fmt"
	"log"
	"net/http"  
	"os"

	"gopkg.in/gin-gonic/gin.v1"
	"gopkg.in/mgo.v2"

)

type Poll struct {
	ID        string `json:"id,omitempty"`
	Firstname string `json:"firstname,omitempty"`
	Lastname  string `json:"lastname,omitempty"`
	Poll      string `json:"poll,omitempty"`

}

var (
	// Session stores mongo session
	Session *mgo.Session

	// Mongo stores the mongodb connection string information
	Mongo *mgo.DialInfo
)

const (
	// MongoDBUrl is the default mongodb url that will be used to connect to the
	// database.
	MongoDBUrl = "mongodb://localhost:27017/smartpoll"

		// CollectionPoll holds the name of the articles collection
	CollectionPoll = "polls"
)

// Connect connects to mongodb
func Connect() {
	uri := os.Getenv("MONGODB_URL")

	if len(uri) == 0 {
		uri = MongoDBUrl
	}

	mongo, err := mgo.ParseURL(uri)
	s, err := mgo.Dial(uri)
	if err != nil {
		fmt.Printf("Can't connect to mongo, go error %v\n", err)
		panic(err.Error())
	}
	s.SetSafe(&mgo.Safe{})
	fmt.Println("Connected to", uri)
	Session = s
	Mongo = mongo
}


func init() {
	Connect()
}

func main() {
	port := os.Getenv("PORT")

	if port == "" {
		log.Fatal("$PORT must be set")
	}



	router := gin.Default()

	router.GET("/", func (c *gin.Context) {
		c.JSON(http.StatusOK, gin.H{"message": "OK"})
		
	})
	router.GET("/polls", allPolls)
	router.Run(":" + port)
}



func allPolls(c *gin.Context) {
	db := c.MustGet("db").(*mgo.Database)
	polls := []Poll{}
	poll := db.C(CollectionPoll).Find(&polls)

	c.JSON(http.StatusOK, gin.H{

		"_id": "ID",
		"firstname": "Firstname",
		"lastname": "Lastname",
		"poll": poll,
		})
}

My DB is as follows:

/* 0 */
{
    "_id" : ObjectId("58d9cf1cdf353f3d2f5951b4"),
    "id" : "1",
    "firstname" : "Sam",
    "lastname" : "Smith",
    "poll" : "Who is the Richest Man in the World"
}

答案1

得分: 1

要从gin上下文(c)中获取数据库对象(db) c.MustGet("db").(*mgo.Database),你首先需要使用gin中间件函数进行设置。

func ConnectMiddleware(c *gin.Context) {
    c.Set("db", Session.DB(Mongo.Database))
    c.Next()
}

然后通过以下代码使用这个中间件:

router := gin.Default()
router.Use(ConnectMiddleware)
router.GET("/", func(c *gin.Context) {
    c.JSON(http.StatusOK, gin.H{"message": "OK"})
})
router.GET("/polls", allPolls)

你正在使用一个过时的gin库版本,其他部分的代码都没问题。

导入最新的github.com/gin-gonic/gin包。

使用以下代码从数据库获取数据:

func allPolls(c *gin.Context) {
    db := c.MustGet("db").(*mgo.Database)
    polls := []Poll{}
    err := db.C(CollectionPoll).Find(nil).All(&polls)
    if err != nil {
        c.Error(err)
    }
    result := gin.H{"payload": polls}
    c.Writer.Header().Set("Content-Type", "application/json")
    c.JSON(200, result)
}
英文:

To get the database object (db) from the gin context (c) c.MustGet("db").(*mgo.Database) you have to first set it using a gin middleware function

func ConnectMiddleware(c *gin.Context) {
    c.Set("db", Session.DB(Mongo.Database))
    c.Next()
}

and then use this middleware through the following code

router := gin.Default()
router.Use(ConnectMiddleware)
router.GET("/", func(c *gin.Context) {
	c.JSON(http.StatusOK, gin.H{"message": "OK"})

})
router.GET("/polls", allPolls)

You are using a outdated version of gin library other things are fine in your code

import the latest package form github.com/gin-gonic/gin

Use this to get the data from the database

func allPolls(c *gin.Context) {
    db := c.MustGet("db").(*mgo.Database)
    polls := []Poll{}
    err := db.C(CollectionPoll).Find(nil).All(&polls)
    if err != nil {
	    c.Error(err)
    }
    result := gin.H{"payload": polls}
    c.Writer.Header().Set("Content-Type", "application/json")
    c.JSON(200, result)
}

答案2

得分: 0

在你的请求中没有名为"db"的变量。

当你执行c.MustGet("db")时,你确保有一个名为"db"的参数,但实际上并没有提供。

Gin代码会引发错误

你需要在请求中传递"name"参数。

更好的解决方案是:如果参数不存在,则返回HTTP错误400 Bad Request。

英文:

There is no variable named "db" in your request.

When you're executing c.MustGet("db") you're assure that there is a param with this name, but it isn't presented.

Gin code which panics

You need to pass "db" name in to your request.

Better solution: if it's not present return HTTP error 400 Bad request.

huangapple
  • 本文由 发表于 2017年6月20日 21:10:28
  • 转载请务必保留本文链接:https://go.coder-hub.com/44654020.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定