1123 # begin by inserting eid/type/source/extid into the entities table |
1123 # begin by inserting eid/type/source/extid into the entities table |
1124 if extid is not None: |
1124 if extid is not None: |
1125 assert isinstance(extid, str) |
1125 assert isinstance(extid, str) |
1126 extid = b64encode(extid) |
1126 extid = b64encode(extid) |
1127 attrs = {'type': entity.cw_etype, 'eid': entity.eid, 'extid': extid, |
1127 attrs = {'type': entity.cw_etype, 'eid': entity.eid, 'extid': extid, |
1128 'source': 'system', 'asource': source.uri, 'mtime': datetime.utcnow()} |
1128 'source': 'system', 'asource': source.uri} |
1129 self._handle_insert_entity_sql(session, self.sqlgen.insert('entities', attrs), attrs) |
1129 self._handle_insert_entity_sql(session, self.sqlgen.insert('entities', attrs), attrs) |
1130 # insert core relations: is, is_instance_of and cw_source |
1130 # insert core relations: is, is_instance_of and cw_source |
1131 try: |
1131 try: |
1132 self._handle_is_relation_sql(session, 'INSERT INTO is_relation(eid_from,eid_to) VALUES (%s,%s)', |
1132 self._handle_is_relation_sql(session, 'INSERT INTO is_relation(eid_from,eid_to) VALUES (%s,%s)', |
1133 (entity.eid, eschema_eid(session, entity.e_schema))) |
1133 (entity.eid, eschema_eid(session, entity.e_schema))) |