使用 golang-migrate 实现数据库迁移

你在学习Golang相关的知识吗？本文《使用 golang-migrate 实现数据库迁移》，主要介绍的内容就涉及到，如果你想提升自己的开发能力，就不要错过这篇文章，大家要知道编程理论基础和实战操作都是不可或缺的哦！

我有一个简单的应用程序，使用 golang-migrate/migrate 和 postgresql 数据库。但是，我认为当我调用 migration 函数时收到错误，因为 migrate.new() 中的 sourceurl 或 databaseurl 是无效的内存地址或 nil 指针。

但我不确定为什么我的sourceurl或databaseurl导致错误 - 我将sourceurl存储为file:///database/migration，这是存储我的sql文件的目录，databaseurl存储为postgres://postgres:[email protected]:5432/go_graphql?sslmode=disable 这是在我的 makefile 中定义的。

我的makefile是这样的

migrate:
    migrate -source file://database/migration \
            -database postgres://postgres:[email protected]:5432/go_graphql?sslmode=disable up

rollback:
    migrate -source file://database/migration \
            -database postgres://postgres:[email protected]:5432/go_graphql?sslmode=disable down

drop:
    migrate -source file://database/migration \
            -database postgres://postgres:[email protected]:5432/go_graphql?sslmode=disable drop

migration:
    migrate create -ext sql -dir database/migration go_graphql

run:
    go run main.go

然后，我的 main.go 如下所示。

func main() {
    ctx := context.background()

    config := config.new()

    db := pg.new(ctx, config)
    println("hel")

    if err := db.migration(); err != nil {
        log.fatal(err)
    }

    fmt.println("server started")
}

在 main.go 中调用 db.migration 时出现错误

func (db *db) migration() error {

    m, err := migrate.new("file:///database/migration/", "postgres://postgres:[email protected]:5432/go_graphql?sslmode=disable"))
    println(m)
    if err != nil {
        // **i get error here!!**
        return fmt.errorf("error happened when migration")
    }
    if err := m.up(); err != nil && err != migrate.errnochange {
        return fmt.errorf("error when migration up: %v", err)
    }

    log.println("migration completed!")
    return err
}

这是我的 config.go。 database_url 与 postgres url 相同

type database struct {
    URL string
}

type Config struct {
    Database database
}

func New() *Config {
    godotenv.Load()

    return &Config{
        Database: database{
            URL: os.Getenv("DATABASE_URL"),
        },
    }
}

正确答案

由于您在评论中发布的错误 error 在迁移源驱动程序时发生：未知驱动程序“文件”（忘记导入？） 我可以告诉您，如上所述，您忘记导入 file：

import (
  ....
  _ "github.com/golang-migrate/migrate/v4/source/file"
)

您可以在 部分中查看 https://github.com/golang-migrate/migrate#use-in-your-go-project 中的示例想要使用现有数据库客户端吗？

终于介绍完啦！小伙伴们，这篇关于《使用 golang-migrate 实现数据库迁移》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！