13

我刚刚开始尝试 Go，我希望用它重新实现一个用 node 编写的 API 服务器。

我在尝试使用依赖注入将数据库上下文作为 gin 中间件传递时遇到了障碍。到目前为止，我已将其设置为：

main.go：

package main

import (
        "fmt"
        "runtime"
        "log"
        "github.com/gin-gonic/gin"
        "votesforschools.com/api/public"
        "votesforschools.com/api/models"
)

type DB struct {
        models.DataStore
}

func main() {
        ConfigRuntime()
        ConfigServer()
}

func Database(connectionString string) gin.HandlerFunc {
        dbInstance, err := models.NewDB(connectionString)
        if err != nil {
                log.Panic(err)
        }

        db := &DB{dbInstance}

        return func(c *gin.Context) {
                c.Set("DB", db)
                c.Next()
        }
}


func ConfigRuntime() {
        nuCPU := runtime.NumCPU()
        runtime.GOMAXPROCS(nuCPU)
        fmt.Printf("Running with %d CPUs\n", nuCPU)
}

func ConfigServer() {

        gin.SetMode(gin.ReleaseMode)

        router := gin.New()
        router.Use(Database("<connectionstring>"))
        router.GET("/public/current-vote-pack", public.GetCurrentVotePack)
        router.Run(":1000")
}

模型/db.go

package models

import (
        "database/sql"
        _ "github.com/go-sql-driver/mysql"
)

type DataStore interface {
        GetVotePack(id string) (*VotePack, error)
}

type DB struct {
        *sql.DB
}

func NewDB(dataSource string) (*DB, error) {
        db, err := sql.Open("mysql", dataSource)
        if err != nil {
                return nil, err
        }
        if err = db.Ping(); err != nil {
                return nil, err
        }
        return &DB{db}, nil
}

模型/votepack.go

package models

import (
        "time"
        "database/sql"
)

type VotePack struct {
        id string
        question string
        description string
        startDate time.Time
        endDate time.Time
        thankYou string
        curriculum []string
}

func (db *DB) GetVotePack(id string) (*VotePack, error) {

        var votePack *VotePack

        err := db.QueryRow(
                "SELECT id, question, description, start_date AS startDate, end_date AS endDate, thank_you AS thankYou, curriculum WHERE id = ?", id).Scan(
                &votePack.id, &votePack.question, &votePack.description, &votePack.startDate, &votePack.endDate, &votePack.thankYou, &votePack.curriculum)

        switch {
        case err == sql.ErrNoRows:
                return nil, err
        case err != nil:
                return nil, err
         default:
                return votePack, nil
        }
}

因此，对于上述所有内容，我想将 models.DataSource 作为中间件传递，以便可以像这样访问它：

公共/public.go

package public

import (
        "github.com/gin-gonic/gin"
)

func GetCurrentVotePack(context *gin.Context) {
        db := context.Keys["DB"]

        votePack, err := db.GetVotePack("c5039ecd-e774-4c19-a2b9-600c2134784d")
        if err != nil{
                context.String(404, "Votepack Not Found")
        }
        context.JSON(200, votePack)
}

但是我得到public\public.go:10: db.GetVotePack undefined (type interface {} is interface with no methods)

当我在调试器中检查（使用带有插件的 Webstorm）时，数据库只是一个空对象。我正在努力做好并避免使用全局变量

4

4 回答 4

20

我认为不context应该用作 DI 容器：https ://golang.org/pkg/context/

包上下文定义了 Context 类型，它携带跨越 API 边界和进程之间的截止日期、取消信号和其他请求范围的值。

我宁愿使用：

package public

type PublicController struct {
        Database *DB
}

func (c *PublicController) GetCurrentVotePack(context *gin.Context) {
        votePack, err := c.Database.GetVotePack("c5039ecd-e774-4c19-a2b9-600c2134784d")
        if err != nil{
                context.String(404, "Votepack Not Found")
        }
        context.JSON(200, votePack)
}

并在 main 中配置您的控制器：

func main() {
        pCtrl := PublicController { Database: models.NewDB("<connectionstring>") }

        router := gin.New()
        router.GET("/public/current-vote-pack", pCtrl.GetCurrentVotePack)
        router.Run(":1000")
}
于 2020-02-20T16:37:37.353 回答
15

其中的值context.Keys都是 type interface{}，因此在 type转换回该类型之前db将无法从 type 调用方法。*DB

安全的方法：

db, ok := context.Keys["DB"].(*DB)
if !ok {
        //Handle case of no *DB instance
}
// db is now a *DB value

context.Keys["DB"]不太安全的方法，如果不是 type 的值，它会恐慌*DB：

db := context.Keys["DB"].(*DB)
// db is now a *DB value

Effective Go在这方面有一个部分。

于 2016-02-27T18:07:09.370 回答
1

您需要类型断言来将接口 (db := context.Keys["DB"]) 转换为有用的东西。例如看这篇文章：convert interface{} to int in Golang

于 2016-02-27T17:52:07.567 回答
0

在启动期间将 DB 设置为上下文时，还有另一种方法可以做到这一点。

 db := ctx.MustGet("DB").(*gorm.DB)

如果存在，MustGet 返回给定键的值，否则它会恐慌。

于 2021-02-16T12:07:51.913 回答