Fix query error when no schema name was provided

2017-07-07 12:35:46 +02:00 · 2017-07-07 12:35:46 +02:00 · 42f58417e9
commit 42f58417e9
parent 0ebacc4842
1 changed files with 5 additions and 3 deletions
--- a/migrate.go
+++ b/migrate.go
@ -87,10 +87,12 @@ 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`)
 		if err != nil {
 			return err
 		}
+	}

 	err = tx.Commit()
 	if err != nil {