460 |
460 |
461 def update_info(self, session, entity, need_fti_update): |
461 def update_info(self, session, entity, need_fti_update): |
462 """mark entity as being modified, fulltext reindex if needed""" |
462 """mark entity as being modified, fulltext reindex if needed""" |
463 raise NotImplementedError() |
463 raise NotImplementedError() |
464 |
464 |
465 def delete_info(self, session, entity, uri, extid): |
465 def delete_info_multi(self, session, entities, uri): |
466 """delete system information on deletion of an entity by transfering |
466 """delete system information on deletion of a list of entities with the |
467 record from the entities table to the deleted_entities table |
467 same etype and belinging to the same source |
468 """ |
468 """ |
469 raise NotImplementedError() |
469 raise NotImplementedError() |
470 |
|
471 def delete_info_multi(self, session, entities, uri, extids): |
|
472 """ame as delete_info but accepts a list of entities with |
|
473 the same etype and belinging to the same source. |
|
474 """ |
|
475 for entity, extid in itertools.izip(entities, extids): |
|
476 self.delete_info(session, entity, uri, extid) |
|
477 |
470 |
478 def modified_entities(self, session, etypes, mtime): |
471 def modified_entities(self, session, etypes, mtime): |
479 """return a 2-uple: |
472 """return a 2-uple: |
480 * list of (etype, eid) of entities of the given types which have been |
473 * list of (etype, eid) of entities of the given types which have been |
481 modified since the given timestamp (actually entities whose full text |
474 modified since the given timestamp (actually entities whose full text |