schema.py 4.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112
  1. from django.db.backends.postgresql_psycopg2.schema import DatabaseSchemaEditor
  2. class PostGISSchemaEditor(DatabaseSchemaEditor):
  3. geom_index_type = 'GIST'
  4. geom_index_ops = 'GIST_GEOMETRY_OPS'
  5. geom_index_ops_nd = 'GIST_GEOMETRY_OPS_ND'
  6. sql_add_geometry_column = "SELECT AddGeometryColumn(%(table)s, %(column)s, %(srid)s, %(geom_type)s, %(dim)s)"
  7. sql_drop_geometry_column = "SELECT DropGeometryColumn(%(table)s, %(column)s)"
  8. sql_alter_geometry_column_not_null = "ALTER TABLE %(table)s ALTER COLUMN %(column)s SET NOT NULL"
  9. sql_add_spatial_index = "CREATE INDEX %(index)s ON %(table)s USING %(index_type)s (%(column)s %(ops)s)"
  10. sql_clear_geometry_columns = "DELETE FROM geometry_columns WHERE f_table_name = %(table)s"
  11. def __init__(self, *args, **kwargs):
  12. super(PostGISSchemaEditor, self).__init__(*args, **kwargs)
  13. self.geometry_sql = []
  14. def geo_quote_name(self, name):
  15. return self.connection.ops.geo_quote_name(name)
  16. def column_sql(self, model, field, include_default=False):
  17. from django.contrib.gis.db.models.fields import GeometryField
  18. if not isinstance(field, GeometryField):
  19. return super(PostGISSchemaEditor, self).column_sql(model, field, include_default)
  20. if field.geography or self.connection.ops.geometry:
  21. # Geography and Geometry (PostGIS 2.0+) columns are
  22. # created normally.
  23. column_sql = super(PostGISSchemaEditor, self).column_sql(model, field, include_default)
  24. else:
  25. column_sql = None, None
  26. # Geometry columns are created by the `AddGeometryColumn`
  27. # stored procedure.
  28. self.geometry_sql.append(
  29. self.sql_add_geometry_column % {
  30. "table": self.geo_quote_name(model._meta.db_table),
  31. "column": self.geo_quote_name(field.column),
  32. "srid": field.srid,
  33. "geom_type": self.geo_quote_name(field.geom_type),
  34. "dim": field.dim,
  35. }
  36. )
  37. if not field.null:
  38. self.geometry_sql.append(
  39. self.sql_alter_geometry_column_not_null % {
  40. "table": self.quote_name(model._meta.db_table),
  41. "column": self.quote_name(field.column),
  42. }
  43. )
  44. if field.spatial_index:
  45. # Spatial indexes created the same way for both Geometry and
  46. # Geography columns.
  47. # PostGIS 2.0 does not support GIST_GEOMETRY_OPS. So, on 1.5
  48. # we use GIST_GEOMETRY_OPS, on 2.0 we use either "nd" ops
  49. # which are fast on multidimensional cases, or just plain
  50. # gist index for the 2d case.
  51. if field.geography:
  52. index_ops = ''
  53. elif self.connection.ops.geometry:
  54. if field.dim > 2:
  55. index_ops = self.geom_index_ops_nd
  56. else:
  57. index_ops = ''
  58. else:
  59. index_ops = self.geom_index_ops
  60. self.geometry_sql.append(
  61. self.sql_add_spatial_index % {
  62. "index": self.quote_name('%s_%s_id' % (model._meta.db_table, field.column)),
  63. "table": self.quote_name(model._meta.db_table),
  64. "column": self.quote_name(field.column),
  65. "index_type": self.geom_index_type,
  66. "ops": index_ops,
  67. }
  68. )
  69. return column_sql
  70. def create_model(self, model):
  71. super(PostGISSchemaEditor, self).create_model(model)
  72. # Create geometry columns
  73. for sql in self.geometry_sql:
  74. self.execute(sql)
  75. self.geometry_sql = []
  76. def delete_model(self, model):
  77. super(PostGISSchemaEditor, self).delete_model(model)
  78. self.execute(self.sql_clear_geometry_columns % {
  79. "table": self.geo_quote_name(model._meta.db_table),
  80. })
  81. def add_field(self, model, field):
  82. super(PostGISSchemaEditor, self).add_field(model, field)
  83. # Create geometry columns
  84. for sql in self.geometry_sql:
  85. self.execute(sql)
  86. self.geometry_sql = []
  87. def remove_field(self, model, field):
  88. from django.contrib.gis.db.models.fields import GeometryField
  89. if not isinstance(field, GeometryField) or \
  90. self.connection.ops.spatial_version > (2, 0) or \
  91. field.geography:
  92. super(PostGISSchemaEditor, self).remove_field(model, field)
  93. else:
  94. self.execute(
  95. self.sql_drop_geometry_column % {
  96. "table": self.geo_quote_name(model._meta.db_table),
  97. "column": self.geo_quote_name(field.column),
  98. }
  99. )