summaryrefslogtreecommitdiff
path: root/django/db/backends
diff options
context:
space:
mode:
authorPaveł Tyślacki <pavel.tyslacki@gmail.com>2018-12-27 22:21:59 +0300
committerTim Graham <timograham@gmail.com>2019-01-12 09:50:20 -0500
commitb69f8eb04cc8762d3dfd5af5ea1fc58e3f2ebcc3 (patch)
tree6662b0cfe731e1912ff157ed46540be87cbec2bc /django/db/backends
parent1e837c4b2351c83b1c902314ddfdfa15c63bc60d (diff)
Fixed #30062 -- Added support for unique conditional constraints.
Diffstat (limited to 'django/db/backends')
-rw-r--r--django/db/backends/base/schema.py50
-rw-r--r--django/db/backends/sqlite3/schema.py11
2 files changed, 47 insertions, 14 deletions
diff --git a/django/db/backends/base/schema.py b/django/db/backends/base/schema.py
index 578bfb244c..113d1b7f67 100644
--- a/django/db/backends/base/schema.py
+++ b/django/db/backends/base/schema.py
@@ -80,6 +80,7 @@ class BaseDatabaseSchemaEditor:
sql_delete_fk = sql_delete_constraint
sql_create_index = "CREATE INDEX %(name)s ON %(table)s (%(columns)s)%(extra)s%(condition)s"
+ sql_create_unique_index = "CREATE UNIQUE INDEX %(name)s ON %(table)s (%(columns)s)%(condition)s"
sql_delete_index = "DROP INDEX %(name)s"
sql_create_pk = "ALTER TABLE %(table)s ADD CONSTRAINT %(name)s PRIMARY KEY (%(columns)s)"
@@ -296,7 +297,7 @@ class BaseDatabaseSchemaEditor:
# Make the table
sql = self.sql_create_table % {
"table": self.quote_name(model._meta.db_table),
- "definition": ", ".join((*column_sqls, *constraints)),
+ "definition": ", ".join(constraint for constraint in (*column_sqls, *constraints) if constraint),
}
if model._meta.db_tablespace:
tablespace_sql = self.connection.ops.tablespace_sql(model._meta.db_tablespace)
@@ -339,11 +340,15 @@ class BaseDatabaseSchemaEditor:
def add_constraint(self, model, constraint):
"""Add a check constraint to a model."""
- self.execute(constraint.create_sql(model, self))
+ sql = constraint.create_sql(model, self)
+ if sql:
+ self.execute(sql)
def remove_constraint(self, model, constraint):
"""Remove a check constraint from a model."""
- self.execute(constraint.remove_sql(model, self))
+ sql = constraint.remove_sql(model, self)
+ if sql:
+ self.execute(sql)
def alter_unique_together(self, model, old_unique_together, new_unique_together):
"""
@@ -1008,7 +1013,14 @@ class BaseDatabaseSchemaEditor:
def _delete_fk_sql(self, model, name):
return self._delete_constraint_sql(self.sql_delete_fk, model, name)
- def _unique_sql(self, fields, name):
+ def _unique_sql(self, model, fields, name, condition=None):
+ if condition:
+ # Databases support conditional unique constraints via a unique
+ # index.
+ sql = self._create_unique_sql(model, fields, name=name, condition=condition)
+ if sql:
+ self.deferred_sql.append(sql)
+ return None
constraint = self.sql_unique_constraint % {
'columns': ', '.join(map(self.quote_name, fields)),
}
@@ -1017,7 +1029,7 @@ class BaseDatabaseSchemaEditor:
'constraint': constraint,
}
- def _create_unique_sql(self, model, columns, name=None):
+ def _create_unique_sql(self, model, columns, name=None, condition=None):
def create_unique_name(*args, **kwargs):
return self.quote_name(self._create_index_name(*args, **kwargs))
@@ -1027,14 +1039,28 @@ class BaseDatabaseSchemaEditor:
else:
name = self.quote_name(name)
columns = Columns(table, columns, self.quote_name)
- return Statement(
- self.sql_create_unique,
- table=table,
- name=name,
- columns=columns,
- )
+ if condition:
+ return Statement(
+ self.sql_create_unique_index,
+ table=table,
+ name=name,
+ columns=columns,
+ condition=' WHERE ' + condition,
+ ) if self.connection.features.supports_partial_indexes else None
+ else:
+ return Statement(
+ self.sql_create_unique,
+ table=table,
+ name=name,
+ columns=columns,
+ )
- def _delete_unique_sql(self, model, name):
+ def _delete_unique_sql(self, model, name, condition=None):
+ if condition:
+ return (
+ self._delete_constraint_sql(self.sql_delete_index, model, name)
+ if self.connection.features.supports_partial_indexes else None
+ )
return self._delete_constraint_sql(self.sql_delete_unique, model, name)
def _check_sql(self, name, check):
diff --git a/django/db/backends/sqlite3/schema.py b/django/db/backends/sqlite3/schema.py
index e8e40bbe34..b1c91dba3c 100644
--- a/django/db/backends/sqlite3/schema.py
+++ b/django/db/backends/sqlite3/schema.py
@@ -4,6 +4,7 @@ from decimal import Decimal
from django.apps.registry import Apps
from django.db.backends.base.schema import BaseDatabaseSchemaEditor
from django.db.backends.ddl_references import Statement
+from django.db.models import UniqueConstraint
from django.db.transaction import atomic
from django.db.utils import NotSupportedError
@@ -398,7 +399,13 @@ class DatabaseSchemaEditor(BaseDatabaseSchemaEditor):
self.delete_model(old_field.remote_field.through)
def add_constraint(self, model, constraint):
- self._remake_table(model)
+ if isinstance(constraint, UniqueConstraint) and constraint.condition:
+ super().add_constraint(model, constraint)
+ else:
+ self._remake_table(model)
def remove_constraint(self, model, constraint):
- self._remake_table(model)
+ if isinstance(constraint, UniqueConstraint) and constraint.condition:
+ super().remove_constraint(model, constraint)
+ else:
+ self._remake_table(model)