1108 self._append_to_entities(sql, attrs) |
1108 self._append_to_entities(sql, attrs) |
1109 |
1109 |
1110 def _handle_source_relation_sql(self, session, sql, attrs): |
1110 def _handle_source_relation_sql(self, session, sql, attrs): |
1111 self._append_to_entities(sql, attrs) |
1111 self._append_to_entities(sql, attrs) |
1112 |
1112 |
1113 # XXX add_info is similar to the one in NativeSQLSource. It is rewritten |
1113 # add_info is _copypasted_ from the one in NativeSQLSource. We want it |
1114 # here to correctly used the _handle_xxx of the SQLGenSourceWrapper. This |
1114 # there because it will use the _handlers of the SQLGenSourceWrapper, which |
1115 # part should be rewritten in a more clearly way. |
1115 # are not like the ones in the native source. |
1116 def add_info(self, session, entity, source, extid, complete): |
1116 def add_info(self, session, entity, source, extid, complete): |
1117 """add type and source info for an eid into the system table""" |
1117 """add type and source info for an eid into the system table""" |
1118 # begin by inserting eid/type/source/extid into the entities table |
1118 # begin by inserting eid/type/source/extid into the entities table |
1119 if extid is not None: |
1119 if extid is not None: |
1120 assert isinstance(extid, str) |
1120 assert isinstance(extid, str) |