equal
deleted
inserted
replaced
443 self._query_cache.clear() |
443 self._query_cache.clear() |
444 entity.cw_clear_all_caches() |
444 entity.cw_clear_all_caches() |
445 |
445 |
446 def delete_entity(self, session, entity): |
446 def delete_entity(self, session, entity): |
447 """delete an entity from the source""" |
447 """delete an entity from the source""" |
448 if session.deleted_in_transaction (self.eid): |
448 if session.deleted_in_transaction(self.eid): |
449 # source is being deleted, don't propagate |
449 # source is being deleted, don't propagate |
450 self._query_cache.clear() |
450 self._query_cache.clear() |
451 return |
451 return |
452 cu = session.cnxset[self.uri] |
452 cu = session.cnxset[self.uri] |
453 cu.execute('DELETE %s X WHERE X eid %%(x)s' % entity.__regid__, |
453 cu.execute('DELETE %s X WHERE X eid %%(x)s' % entity.__regid__, |
464 session.entity_from_eid(subject).cw_clear_all_caches() |
464 session.entity_from_eid(subject).cw_clear_all_caches() |
465 session.entity_from_eid(object).cw_clear_all_caches() |
465 session.entity_from_eid(object).cw_clear_all_caches() |
466 |
466 |
467 def delete_relation(self, session, subject, rtype, object): |
467 def delete_relation(self, session, subject, rtype, object): |
468 """delete a relation from the source""" |
468 """delete a relation from the source""" |
469 if session.deleted_in_transaction (self.eid): |
469 if session.deleted_in_transaction(self.eid): |
470 # source is being deleted, don't propagate |
470 # source is being deleted, don't propagate |
471 self._query_cache.clear() |
471 self._query_cache.clear() |
472 return |
472 return |
473 cu = session.cnxset[self.uri] |
473 cu = session.cnxset[self.uri] |
474 cu.execute('DELETE X %s Y WHERE X eid %%(x)s, Y eid %%(y)s' % rtype, |
474 cu.execute('DELETE X %s Y WHERE X eid %%(x)s, Y eid %%(y)s' % rtype, |