From 26e6263613de15c6054cd82f4b69edadf672ed87 Mon Sep 17 00:00:00 2001
From: Oliver Gorwits <oliver@cpan.org>
Date: Thu, 20 Dec 2012 13:29:54 +0000
Subject: [PATCH] upgrade db incrementally

---
 Netdisco/bin/netdisco-db-deploy | 15 +++++++++++++--
 1 file changed, 13 insertions(+), 2 deletions(-)

diff --git a/Netdisco/bin/netdisco-db-deploy b/Netdisco/bin/netdisco-db-deploy
index 7e0f49a4..7f8c2068 100755
--- a/Netdisco/bin/netdisco-db-deploy
+++ b/Netdisco/bin/netdisco-db-deploy
@@ -63,12 +63,23 @@ try {
       $dbh->selectrow_arrayref("SELECT * FROM device WHERE 0 = 1");
     });
 
-    $schema->_set_db_version(2)
+    $schema->_set_db_version({version => 2})
       if $schema->get_db_version == 1;
     $schema->storage->disconnect;
 };
 
 # upgrade from whatever dbix_class_schema_versions says, to $VERSION
-$schema->txn_do(sub { $schema->upgrade });
+my $db_version = $schema->get_db_version;
+my $target_version = $schema->schema_version;
+
+# one step at a time, in case user has applied local changes already
+for (my $i = $db_version; $i < $target_version; $i++) {
+    try {
+        $schema->upgrade_single_step($i, $i + 1);
+    }
+    catch {
+        $schema->_set_db_version({version => $i + 1});
+    }
+}
 
 exit 0;