Manager: vacuum the database at startup
This commit is contained in:
parent
1fc71ccf92
commit
98da20f1a9
@ -33,6 +33,9 @@ func OpenDB(ctx context.Context, dsn string) (*DB, error) {
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Perfom some maintenance at startup.
|
||||||
|
db.vacuum()
|
||||||
|
|
||||||
if err := db.migrate(); err != nil {
|
if err := db.migrate(); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
@ -62,6 +65,7 @@ func openDBWithConfig(uri string, config *gorm.Config) (*DB, error) {
|
|||||||
db := DB{
|
db := DB{
|
||||||
gormDB: gormDB,
|
gormDB: gormDB,
|
||||||
}
|
}
|
||||||
|
|
||||||
return &db, nil
|
return &db, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -82,9 +86,14 @@ func (db *DB) PeriodicMaintenanceLoop(ctx context.Context) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
log.Debug().Msg("vacuuming database")
|
log.Debug().Msg("vacuuming database")
|
||||||
|
db.vacuum()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// vacuum executes the SQL "VACUUM" command, and logs any errors.
|
||||||
|
func (db *DB) vacuum() {
|
||||||
tx := db.gormDB.Exec("vacuum")
|
tx := db.gormDB.Exec("vacuum")
|
||||||
if tx.Error != nil {
|
if tx.Error != nil {
|
||||||
log.Error().Err(tx.Error).Msg("error vacuuming database")
|
log.Error().Err(tx.Error).Msg("error vacuuming database")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user