equal
deleted
inserted
replaced
400 @deprecated("[3.7] checkpoint() deprecated. use commit() instead") |
400 @deprecated("[3.7] checkpoint() deprecated. use commit() instead") |
401 def checkpoint(self): |
401 def checkpoint(self): |
402 self.commit() |
402 self.commit() |
403 |
403 |
404 def commit(self): |
404 def commit(self): |
405 self._commit() |
405 txuuid = self._commit() |
406 self.session.set_pool() |
406 self.session.set_pool() |
|
407 return txuuid |
407 |
408 |
408 def rql(self, *args): |
409 def rql(self, *args): |
409 if self._rql is not None: |
410 if self._rql is not None: |
410 return self._rql(*args) |
411 return self._rql(*args) |
411 return self.session.execute(*args) |
412 return self.session.execute(*args) |
560 self._nb_inserted_relations = 0 |
561 self._nb_inserted_relations = 0 |
561 self.rql = session.execute |
562 self.rql = session.execute |
562 # deactivate security |
563 # deactivate security |
563 session.set_read_security(False) |
564 session.set_read_security(False) |
564 session.set_write_security(False) |
565 session.set_write_security(False) |
565 # disable undoing |
|
566 session.undo_actions = frozenset() |
|
567 |
566 |
568 def create_entity(self, etype, **kwargs): |
567 def create_entity(self, etype, **kwargs): |
569 for k, v in kwargs.iteritems(): |
568 for k, v in kwargs.iteritems(): |
570 kwargs[k] = getattr(v, 'eid', v) |
569 kwargs[k] = getattr(v, 'eid', v) |
571 entity, rels = self.metagen.base_etype_dicts(etype) |
570 entity, rels = self.metagen.base_etype_dicts(etype) |