@@ -63,15 +63,15 @@ func New(opts ...Option) (*Migrator, error) {
63
63
}
64
64
65
65
if len (m .migrations ) == 0 {
66
- return nil , errors .New ("Migrations must be provided" )
66
+ return nil , errors .New ("migrations must be provided" )
67
67
}
68
68
69
69
for _ , m := range m .migrations {
70
70
switch m .(type ) {
71
71
case * Migration :
72
72
case * MigrationNoTx :
73
73
default :
74
- return nil , errors .New ("Invalid migration type" )
74
+ return nil , errors .New ("invalid migration type" )
75
75
}
76
76
}
77
77
@@ -103,11 +103,11 @@ func (m *Migrator) Migrate(ctx context.Context, db PgxIface) error {
103
103
switch mm := migration .(type ) {
104
104
case * Migration :
105
105
if err := migrate (ctx , db , insertVersion , mm , m .onNotice ); err != nil {
106
- return fmt .Errorf ("Error while running migrations: %w" , err )
106
+ return fmt .Errorf ("error while running migrations: %w" , err )
107
107
}
108
108
case * MigrationNoTx :
109
109
if err := migrateNoTx (ctx , db , insertVersion , mm , m .onNotice ); err != nil {
110
- return fmt .Errorf ("Error while running migrations: %w" , err )
110
+ return fmt .Errorf ("error while running migrations: %w" , err )
111
111
}
112
112
}
113
113
}
@@ -185,18 +185,18 @@ func migrate(ctx context.Context, db PgxIface, insertVersion string, migration *
185
185
defer func () {
186
186
if err != nil {
187
187
if errRb := tx .Rollback (ctx ); errRb != nil {
188
- err = fmt .Errorf ("Error rolling back: %s\n %s" , errRb , err )
188
+ err = fmt .Errorf ("error rolling back: %s\n %s" , errRb , err )
189
189
}
190
190
return
191
191
}
192
192
err = tx .Commit (ctx )
193
193
}()
194
194
notice (fmt .Sprintf ("Applying migration named '%s'..." , migration .Name ))
195
195
if err = migration .Func (ctx , tx ); err != nil {
196
- return fmt .Errorf ("Error executing golang migration: %w" , err )
196
+ return fmt .Errorf ("error executing golang migration: %w" , err )
197
197
}
198
198
if _ , err = tx .Exec (ctx , insertVersion ); err != nil {
199
- return fmt .Errorf ("Error updating migration versions: %w" , err )
199
+ return fmt .Errorf ("error updating migration versions: %w" , err )
200
200
}
201
201
notice (fmt .Sprintf ("Applied migration named '%s'" , migration .Name ))
202
202
@@ -206,10 +206,10 @@ func migrate(ctx context.Context, db PgxIface, insertVersion string, migration *
206
206
func migrateNoTx (ctx context.Context , db PgxIface , insertVersion string , migration * MigrationNoTx , notice func (string )) error {
207
207
notice (fmt .Sprintf ("Applying no tx migration named '%s'..." , migration .Name ))
208
208
if err := migration .Func (ctx , db ); err != nil {
209
- return fmt .Errorf ("Error executing golang migration: %w" , err )
209
+ return fmt .Errorf ("error executing golang migration: %w" , err )
210
210
}
211
211
if _ , err := db .Exec (ctx , insertVersion ); err != nil {
212
- return fmt .Errorf ("Error updating migration versions: %w" , err )
212
+ return fmt .Errorf ("error updating migration versions: %w" , err )
213
213
}
214
214
notice (fmt .Sprintf ("Applied no tx migration named '%s'..." , migration .Name ))
215
215
0 commit comments