self.target_cursor.execute("UPDATE media_collections SET recorded_from_year = %s, "
"recorded_to_year = %s WHERE old_code = %s", (from_year, to_year, old_code))
+
+class CollectionsCollectorNormalizer(DataMigrator):
+ """Migrate collector_is_creator flag"""
+
+ implements(IDataMigrator)
+
+ def get_name(self):
+ return "collections:collector"
+
+ def process(self):
+ self.target_cursor.execute("UPDATE media_collections SET collector_is_creator = 0")
+ self.target_cursor.execute("UPDATE media_collections SET collector_is_creator = (collector IN ('=', '=+N', 'ID' 'ID.' 'IDE.' 'IDEM'))")
+ self.stats['flagged'] = self.target_cursor.rowcount
+