Fix lint
This commit is contained in:
parent
7d4e191660
commit
97bf025984
|
@ -87,7 +87,11 @@ func (m *Migrate) Migrate() error {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
if m.initSchema != nil && m.isFirstRun() {
|
isFirstRun, err := m.isFirstRun()
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
if m.initSchema != nil && isFirstRun {
|
||||||
return m.runInitSchema()
|
return m.runInitSchema()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -200,11 +204,10 @@ func (m *Migrate) migrationDidRun(mig *Migration) (bool, error) {
|
||||||
return count > 0, err
|
return count > 0, err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *Migrate) isFirstRun() bool {
|
func (m *Migrate) isFirstRun() (bool, error) {
|
||||||
row := m.db.DB().QueryRow(fmt.Sprintf("SELECT COUNT(*) FROM %s", m.options.TableName))
|
|
||||||
var count int
|
var count int
|
||||||
_ = row.Scan(&count)
|
_, err := m.db.SQL(fmt.Sprintf("SELECT COUNT(*) FROM %s", m.options.TableName)).Get(&count)
|
||||||
return count == 0
|
return count == 0, err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *Migrate) insertMigration(id string) error {
|
func (m *Migrate) insertMigration(id string) error {
|
||||||
|
|
Loading…
Reference in New Issue