238 |
238 |
239 def get_source(self, uri, source_config): |
239 def get_source(self, uri, source_config): |
240 source_config['uri'] = uri |
240 source_config['uri'] = uri |
241 return get_source(source_config, self.schema, self) |
241 return get_source(source_config, self.schema, self) |
242 |
242 |
243 def set_schema(self, schema, resetvreg=True): |
243 def set_schema(self, schema, resetvreg=True, rebuildinfered=True): |
244 schema.rebuild_infered_relations() |
244 if rebuildinfered: |
|
245 schema.rebuild_infered_relations() |
245 self.info('set schema %s %#x', schema.name, id(schema)) |
246 self.info('set schema %s %#x', schema.name, id(schema)) |
246 self.debug(', '.join(sorted(str(e) for e in schema.entities()))) |
247 self.debug(', '.join(sorted(str(e) for e in schema.entities()))) |
247 self.querier.set_schema(schema) |
248 self.querier.set_schema(schema) |
248 for source in self.sources: |
249 for source in self.sources: |
249 source.set_schema(schema) |
250 source.set_schema(schema) |