Audit fixes
This commit is contained in:
11
migrate.go
11
migrate.go
@@ -5,8 +5,7 @@ import (
|
|||||||
"embed"
|
"embed"
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"path/filepath"
|
"path"
|
||||||
"sort"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
const initMigrationTableQuery = `
|
const initMigrationTableQuery = `
|
||||||
@@ -34,17 +33,13 @@ func Migrate(db *sql.DB, migrationFS embed.FS) error {
|
|||||||
return fmt.Errorf("unexpected non-directory in migration FS: %s", dirs[0].Name())
|
return fmt.Errorf("unexpected non-directory in migration FS: %s", dirs[0].Name())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ReadDir returns files in sorted order.
|
||||||
dirName := dirs[0].Name()
|
dirName := dirs[0].Name()
|
||||||
files, err := migrationFS.ReadDir(dirName)
|
files, err := migrationFS.ReadDir(dirName)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// Sort sql files by name.
|
|
||||||
sort.Slice(files, func(i, j int) bool {
|
|
||||||
return files[i].Name() < files[j].Name()
|
|
||||||
})
|
|
||||||
|
|
||||||
for _, dirEnt := range files {
|
for _, dirEnt := range files {
|
||||||
if !dirEnt.Type().IsRegular() {
|
if !dirEnt.Type().IsRegular() {
|
||||||
return fmt.Errorf("unexpected non-regular file in migration fs: %s", dirEnt.Name())
|
return fmt.Errorf("unexpected non-regular file in migration fs: %s", dirEnt.Name())
|
||||||
@@ -64,7 +59,7 @@ func Migrate(db *sql.DB, migrationFS embed.FS) error {
|
|||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
migration, err := migrationFS.ReadFile(filepath.Join(dirName, name))
|
migration, err := migrationFS.ReadFile(path.Join(dirName, name))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user