hanzoai/migrate
2
0
Fork 0
mirror of https://github.com/hanzoai/migrate.git synced 2026-09-30 22:55:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

rename Migration.LongString to LogString

Browse Source
This commit is contained in:
Matthias Kadenbach
2017-02-09 18:06:38 -08:00
parent 1dd572fb18
commit 1392f22c47
3 changed files with 12 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
migrate.go
+8 -8
View File
@@ -295,9 +295,9 @@ func (m *Migrate) Run(migration ...*Migration) error {
defer close(ret)
for _, migr := range migration {
if m.PrefetchMigrations > 0 && migr.Body != nil {
m.logVerbosePrintf("Start buffering %v\n", migr.StringLong())
m.logVerbosePrintf("Start buffering %v\n", migr.LogString())
} else {
m.logVerbosePrintf("Scheduled %v\n", migr.StringLong())
m.logVerbosePrintf("Scheduled %v\n", migr.LogString())
}
ret <- migr
@@ -629,13 +629,13 @@ func (m *Migrate) runMigrations(ret <-chan interface{}) error {
migr := r.(*Migration)
if migr.Body == nil {
m.logVerbosePrintf("Execute %v\n", migr.StringLong())
m.logVerbosePrintf("Execute %v\n", migr.LogString())
if err := m.databaseDrv.Run(migr.TargetVersion, nil); err != nil {
return err
}
} else {
m.logVerbosePrintf("Read and execute %v\n", migr.StringLong())
m.logVerbosePrintf("Read and execute %v\n", migr.LogString())
if err := m.databaseDrv.Run(migr.TargetVersion, migr.BufferedBody); err != nil {
return err
}
@@ -648,9 +648,9 @@ func (m *Migrate) runMigrations(ret <-chan interface{}) error {
// log either verbose or normal
if m.Log != nil {
if m.Log.Verbose() {
m.logPrintf("Finished %v (read %v, ran %v)\n", migr.StringLong(), readTime, runTime)
m.logPrintf("Finished %v (read %v, ran %v)\n", migr.LogString(), readTime, runTime)
} else {
m.logPrintf("%v (%v)\n", migr.StringLong(), readTime+runTime)
m.logPrintf("%v (%v)\n", migr.LogString(), readTime+runTime)
}
}
@@ -754,9 +754,9 @@ func (m *Migrate) newMigration(version uint, targetVersion int) (*Migration, err
}
if m.PrefetchMigrations > 0 && migr.Body != nil {
m.logVerbosePrintf("Start buffering %v\n", migr.StringLong())
m.logVerbosePrintf("Start buffering %v\n", migr.LogString())
} else {
m.logVerbosePrintf("Scheduled %v\n", migr.StringLong())
m.logVerbosePrintf("Scheduled %v\n", migr.LogString())
}
return migr, nil
migration.go
+1 -2
View File
@@ -108,8 +108,7 @@ func (m *Migration) String() string {
}
// StringLong returns a string describing this migration to humans.
// TODO: rename to LogString()
func (m *Migration) StringLong() string {
func (m *Migration) LogString() string {
directionStr := "u"
if m.TargetVersion < int(m.Version) {
directionStr = "d"
migration_test.go
+3 -3
View File
@@ -19,7 +19,7 @@ func ExampleNewMigration() {
log.Fatal(err)
}
fmt.Print(migr.StringLong())
fmt.Print(migr.LogString())
// Output:
// 1486686016/u create_users_table
}
@@ -33,7 +33,7 @@ func ExampleNewMigration_nilMigration() {
log.Fatal(err)
}
fmt.Print(migr.StringLong())
fmt.Print(migr.LogString())
// Output:
// 1486686016/u <empty>
}
@@ -50,7 +50,7 @@ func ExampleNewMigration_nilVersion() {
log.Fatal(err)
}
fmt.Print(migr.StringLong())
fmt.Print(migr.LogString())
// Output:
// 1486686016/d drop_users_table
}