diff --git a/migrate.go b/migrate.go index 96609d9..465a96b 100644 --- a/migrate.go +++ b/migrate.go @@ -38,6 +38,9 @@ func Migrate(db *sql.DB, version int, o Options, asset AssetFunc) error { var err error + searchPath := `public` + _ = db.QueryRow(`SHOW search_path`).Scan(&searchPath) + if o.Schema != `` { _, _ = db.Exec(`CREATE SCHEMA IF NOT EXISTS ` + o.Schema) @@ -88,7 +91,7 @@ func Migrate(db *sql.DB, version int, o Options, asset AssetFunc) error { } if o.Schema != `` { - _, err = tx.Exec(`SET search_path TO ` + o.Schema + `,public`) + _, err = tx.Exec(`SET search_path TO ` + searchPath) if err != nil { return err }