def _preprocess_mapping(self):
resources = []
for s in self.mapping.subjects():
subject = None
if isinstance(s, URIRef) and s not in resources:
resources.append(s)
for node in self.mapping.objects(subject=s, predicate=rr.subjectMap):
for template in self.mapping.objects(subject=node, predicate=rr.template):
subject = template
for type_class in self.mapping.objects(subject=node, predicate=rr['class']):
self.preprocessed_mapping.add((subject, RDF.type, type_class))
for node in self.mapping.objects(subject=s, predicate=rr.predicateObjectMap):
predicate = None
for predicate_object in self.mapping.objects(subject=node, predicate=rr.predicate):
predicate = predicate_object
for object_map in self.mapping.objects(subject=node, predicate=rr.objectMap):
for reference in self.mapping.objects(subject=object_map, predicate=xrr.reference):
self.preprocessed_mapping.add((subject, predicate, reference))
for node in self.mapping.objects(subject=s, predicate=xrr.logicalSource):
subject_prefix = subject.split('{')[0]
self.logical_sources[subject_prefix] = {}
for query in self.mapping.objects(subject=node, predicate=xrr.query):
self.logical_sources[subject_prefix]['query'] = query
for iterator in self.mapping.objects(subject=node, predicate=rml.iterator):
self.logical_sources[subject_prefix]['iterator'] = iterator
评论列表
文章目录
