800 

   800 

   801     def relate(self, eid_from, rtype, eid_to, **kwargs):

   801     def relate(self, eid_from, rtype, eid_to, **kwargs):

   802         assert not rtype.startswith('reverse_')

   802         assert not rtype.startswith('reverse_')

   803         self.add_relation(self.session, eid_from, rtype, eid_to,

   803         self.add_relation(self.session, eid_from, rtype, eid_to,

   804                           self.rschema(rtype).inlined)

   804                           self.rschema(rtype).inlined)

   805         self._nb_inserted_relations += 1

   808         self._nb_inserted_relations += 1

   806 

   809 

   807     @property

   810     @property

   808     def nb_inserted_entities(self):

   811     def nb_inserted_entities(self):

   809         return self._nb_inserted_entities

   812         return self._nb_inserted_entities

   926         if subj_eid is None or obj_eid is None:

   929         if subj_eid is None or obj_eid is None:

   927             return

   930             return

   928         # XXX Could subjtype be inferred ?

   931         # XXX Could subjtype be inferred ?

   929         self.source.add_relation(self.session, subj_eid, rtype, obj_eid,

   932         self.source.add_relation(self.session, subj_eid, rtype, obj_eid,

   930                                  self.rschema(rtype).inlined, **kwargs)

   933                                  self.rschema(rtype).inlined, **kwargs)

   931 

   937 

   932     def drop_indexes(self, etype):

   938     def drop_indexes(self, etype):

   933         """Drop indexes for a given entity type"""

   939         """Drop indexes for a given entity type"""

   934         if etype not in self.indexes_etypes:

   940         if etype not in self.indexes_etypes:

   935             cu = self.session.cnxset['system']

   941             cu = self.session.cnxset['system']