equal
deleted
inserted
replaced
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: |