summaryrefslogtreecommitdiff
path: root/django/db/models/indexes.py
diff options
context:
space:
mode:
authorAkshesh <aksheshdoshi@gmail.com>2016-06-25 22:02:56 +0530
committerTim Graham <timograham@gmail.com>2016-06-27 10:41:01 -0400
commit156e2d59cf92eb252c2f6ef9bb0b65f26c707de2 (patch)
treea385db97c67f6b8504954c3df3ac88f169d13f8c /django/db/models/indexes.py
parentc962b9104a22505a7d6c57bbec9eda163f486c7d (diff)
downloaddjango-156e2d59cf92eb252c2f6ef9bb0b65f26c707de2.tar.gz
Fixed #26709 -- Added class-based indexes.
Added the AddIndex and RemoveIndex operations to use them in migrations. Thanks markush, mjtamlyn, timgraham, and charettes for review and advice.
Diffstat (limited to 'django/db/models/indexes.py')
-rw-r--r--django/db/models/indexes.py113
1 files changed, 113 insertions, 0 deletions
diff --git a/django/db/models/indexes.py b/django/db/models/indexes.py
new file mode 100644
index 0000000000..15d618156e
--- /dev/null
+++ b/django/db/models/indexes.py
@@ -0,0 +1,113 @@
+from __future__ import unicode_literals
+
+import hashlib
+
+from django.utils.encoding import force_bytes
+from django.utils.functional import cached_property
+
+__all__ = ['Index']
+
+# The max length of the names of the indexes (restricted to 30 due to Oracle)
+MAX_NAME_LENGTH = 30
+
+
+class Index(object):
+ suffix = 'idx'
+
+ def __init__(self, fields=[], name=None):
+ if not fields:
+ raise ValueError('At least one field is required to define an index.')
+ self.fields = fields
+ self._name = name or ''
+ if self._name:
+ errors = self.check_name()
+ if len(self._name) > MAX_NAME_LENGTH:
+ errors.append('Index names cannot be longer than %s characters.' % MAX_NAME_LENGTH)
+ if errors:
+ raise ValueError(errors)
+
+ @cached_property
+ def name(self):
+ if not self._name:
+ self._name = self.get_name()
+ self.check_name()
+ return self._name
+
+ def check_name(self):
+ errors = []
+ # Name can't start with an underscore on Oracle; prepend D if needed.
+ if self._name[0] == '_':
+ errors.append('Index names cannot start with an underscore (_).')
+ self._name = 'D%s' % self._name[1:]
+ # Name can't start with a number on Oracle; prepend D if needed.
+ elif self._name[0].isdigit():
+ errors.append('Index names cannot start with a number (0-9).')
+ self._name = 'D%s' % self._name[1:]
+ return errors
+
+ def create_sql(self, schema_editor):
+ fields = [self.model._meta.get_field(field) for field in self.fields]
+ tablespace_sql = schema_editor._get_index_tablespace_sql(self.model, fields)
+ columns = [field.column for field in fields]
+
+ quote_name = schema_editor.quote_name
+ return schema_editor.sql_create_index % {
+ 'table': quote_name(self.model._meta.db_table),
+ 'name': quote_name(self.name),
+ 'columns': ', '.join(quote_name(column) for column in columns),
+ 'extra': tablespace_sql,
+ }
+
+ def remove_sql(self, schema_editor):
+ quote_name = schema_editor.quote_name
+ return schema_editor.sql_delete_index % {
+ 'table': quote_name(self.model._meta.db_table),
+ 'name': quote_name(self.name),
+ }
+
+ def deconstruct(self):
+ path = '%s.%s' % (self.__class__.__module__, self.__class__.__name__)
+ path = path.replace('django.db.models.indexes', 'django.db.models')
+ return (path, (), {'fields': self.fields})
+
+ @staticmethod
+ def _hash_generator(*args):
+ """
+ Generate a 32-bit digest of a set of arguments that can be used to
+ shorten identifying names.
+ """
+ h = hashlib.md5()
+ for arg in args:
+ h.update(force_bytes(arg))
+ return h.hexdigest()[:6]
+
+ def get_name(self):
+ """
+ Generate a unique name for the index.
+
+ The name is divided into 3 parts - table name (12 chars), field name
+ (8 chars) and unique hash + suffix (10 chars). Each part is made to
+ fit its size by truncating the excess length.
+ """
+ table_name = self.model._meta.db_table
+ column_names = [self.model._meta.get_field(field).column for field in self.fields]
+ hash_data = [table_name] + column_names + [self.suffix]
+ index_name = '%s_%s_%s' % (
+ table_name[:11],
+ column_names[0][:7],
+ '%s_%s' % (self._hash_generator(*hash_data), self.suffix),
+ )
+ assert len(index_name) <= 30, (
+ 'Index too long for multiple database support. Is self.suffix '
+ 'longer than 3 characters?'
+ )
+ return index_name
+
+ def __repr__(self):
+ return "<%s: fields='%s'>" % (self.__class__.__name__, ', '.join(self.fields))
+
+ def __eq__(self, other):
+ return (self.__class__ == other.__class__) and (self.deconstruct() == other.deconstruct())
+
+ def __ne__(self, other):
+ return not (self == other)