1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
#!/usr/bin/python -S
#
# Copyright 2009 Canonical Ltd. This software is licensed under the
# GNU Affero General Public License version 3 (see the file LICENSE).
"""Prune old nonces."""
__metaclass__ = type
__all__ = []
import _pythonpath
from optparse import OptionParser
from canonical.database.sqlbase import connect, ISOLATION_LEVEL_AUTOCOMMIT
from canonical.launchpad.scripts import db_options
from canonical.launchpad.scripts.logger import log, logger_options
def update_until_done(con, table, query, vacuum_every=100):
log.info("Running %s" % query)
loops = 0
total_rows = 0
cur = con.cursor()
while True:
loops += 1
cur.execute(query)
rowcount = cur.rowcount
total_rows += rowcount
log.debug("Updated %d" % total_rows)
if vacuum_every is not None and loops % vacuum_every == 0:
log.debug("Vacuuming %s" % table)
cur.execute("VACUUM %s" % table)
if rowcount <= 0:
log.info("Done")
return
parser = OptionParser()
logger_options(parser)
db_options(parser)
options, args = parser.parse_args()
con = connect(options.dbuser, isolation=ISOLATION_LEVEL_AUTOCOMMIT)
update_until_done(con, 'OAuthNonce', """
DELETE FROM OAuthNonce
WHERE id IN (
SELECT id FROM OAuthNonce
WHERE request_timestamp < 'yesterday'
LIMIT 5000)
""", vacuum_every=None)
|