optimizer.py 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361
  1. from __future__ import unicode_literals
  2. from django.db import migrations
  3. from django.utils import six
  4. class MigrationOptimizer(object):
  5. """
  6. Powers the optimization process, where you provide a list of Operations
  7. and you are returned a list of equal or shorter length - operations
  8. are merged into one if possible.
  9. For example, a CreateModel and an AddField can be optimized into a
  10. new CreateModel, and CreateModel and DeleteModel can be optimized into
  11. nothing.
  12. """
  13. def optimize(self, operations, app_label=None):
  14. """
  15. Main optimization entry point. Pass in a list of Operation instances,
  16. get out a new list of Operation instances.
  17. Unfortunately, due to the scope of the optimization (two combinable
  18. operations might be separated by several hundred others), this can't be
  19. done as a peephole optimization with checks/output implemented on
  20. the Operations themselves; instead, the optimizer looks at each
  21. individual operation and scans forwards in the list to see if there
  22. are any matches, stopping at boundaries - operations which can't
  23. be optimized over (RunSQL, operations on the same field/model, etc.)
  24. The inner loop is run until the starting list is the same as the result
  25. list, and then the result is returned. This means that operation
  26. optimization must be stable and always return an equal or shorter list.
  27. The app_label argument is optional, but if you pass it you'll get more
  28. efficient optimization.
  29. """
  30. # Internal tracking variable for test assertions about # of loops
  31. self._iterations = 0
  32. while True:
  33. result = self.optimize_inner(operations, app_label)
  34. self._iterations += 1
  35. if result == operations:
  36. return result
  37. operations = result
  38. def optimize_inner(self, operations, app_label=None):
  39. """
  40. Inner optimization loop.
  41. """
  42. new_operations = []
  43. for i, operation in enumerate(operations):
  44. # Compare it to each operation after it
  45. for j, other in enumerate(operations[i + 1:]):
  46. result = self.reduce(operation, other, operations[i + 1:i + j + 1])
  47. if result is not None:
  48. # Optimize! Add result, then remaining others, then return
  49. new_operations.extend(result)
  50. new_operations.extend(operations[i + 1:i + 1 + j])
  51. new_operations.extend(operations[i + j + 2:])
  52. return new_operations
  53. if not self.can_optimize_through(operation, other, app_label):
  54. new_operations.append(operation)
  55. break
  56. else:
  57. new_operations.append(operation)
  58. return new_operations
  59. #### REDUCTION ####
  60. def reduce(self, operation, other, in_between=None):
  61. """
  62. Either returns a list of zero, one or two operations,
  63. or None, meaning this pair cannot be optimized.
  64. """
  65. submethods = [
  66. (
  67. migrations.CreateModel,
  68. migrations.DeleteModel,
  69. self.reduce_model_create_delete,
  70. ),
  71. (
  72. migrations.AlterModelTable,
  73. migrations.DeleteModel,
  74. self.reduce_model_alter_delete,
  75. ),
  76. (
  77. migrations.AlterUniqueTogether,
  78. migrations.DeleteModel,
  79. self.reduce_model_alter_delete,
  80. ),
  81. (
  82. migrations.AlterIndexTogether,
  83. migrations.DeleteModel,
  84. self.reduce_model_alter_delete,
  85. ),
  86. (
  87. migrations.CreateModel,
  88. migrations.RenameModel,
  89. self.reduce_model_create_rename,
  90. ),
  91. (
  92. migrations.RenameModel,
  93. migrations.RenameModel,
  94. self.reduce_model_rename_self,
  95. ),
  96. (
  97. migrations.CreateModel,
  98. migrations.AddField,
  99. self.reduce_create_model_add_field,
  100. ),
  101. (
  102. migrations.CreateModel,
  103. migrations.AlterField,
  104. self.reduce_create_model_alter_field,
  105. ),
  106. (
  107. migrations.CreateModel,
  108. migrations.RemoveField,
  109. self.reduce_create_model_remove_field,
  110. ),
  111. (
  112. migrations.AddField,
  113. migrations.AlterField,
  114. self.reduce_add_field_alter_field,
  115. ),
  116. (
  117. migrations.AddField,
  118. migrations.RemoveField,
  119. self.reduce_add_field_delete_field,
  120. ),
  121. (
  122. migrations.AlterField,
  123. migrations.RemoveField,
  124. self.reduce_alter_field_delete_field,
  125. ),
  126. (
  127. migrations.AddField,
  128. migrations.RenameField,
  129. self.reduce_add_field_rename_field,
  130. ),
  131. (
  132. migrations.AlterField,
  133. migrations.RenameField,
  134. self.reduce_alter_field_rename_field,
  135. ),
  136. (
  137. migrations.CreateModel,
  138. migrations.RenameField,
  139. self.reduce_create_model_rename_field,
  140. ),
  141. (
  142. migrations.RenameField,
  143. migrations.RenameField,
  144. self.reduce_rename_field_self,
  145. ),
  146. ]
  147. for ia, ib, om in submethods:
  148. if isinstance(operation, ia) and isinstance(other, ib):
  149. return om(operation, other, in_between or [])
  150. return None
  151. def model_to_key(self, model):
  152. """
  153. Takes either a model class or a "appname.ModelName" string
  154. and returns (appname, modelname)
  155. """
  156. if isinstance(model, six.string_types):
  157. return model.split(".", 1)
  158. else:
  159. return (
  160. model._meta.app_label,
  161. model._meta.object_name,
  162. )
  163. def reduce_model_create_delete(self, operation, other, in_between):
  164. """
  165. Folds a CreateModel and a DeleteModel into nothing.
  166. """
  167. if (operation.name.lower() == other.name.lower() and
  168. not operation.options.get("proxy", False)):
  169. return []
  170. def reduce_model_alter_delete(self, operation, other, in_between):
  171. """
  172. Folds an AlterModelSomething and a DeleteModel into just delete.
  173. """
  174. if operation.name.lower() == other.name.lower():
  175. return [other]
  176. def reduce_model_create_rename(self, operation, other, in_between):
  177. """
  178. Folds a model rename into its create
  179. """
  180. if operation.name.lower() == other.old_name.lower():
  181. return [
  182. migrations.CreateModel(
  183. other.new_name,
  184. fields=operation.fields,
  185. options=operation.options,
  186. bases=operation.bases,
  187. )
  188. ]
  189. def reduce_model_rename_self(self, operation, other, in_between):
  190. """
  191. Folds a model rename into another one
  192. """
  193. if operation.new_name.lower() == other.old_name.lower():
  194. return [
  195. migrations.RenameModel(
  196. operation.old_name,
  197. other.new_name,
  198. )
  199. ]
  200. def reduce_create_model_add_field(self, operation, other, in_between):
  201. if operation.name.lower() == other.model_name.lower():
  202. # Don't allow optimisations of FKs through models they reference
  203. if hasattr(other.field, "rel") and other.field.rel:
  204. for between in in_between:
  205. # Check that it doesn't point to the model
  206. app_label, object_name = self.model_to_key(other.field.rel.to)
  207. if between.references_model(object_name, app_label):
  208. return None
  209. # Check that it's not through the model
  210. if getattr(other.field.rel, "through", None):
  211. app_label, object_name = self.model_to_key(other.field.rel.through)
  212. if between.references_model(object_name, app_label):
  213. return None
  214. # OK, that's fine
  215. return [
  216. migrations.CreateModel(
  217. operation.name,
  218. fields=operation.fields + [(other.name, other.field)],
  219. options=operation.options,
  220. bases=operation.bases,
  221. )
  222. ]
  223. def reduce_create_model_alter_field(self, operation, other, in_between):
  224. if operation.name.lower() == other.model_name.lower():
  225. return [
  226. migrations.CreateModel(
  227. operation.name,
  228. fields=[
  229. (n, other.field if n == other.name else v)
  230. for n, v in operation.fields
  231. ],
  232. options=operation.options,
  233. bases=operation.bases,
  234. )
  235. ]
  236. def reduce_create_model_rename_field(self, operation, other, in_between):
  237. if operation.name.lower() == other.model_name.lower():
  238. return [
  239. migrations.CreateModel(
  240. operation.name,
  241. fields=[
  242. (other.new_name if n == other.old_name else n, v)
  243. for n, v in operation.fields
  244. ],
  245. options=operation.options,
  246. bases=operation.bases,
  247. )
  248. ]
  249. def reduce_create_model_remove_field(self, operation, other, in_between):
  250. if operation.name.lower() == other.model_name.lower():
  251. return [
  252. migrations.CreateModel(
  253. operation.name,
  254. fields=[
  255. (n, v)
  256. for n, v in operation.fields
  257. if n.lower() != other.name.lower()
  258. ],
  259. options=operation.options,
  260. bases=operation.bases,
  261. )
  262. ]
  263. def reduce_add_field_alter_field(self, operation, other, in_between):
  264. if operation.model_name.lower() == other.model_name.lower() and operation.name.lower() == other.name.lower():
  265. return [
  266. migrations.AddField(
  267. model_name=operation.model_name,
  268. name=operation.name,
  269. field=other.field,
  270. )
  271. ]
  272. def reduce_add_field_delete_field(self, operation, other, in_between):
  273. if operation.model_name.lower() == other.model_name.lower() and operation.name.lower() == other.name.lower():
  274. return []
  275. def reduce_alter_field_delete_field(self, operation, other, in_between):
  276. if operation.model_name.lower() == other.model_name.lower() and operation.name.lower() == other.name.lower():
  277. return [other]
  278. def reduce_add_field_rename_field(self, operation, other, in_between):
  279. if operation.model_name.lower() == other.model_name.lower() and operation.name.lower() == other.old_name.lower():
  280. return [
  281. migrations.AddField(
  282. model_name=operation.model_name,
  283. name=other.new_name,
  284. field=operation.field,
  285. )
  286. ]
  287. def reduce_alter_field_rename_field(self, operation, other, in_between):
  288. if operation.model_name.lower() == other.model_name.lower() and operation.name.lower() == other.old_name.lower():
  289. return [
  290. other,
  291. migrations.AlterField(
  292. model_name=operation.model_name,
  293. name=other.new_name,
  294. field=operation.field,
  295. ),
  296. ]
  297. def reduce_rename_field_self(self, operation, other, in_between):
  298. if operation.model_name.lower() == other.model_name.lower() and operation.new_name.lower() == other.old_name.lower():
  299. return [
  300. migrations.RenameField(
  301. operation.model_name,
  302. operation.old_name,
  303. other.new_name,
  304. ),
  305. ]
  306. #### THROUGH CHECKS ####
  307. def can_optimize_through(self, operation, other, app_label=None):
  308. """
  309. Returns True if it's possible to optimize 'operation' with something
  310. the other side of 'other'. This is possible if, for example, they
  311. affect different models.
  312. """
  313. MODEL_LEVEL_OPERATIONS = (
  314. migrations.CreateModel,
  315. migrations.AlterModelTable,
  316. migrations.AlterUniqueTogether,
  317. migrations.AlterIndexTogether,
  318. )
  319. FIELD_LEVEL_OPERATIONS = (
  320. migrations.AddField,
  321. migrations.AlterField,
  322. )
  323. # If it's a model level operation, let it through if there's
  324. # nothing that looks like a reference to us in 'other'.
  325. if isinstance(operation, MODEL_LEVEL_OPERATIONS):
  326. if not other.references_model(operation.name, app_label):
  327. return True
  328. # If it's field level, only let it through things that don't reference
  329. # the field (which includes not referencing the model)
  330. if isinstance(operation, FIELD_LEVEL_OPERATIONS):
  331. if not other.references_field(operation.model_name, operation.name, app_label):
  332. return True
  333. return False