cache_cleanup.py.svn-base

"""
Daily cleanup job.

Can be run as a cronjob to clean out old data from the database (only expired
sessions at the moment).
"""

from django_extensions.management.jobs import DailyJob

class Job(DailyJob):
    help = "Cache (db) cleanup Job"

    def execute(self):
	from django.conf import settings
	import os

	if settings.CACHE_BACKEND.startswith('db://'):
	    os.environ['TZ'] = settings.TIME_ZONE
	    table_name = settings.CACHE_BACKEND[5:]
	    cursor = connection.cursor()
	    cursor.execute("DELETE FROM %s WHERE %s < UTC_TIMESTAMP()" % \
		(backend.quote_name(table_name), backend.quote_name('expires')))
	    transaction.commit_unless_managed()