equal
deleted
inserted
replaced
504 |
504 |
505 def create_eid(self, session): |
505 def create_eid(self, session): |
506 self._eid_creation_lock.acquire() |
506 self._eid_creation_lock.acquire() |
507 try: |
507 try: |
508 for sql in self.dbhelper.sqls_increment_sequence('entities_id_seq'): |
508 for sql in self.dbhelper.sqls_increment_sequence('entities_id_seq'): |
509 self.doexec(session, sql) |
509 cursor = self.doexec(session, sql) |
510 return cursor.fetchone()[0] |
510 return cursor.fetchone()[0] |
511 finally: |
511 finally: |
512 self._eid_creation_lock.release() |
512 self._eid_creation_lock.release() |
513 |
513 |
514 def add_info(self, session, entity, source, extid=None): |
514 def add_info(self, session, entity, source, extid=None): |