我正在嘗試使用golang-migrate將 sql 文件遷移到我的 postgresql 數(shù)據(jù)庫(kù)中。我可能做錯(cuò)了，但是當(dāng)我運(yùn)行遷移命令時(shí)，它說(shuō)沒有找到方案： $ go run ./cmd/ migrate2022/04/05 16:20:29 no schemeexit status 1這是代碼： // package dbschema contains the database schema, migrations, and seeding data. package dbschema import ( "context" _ "embed" // Calls init function. "fmt" "log" "github.com/golang-migrate/migrate/v4" "github.com/golang-migrate/migrate/v4/database/postgres" "github.com/jmoiron/sqlx" "github.com/jonleopard/bootstrap/pkg/sys/database" _ "github.com/lib/pq" ) var ( //go:embed sql/000001_schema.up.sql schemaDoc string //go:embed sql/seed.sql seedDoc string ) // Migrate attempts to bring the schema for db up to date with the migrations // defined in this package. func Migrate(ctx context.Context, db *sqlx.DB) error { if err := database.StatusCheck(ctx, db); err != nil { return fmt.Errorf("status check database: %w", err) } driver, err := postgres.WithInstance(db.DB, &postgres.Config{}) if err != nil { return fmt.Errorf("Construct Migrate driver: %w", err) } m, err := migrate.NewWithDatabaseInstance(schemaDoc, "postgres", driver) if err != nil { log.Fatal(err) } return m.Up() }
1 回答
瀟湘沐
TA貢獻(xiàn)1816條經(jīng)驗(yàn) 獲得超6個(gè)贊
func NewWithDatabaseInstance(sourceURL string, databaseName string, databaseInstance database.Driver) (*Migrate, error)
所以第一個(gè)參數(shù)是一個(gè) URL，你傳遞的是腳本本身。NewWithDatabaseInstance調(diào)用SchemeFromURL是什么產(chǎn)生了你看到的錯(cuò)誤（因?yàn)槟銈鬟f的 url 不包含 a :）。一個(gè)URL包含一個(gè)“方案” :，然后是其他信息。
要將 golang-migrate 與文檔中embed的示例結(jié)合使用：
//go:embed testdata/migrations/*.sql
var fs embed.FS
func main() {
d, err := iofs.New(fs, "testdata/migrations")
if err != nil {
log.Fatal(err)
}
m, err := migrate.NewWithSourceInstance("iofs", d, "postgres://postgres@localhost/postgres?sslmode=disable")
if err != nil {
log.Fatal(err)
}
err = m.Up()
if err != nil {
// ...
}
// ...
}
您會(huì)注意到，這會(huì)傳入文件夾（作為embed.FS）而不是單個(gè)文件。這是因?yàn)間olang-migrate旨在應(yīng)用多個(gè)遷移，而不是僅針對(duì)數(shù)據(jù)庫(kù)運(yùn)行單個(gè)腳本。你應(yīng)該能夠使用類似的東西：
//go:embed sql/*.sql
var schemaFs embed.FS
...
d, err := iofs.New(fs, "sql") // Get migrations from sql folder
if err != nil {
log.Fatal(err)
}
m, err := migrate.NewWithSourceInstance("iofs", d, "postgres", driver)
- 1 回答
- 0 關(guān)注
- 141 瀏覽
添加回答
舉報(bào)
0/150
提交
取消