From: Mike Bayer <mike_mp@zzzcomputing.com>
Date: Thu, 29 Apr 2010 20:56:17 +0000 (-0400)
Subject: upgrade path
X-Git-Tag: rel_0_1_0~98
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=0117f00282ae3999cdab798110a7556ced4127ba;p=thirdparty%2Fsqlalchemy%2Falembic.git

upgrade path
---

diff --git a/alembic/script.py b/alembic/script.py
index 65fef669..2f33ffb8 100644
--- a/alembic/script.py
+++ b/alembic/script.py
@@ -23,11 +23,14 @@ class ScriptDirectory(object):
                     options.get_main_option('script_location'))
 
     def upgrade_from(self, current_rev):
-        script = self._revision_map[current_rev]
-        while script:
-            yield script.module.upgrade, script.upgrade
-            script = script.nextrev
-
+        head = self._current_head()
+        script = self._revision_map[head]
+        scripts = []
+        while script.upgrade != current_rev:
+            scripts.append((script.module.upgrade, script.upgrade))
+            script = self._revision_map[script.downgrade]
+        return reversed(scripts)
+        
     def downgrade_to(self, destination, current_rev):
         return []
         
@@ -55,6 +58,15 @@ class ScriptDirectory(object):
                 map_[rev.downgrade].nextrev = rev.upgrade
         return map_
     
+    def _current_head(self):
+        current_heads = self._get_heads()
+        if len(current_heads) > 1:
+            raise Exception("Only a single head supported so far...")
+        if current_heads:
+            return current_heads[0]
+        else:
+            return None
+        
     def _get_heads(self):
         # TODO: keep map sorted chronologically
         heads = []
@@ -87,13 +99,7 @@ class ScriptDirectory(object):
                     src, dest)
     
     def generate_rev(self, revid, message):
-        current_heads = self._get_heads()
-        if len(current_heads) > 1:
-            raise Exception("Only a single head supported so far...")
-        if current_heads:
-            current_head = current_heads[0]
-        else:
-            current_head = None
+        current_head = self._current_head()
         filename = "%s.py" % revid
         self.generate_template(
             os.path.join(self.dir, "script.py.mako"),
diff --git a/tests/test_migrations.py b/tests/test_migrations.py
new file mode 100644
index 00000000..1956bb94
--- /dev/null
+++ b/tests/test_migrations.py
@@ -0,0 +1,28 @@
+from tests import clear_staging_env, staging_env, eq_, ne_
+from alembic import util
+
+
+def setup():
+    global env
+    env = staging_env()
+    global a, b, c, d, e
+    a = env.generate_rev(util.rev_id(), None)
+    b = env.generate_rev(util.rev_id(), None)
+    c = env.generate_rev(util.rev_id(), None)
+    d = env.generate_rev(util.rev_id(), None)
+    e = env.generate_rev(util.rev_id(), None)
+    
+def teardown():
+    clear_staging_env()
+
+
+def test_upgrade_path():
+    
+    eq_(
+        list(env.upgrade_from(c.upgrade)),
+        [
+            (d.module.upgrade, d.upgrade),
+            (e.module.upgrade, e.upgrade),
+        ]
+    )
+    
\ No newline at end of file