diff options
| author | Paveł Tyślacki <pavel.tyslacki@gmail.com> | 2018-12-27 22:21:59 +0300 |
|---|---|---|
| committer | Tim Graham <timograham@gmail.com> | 2019-01-12 09:50:20 -0500 |
| commit | b69f8eb04cc8762d3dfd5af5ea1fc58e3f2ebcc3 (patch) | |
| tree | 6662b0cfe731e1912ff157ed46540be87cbec2bc /django/db/backends | |
| parent | 1e837c4b2351c83b1c902314ddfdfa15c63bc60d (diff) | |
Fixed #30062 -- Added support for unique conditional constraints.
Diffstat (limited to 'django/db/backends')
| -rw-r--r-- | django/db/backends/base/schema.py | 50 | ||||
| -rw-r--r-- | django/db/backends/sqlite3/schema.py | 11 |
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) |
