cubicweb: comparison server/sources/__init_

equal deleted inserted replaced

-:b0a70092946a
+:7f93da785e3a
 # connections handling #####################################################
 def get_connection(self):
 """open and return a connection to the source"""
-raise NotImplementedError()
+raise NotImplementedError(self)
 def check_connection(self, cnx):
 """Check connection validity, return None if the connection is still
 valid else a new connection (called when the connections set using the
 given connection is being attached to a session). Do nothing by default.
 """if the source support CWUser entity type, it should implement
 this method which should return CWUser eid for the given login/password
 if this account is defined in this source and valid login / password is
 given. Else raise `AuthenticationError`
 """
-raise NotImplementedError()
+raise NotImplementedError(self)
 # RQL query api ############################################################
 def syntax_tree_search(self, session, union,
 args=None, cachekey=None, varmap=None, debug=0):
 """return result from this source for a rql query (actually from a rql
 syntax tree and a solution dictionary mapping each used variable to a
 possible type). If cachekey is given, the query necessary to fetch the
 results (but not the results themselves) may be cached using this key.
 """
-raise NotImplementedError()
+raise NotImplementedError(self)
 def flying_insert(self, table, session, union, args=None, varmap=None):
 """similar as .syntax_tree_search, but inserts data in the temporary
 table (on-the-fly if possible, eg for the system source whose the given
 cursor come from). If not possible, inserts all data by calling
 # write modification api ###################################################
 # read-only sources don't have to implement methods below
 def get_extid(self, entity):
 """return the external id for the given newly inserted entity"""
-raise NotImplementedError()
+raise NotImplementedError(self)
 def add_entity(self, session, entity):
 """add a new entity to the source"""
-raise NotImplementedError()
+raise NotImplementedError(self)
 def update_entity(self, session, entity):
 """update an entity in the source"""
-raise NotImplementedError()
+raise NotImplementedError(self)
 def delete_entities(self, session, entities):
 """delete several entities from the source"""
 for entity in entities:
 self.delete_entity(session, entity)
 def delete_entity(self, session, entity):
 """delete an entity from the source"""
-raise NotImplementedError()
+raise NotImplementedError(self)
 def add_relation(self, session, subject, rtype, object):
 """add a relation to the source"""
-raise NotImplementedError()
+raise NotImplementedError(self)
 def add_relations(self, session,  rtype, subj_obj_list):
 """add a relations to the source"""
 # override in derived classes if you feel you can
 # optimize
 for subject, object in subj_obj_list:
 self.add_relation(session, subject, rtype, object)
 def delete_relation(self, session, subject, rtype, object):
 """delete a relation from the source"""
-raise NotImplementedError()
+raise NotImplementedError(self)
 # system source interface #################################################
 def eid_type_source(self, session, eid):
 """return a tuple (type, source, extid) for the entity with id <eid>"""
-raise NotImplementedError()
+raise NotImplementedError(self)
 def create_eid(self, session):
-raise NotImplementedError()
+raise NotImplementedError(self)
 def add_info(self, session, entity, source, extid):
 """add type and source info for an eid into the system table"""
-raise NotImplementedError()
+raise NotImplementedError(self)
 def update_info(self, session, entity, need_fti_update):
 """mark entity as being modified, fulltext reindex if needed"""
-raise NotImplementedError()
+raise NotImplementedError(self)
 def delete_info_multi(self, session, entities, uri):
 """delete system information on deletion of a list of entities with the
 same etype and belinging to the same source
 """
-raise NotImplementedError()
+raise NotImplementedError(self)
 def modified_entities(self, session, etypes, mtime):
 """return a 2-uple:
 * list of (etype, eid) of entities of the given types which have been
 modified since the given timestamp (actually entities whose full text
 index content has changed)
 * list of (etype, eid) of entities of the given types which have been
 deleted since the given timestamp
 """
-raise NotImplementedError()
+raise NotImplementedError(self)
 def index_entity(self, session, entity):
 """create an operation to [re]index textual content of the given entity
 on commit
 """
-raise NotImplementedError()
+raise NotImplementedError(self)
 def fti_unindex_entities(self, session, entities):
 """remove text content for entities from the full text index
 """
-raise NotImplementedError()
+raise NotImplementedError(self)
 def fti_index_entities(self, session, entities):
 """add text content of created/modified entities to the full text index
 """
-raise NotImplementedError()
+raise NotImplementedError(self)
 # sql system source interface #############################################
 def sqlexec(self, session, sql, args=None):
 """execute the query and return its result"""
-raise NotImplementedError()
+raise NotImplementedError(self)
 def temp_table_def(self, selection, solution, table, basemap):
-raise NotImplementedError()
+raise NotImplementedError(self)
 def create_index(self, session, table, column, unique=False):
-raise NotImplementedError()
+raise NotImplementedError(self)
 def drop_index(self, session, table, column, unique=False):
-raise NotImplementedError()
+raise NotImplementedError(self)
 def create_temp_table(self, session, table, schema):
-raise NotImplementedError()
+raise NotImplementedError(self)
 def clean_temp_data(self, session, temptables):
 """remove temporary data, usually associated to temporary tables"""
 pass

branch	stable
changeset 8134	7f93da785e3a
parent 7922	d307c3817782
child 8228	fe53c7e1625f