在Golang和Fiber中，使用database/sql和“github.com/lib/pq”作为PostgreSQL驱动程序进行查询的指南

知识点掌握了，还需要不断练习才能熟练运用。下面golang学习网给大家带来一个Golang开发实战，手把手教大家学习《在Golang和Fiber中，使用database/sql和“github.com/lib/pq”作为PostgreSQL驱动程序进行查询的指南》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

这是我的光纤控制器

func register(c *fiber.ctx) error {
    user := new(user)

    if err := c.bodyparser(user); err != nil {
        return c.status(400).json(fiber.map{
            "error": err.error(),
        })
    }

    if user.username == "" || user.password == "" {
        return c.status(fiber.statusbadrequest).json(fiber.map{
            "error":   "bad request.",
            "message": "please include both username and password.",
        })
    }

    query := `select username from user where username = $1`

    res, err := db.query(query, user.username)

    if err != nil {
        return err
    }
    defer res.close()

    return c.json("hello")
}

但是当我到达终点时我得到了

panic: runtime error: invalid memory address or nil pointer dereference
[signal 0xc0000005 code=0x1 addr=0x20 pc=0x865db4]

goroutine 22 [running]:
database/sql.(*db).conn(0x0, {0xbee8e0, 0xeee440}, 0x1)
        c:/program files/go/src/database/sql/sql.go:1282 +0x54
database/sql.(*db).query(0x9?, {0xbee8e0, 0xeee440}, {0xb670d2, 0x2d}, {0xc00028fb08, 0x1, 0x1}, 0xc0?)
        c:/program files/go/src/database/sql/sql.go:1721 +0x57
database/sql.(*db).querycontext.func1(0x0?)
        c:/program files/go/src/database/sql/sql.go:1704 +0x4f
database/sql.(*db).retry(0xc00002c440?, 0xc00028f9f0)
database/sql.(*db).querycontext(0xc00000ad18?, {0xbee8e0?, 0xeee440?}, {0xb670d2?, 0xc00000ac50?}, {0xc00028fb08?, 0xc0000a3af8?, 0x7cbfaf?})
        c:/program files/go/src/database/sql/sql.go:1703 +0xc5
database/sql.(*db).query(...)
        c:/program files/go/src/database/sql/sql.go:1717
example/backend/user.register(0xc000004600)
        c:/users/me/documents/hello/backend/user/user.go:35 +0x1e5
github.com/gofiber/fiber/v2.(*app).next(0xc00000c900, 0xc000004600)
        c:/users/me/go/pkg/mod/github.com/gofiber/fiber/[email protected]/router.go:144 +0x1b2
github.com/gofiber/fiber/v2.(*app).handler(0xc00000c900, 0x81622f?)
        c:/users/me/go/pkg/mod/github.com/gofiber/fiber/[email protected]/router.go:171 +0x78
github.com/valyala/fasthttp.(*server).serveconn(0xc000160000, {0xbeff80?, 0xc00008e0c0})
        c:/users/me/go/pkg/mod/github.com/valyala/[email protected]/server.go:2363 +0x11d4
github.com/valyala/fasthttp.(*workerpool).workerfunc(0xc0000d0140, 0xc000096320)
        c:/users/me/go/pkg/mod/github.com/valyala/[email protected]/workerpool.go:224 +0xa4
github.com/valyala/fasthttp.(*workerpool).getch.func1()
        c:/users/me/go/pkg/mod/github.com/valyala/[email protected]/workerpool.go:196 +0x32
created by github.com/valyala/fasthttp.(*workerpool).getch in goroutine 1
        c:/users/me/go/pkg/mod/github.com/valyala/[email protected]/workerpool.go:195 +0x1ab

我有另一个端点没有执行任何查询并且工作正常，所以我认为我与数据库本身的连接没有任何问题，因为此时我已经建立了与它的连接。

这是我的另一个端点

app.get("/", func(c *fiber.ctx) error {
        return c.status(fiber.statusok).json(fiber.map{
            "status":  "ok.",
            "message": "service is up and running.",
        })
    })

这是我连接到 postgre 的方式，任何帮助将不胜感激

package config

import (
    "database/sql"
    "fmt"
    "os"

    "github.com/joho/godotenv"

    _ "github.com/lib/pq"
)

var db *sql.DB

func PostgreInit() error {
    // load env
    if envErr := godotenv.Load(".env"); envErr != nil {
        fmt.Println("Could not load .env")
        os.Exit(1)
    }

    var (
        DB_NAME     = os.Getenv("DB_NAME")
        DB_USER     = os.Getenv("DB_USER")
        DB_PASSWORD = os.Getenv("DB_PASSWORD")
        DB_HOST     = os.Getenv("DB_HOST")
        DB_PORT     = os.Getenv("DB_PORT")
    )

    // connect to db
    var err error
    connStr := fmt.Sprintf(
        "postgres://%v:%v@%v:%v/%v?sslmode=disable",
        DB_USER, DB_PASSWORD, DB_HOST, DB_PORT, DB_NAME)

    db, err = sql.Open("postgres", connStr)
    if err != nil {
        return err
    }

    if err = db.Ping(); err != nil {
        return err
    }

    return nil
}

正确答案

问题出在您的控制器中： res, err := db.Query(query, user.Username) 什么是db？如果数据库是这样的； var db *sql.DB，从控制器中你不能像这样使用 db 变量，因为在 golang 中小写意味着它是私有的。这就是它返回无效内存地址的原因。您应该通过依赖注入或类似的函数参数或任何您想要的方式传递连接。

好了，本文到此结束，带大家了解了《在Golang和Fiber中，使用database/sql和“github.com/lib/pq”作为PostgreSQL驱动程序进行查询的指南》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！