Report correct number of pruned rows in Postgres mailserver (#1789)
This commit is contained in:
parent
44aa313981
commit
179e3e851e
|
@ -171,11 +171,15 @@ func (i *PostgresDB) Prune(t time.Time, batch int) (int, error) {
|
||||||
}
|
}
|
||||||
defer stmt.Close()
|
defer stmt.Close()
|
||||||
|
|
||||||
if _, err = stmt.Exec(kl.Bytes(), ku.Bytes()); err != nil {
|
result, err := stmt.Exec(kl.Bytes(), ku.Bytes())
|
||||||
|
if err != nil {
|
||||||
return 0, err
|
return 0, err
|
||||||
}
|
}
|
||||||
|
rows, err := result.RowsAffected()
|
||||||
return 0, nil
|
if err != nil {
|
||||||
|
return 0, err
|
||||||
|
}
|
||||||
|
return int(rows), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (i *PostgresDB) SaveEnvelope(env types.Envelope) error {
|
func (i *PostgresDB) SaveEnvelope(env types.Envelope) error {
|
||||||
|
|
Loading…
Reference in New Issue