From 220cabfb5b1a6218dc15397da7567be1997d836d Mon Sep 17 00:00:00 2001 From: Steven Date: Thu, 29 Aug 2024 20:31:37 +0800 Subject: [PATCH] fix: migrator base path --- store/migrator.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/store/migrator.go b/store/migrator.go index 6f81654..00061be 100644 --- a/store/migrator.go +++ b/store/migrator.go @@ -61,7 +61,7 @@ func (s *Store) Migrate(ctx context.Context) error { } if common.IsVersionGreaterThan(schemaVersion, latestMigrationHistoryVersion) { - filePaths, err := fs.Glob(migrationFS, fmt.Sprintf("%s/*/*.sql", s.getMigrationBasePath())) + filePaths, err := fs.Glob(migrationFS, fmt.Sprintf("%s*/*.sql", s.getMigrationBasePath())) if err != nil { return errors.Wrap(err, "failed to read migration files") } @@ -265,7 +265,7 @@ func (s *Store) normalizedMigrationHistoryList(ctx context.Context) error { latestMinorVersion := common.GetMinorVersion(latestVersion) schemaVersionMap := map[string]string{} - filePaths, err := fs.Glob(migrationFS, fmt.Sprintf("%s/*/*.sql", s.getMigrationBasePath())) + filePaths, err := fs.Glob(migrationFS, fmt.Sprintf("%s*/*.sql", s.getMigrationBasePath())) if err != nil { return errors.Wrap(err, "failed to read migration files") }