我有一个使用 golang-migrate/migrate 和 postgresql 数据库的简单应用程序。但是,我认为在调用Migration
函数时会收到错误,因为我的 sourceURL 或 databaseURLmigrate.New()
是无效的内存地址或 nil 指针。
但我不确定为什么我的 sourceURL 或 databaseURL 会导致错误 - 我将 sourceURL 存储file:///database/migration
为存储我的 sql 文件的目录,databaseURL 存储postgres://postgres:postgres@127.0.0.1:5432/go_graphql?sslmode=disable
在我的 Makefile 中定义的目录。
我Makefile
的是这样的
migrate:
migrate -source file://database/migration \
-database postgres://postgres:postgres@127.0.0.1:5432/go_graphql?sslmode=disable up
rollback:
migrate -source file://database/migration \
-database postgres://postgres:postgres@127.0.0.1:5432/go_graphql?sslmode=disable down
drop:
migrate -source file://database/migration \
-database postgres://postgres:postgres@127.0.0.1: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")
}
我打电话时出错db.Migration
了main.go
func (db *DB) Migration() error {
m, err := migrate.New("file:///database/migration/", "postgres://postgres:postgres@127.0.0.1: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 网址相同
type database struct {
URL string
}
type Config struct {
Database database
}
func New() *Config {
godotenv.Load()
return &Config{
Database: database{
URL: os.Getenv("DATABASE_URL"),
},
}
}