londiste: automatic db upgrade

this is an experiment...

diff --git a/python/londiste/playback.py b/python/londiste/playback.py
index 499728ad400ae24a878dc281c3d4eb6b5f67bb02..64a81a978b9982ab5f9c6ed02b2d35e045f730c3 100644 (file)
--- a/python/londiste/playback.py
+++ b/python/londiste/playback.py
@@ -296,11 +296,24 @@ class Replicator(CascadedWorker):
             curs.execute("set session_replication_role = 'replica'")
             db.commit()
 
+    code_check_done = 0
+    def check_code(self, db):
+        objs = [
+            skytools.DBFunction("pgq.maint_operations", 0,
+                sql_file = "londiste.maint-upgrade.sql"),
+        ]
+        skytools.db_install(db.cursor(), objs, self.log)
+        db.commit()
+
     def process_remote_batch(self, src_db, tick_id, ev_list, dst_db):
         "All work for a batch.  Entry point from SetConsumer."
 
         # this part can play freely with transactions
 
+        if not self.code_check_done:
+            self.check_code(dst_db)
+            self.code_check_done = 1
+
         self.sync_database_encodings(src_db, dst_db)
         
         self.cur_tick = self._batch_info['tick_id']