Fixed #17300 -- Prevented createcachetable from crashing when the cache table already exists. Thanks Claude Paroz.

git-svn-id: http://code.djangoproject.com/svn/django/trunk@17363 bcc190cf-cafb-0310-a4f2-bffc1f526a37
This commit is contained in:
Aymeric Augustin 2012-01-08 20:00:30 +00:00
parent 15d10a5210
commit 19c544ff42
2 changed files with 18 additions and 4 deletions

View File

@ -3,6 +3,7 @@ from optparse import make_option
from django.core.cache.backends.db import BaseDatabaseCache
from django.core.management.base import LabelCommand
from django.db import connections, router, transaction, models, DEFAULT_DB_ALIAS
from django.db.utils import DatabaseError
class Command(LabelCommand):
help = "Creates the table needed to use the SQL cache backend."
@ -51,7 +52,14 @@ class Command(LabelCommand):
full_statement.append(' %s%s' % (line, i < len(table_output)-1 and ',' or ''))
full_statement.append(');')
curs = connection.cursor()
curs.execute("\n".join(full_statement))
for statement in index_output:
curs.execute(statement)
transaction.commit_unless_managed(using=db)
try:
curs.execute("\n".join(full_statement))
except DatabaseError, e:
self.stderr.write(
self.style.ERROR("Cache table '%s' could not be created.\nThe error was: %s.\n" %
(tablename, e)))
transaction.rollback_unless_managed(using=db)
else:
for statement in index_output:
curs.execute(statement)
transaction.commit_unless_managed(using=db)

View File

@ -7,6 +7,7 @@ from __future__ import with_statement, absolute_import
import hashlib
import os
import re
import StringIO
import tempfile
import time
import warnings
@ -817,6 +818,11 @@ class DBCacheTests(BaseCacheTests, TransactionTestCase):
self.cache = get_cache('db://%s?max_entries=30&cull_frequency=0' % self._table_name)
self.perform_cull_test(50, 18)
def test_second_call_doesnt_crash(self):
err = StringIO.StringIO()
management.call_command('createcachetable', self._table_name, verbosity=0, interactive=False, stderr=err)
self.assertTrue("Cache table 'test cache table' could not be created" in err.getvalue())
DBCacheWithTimeZoneTests = override_settings(USE_TZ=True)(DBCacheTests)