server/migractions.py
branchtls-sprint
changeset 1036 593df4919845
parent 1016 26387b836099
child 1263 01152fffd593
equal deleted inserted replaced
1035:776a700560e9 1036:593df4919845
   281             self.cmd_set_property('system.version.'+pack,
   281             self.cmd_set_property('system.version.'+pack,
   282                                   self.config.cube_version(pack))
   282                                   self.config.cube_version(pack))
   283         if not update_database:
   283         if not update_database:
   284             self.commit()
   284             self.commit()
   285             return
   285             return
   286         newcubes_schema = self.config.load_schema()
   286         newcubes_schema = self.config.load_schema(construction_mode='non-strict')
   287         new = set()
   287         new = set()
   288         # execute pre-create files
   288         # execute pre-create files
   289         for pack in reversed(newcubes):
   289         for pack in reversed(newcubes):
   290             self.exec_event_script('precreate', self.config.cube_dir(pack))
   290             self.exec_event_script('precreate', self.config.cube_dir(pack))
   291         # add new entity and relation types
   291         # add new entity and relation types
   315                 
   315                 
   316     def cmd_remove_cube(self, cube):
   316     def cmd_remove_cube(self, cube):
   317         removedcubes = super(ServerMigrationHelper, self).cmd_remove_cube(cube)
   317         removedcubes = super(ServerMigrationHelper, self).cmd_remove_cube(cube)
   318         if not removedcubes:
   318         if not removedcubes:
   319             return
   319             return
   320         print removedcubes
       
   321         fsschema = self.fs_schema
   320         fsschema = self.fs_schema
   322         removedcubes_schema = self.config.load_schema()
   321         removedcubes_schema = self.config.load_schema(construction_mode='non-strict')
   323         reposchema = self.repo.schema
   322         reposchema = self.repo.schema
   324         # execute pre-remove files
   323         # execute pre-remove files
   325         for pack in reversed(removedcubes):
   324         for pack in reversed(removedcubes):
   326             self.exec_event_script('preremove', self.config.cube_dir(pack))
   325             self.exec_event_script('preremove', self.config.cube_dir(pack))
   327         # remove cubes'entity and relation types
   326         # remove cubes'entity and relation types
  1073             msg = rql
  1072             msg = rql
  1074         if self.ask_confirm:
  1073         if self.ask_confirm:
  1075             if not self._h.confirm('execute rql: %s ?' % msg):
  1074             if not self._h.confirm('execute rql: %s ?' % msg):
  1076                 raise StopIteration
  1075                 raise StopIteration
  1077         try:
  1076         try:
  1078             #print rql, kwargs
       
  1079             rset = self._h.rqlcursor.execute(rql, kwargs)
  1077             rset = self._h.rqlcursor.execute(rql, kwargs)
  1080         except Exception, ex:
  1078         except Exception, ex:
  1081             if self._h.confirm('error: %s\nabort?' % ex):
  1079             if self._h.confirm('error: %s\nabort?' % ex):
  1082                 raise
  1080                 raise
  1083             else:
  1081             else: