HyperNet/Nexus
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

🔊 More logs in db maintain

Browse Source
This commit is contained in:
LittleSheep 2025-03-01 13:27:07 +08:00
parent 74dd8fc182
commit 1f07c0edf4
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/internal/watchtower/database.go
View File

@ -125,11 +125,13 @@ func CleanDb(dsn string) error {
return fmt.Errorf("failed to scan tables: %v", err) return fmt.Errorf("failed to scan tables: %v", err)
} }
deadline := time.Now().Add(-7 * 24 * time.Hour) // 30 days before deadline := time.Now().Add(-7 * 24 * time.Hour) // 7 days before
for _, table := range tables { for _, table := range tables {
sql := fmt.Sprintf("DELETE FROM %s WHERE deleted_at < ?", table) sql := fmt.Sprintf("DELETE FROM %s WHERE deleted_at < ?", table)
if err := conn.Raw(sql, deadline).Error; err != nil { if tx := conn.Raw(sql, deadline); tx.Error != nil {
log.Warn().Err(err).Str("table", table).Str("dsn", dsn).Msg("Unable to clean soft deleted records in this table...") log.Warn().Err(err).Str("table", table).Str("dsn", dsn).Msg("Unable to clean soft deleted records in this table...")
} else {
log.Info().Str("table", table).Str("dsn", dsn).Int64("rows", tx.RowsAffected).Msg("Cleaned soft deleted records in this table...")
} }
} }