Skip to content
This repository has been archived by the owner on Jan 3, 2021. It is now read-only.

Commit

Permalink
Hacked in some stuff for D2R Server 0.3 ... refactor later
Browse files Browse the repository at this point in the history
  • Loading branch information
cyganiak committed Sep 1, 2006
1 parent 1ed6866 commit cede6ee
Show file tree
Hide file tree
Showing 2 changed files with 148 additions and 22 deletions.
124 changes: 111 additions & 13 deletions src/de/fuberlin/wiwiss/d2rq/GraphD2RQ.java
View file
@@ -1,33 +1,41 @@
/*
(c) Copyright 2004 by Chris Bizer (chris@bizer.de)
*/

package de.fuberlin.wiwiss.d2rq;

import java.lang.reflect.Constructor;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;

import com.hp.hpl.jena.graph.Capabilities;
import com.hp.hpl.jena.graph.Graph;
import com.hp.hpl.jena.graph.Node;
import com.hp.hpl.jena.graph.Triple;
import com.hp.hpl.jena.graph.TripleMatch;
import com.hp.hpl.jena.graph.impl.GraphBase;
import com.hp.hpl.jena.graph.query.QueryHandler;
import com.hp.hpl.jena.graph.query.SimpleQueryHandler;
import com.hp.hpl.jena.rdf.model.Model;
import com.hp.hpl.jena.rdf.model.ModelFactory;
import com.hp.hpl.jena.rdf.model.Resource;
import com.hp.hpl.jena.util.iterator.ExtendedIterator;
import com.hp.hpl.jena.vocabulary.RDF;
import com.hp.hpl.jena.vocabulary.RDFS;

import de.fuberlin.wiwiss.d2rq.find.FindQuery;
import de.fuberlin.wiwiss.d2rq.find.QueryContext;
import de.fuberlin.wiwiss.d2rq.helpers.D2RQUtil;
import de.fuberlin.wiwiss.d2rq.helpers.Logger;
import de.fuberlin.wiwiss.d2rq.map.D2RQ;
import de.fuberlin.wiwiss.d2rq.map.Database;
import de.fuberlin.wiwiss.d2rq.map.FixedNodeMaker;
import de.fuberlin.wiwiss.d2rq.map.NodeMaker;
import de.fuberlin.wiwiss.d2rq.map.PropertyBridge;
import de.fuberlin.wiwiss.d2rq.map.URIMatchPolicy;
import de.fuberlin.wiwiss.d2rq.parser.MapParser;
import de.fuberlin.wiwiss.d2rq.rdql.D2RQQueryHandler;

Expand All @@ -38,15 +46,9 @@
* ontologies and relational data models. More information about D2RQ is found
* at: http://www.wiwiss.fu-berlin.de/suhl/bizer/d2rq/
*
* <p>History:<br>
* 06-06-2004: Initial version of this class.<br>
* 08-03-2004: New query algorithm, moved map building to MapParser
*
* @author Chris Bizer chris@bizer.de
* @author Richard Cyganiak <richard@cyganiak.de>
* @version V0.2
*
* @see de.fuberlin.wiwiss.d2rq.D2RQCapabilities
* @author Richard Cyganiak (richard@cyganiak.de)
* @version $Id: GraphD2RQ.java,v 1.22 2006/09/01 08:49:27 cyganiak Exp $
*/
public class GraphD2RQ extends GraphBase implements Graph {
static private boolean usingD2RQQueryHandler=false;
Expand All @@ -59,7 +61,7 @@ public class GraphD2RQ extends GraphBase implements Graph {
/** Collection of all PropertyBridges definded in the mapping file */
private List propertyBridges;
private Map propertyBridgesByDatabase;

public static boolean isUsingD2RQQueryHandler() {
return usingD2RQQueryHandler;
}
Expand Down Expand Up @@ -91,6 +93,9 @@ public GraphD2RQ(Model mapModel, String baseURIForData) throws D2RQException {
this.propertyBridges = sortPropertyBridges(parser.getPropertyBridges());
this.processingInstructions = parser.getProcessingInstructions();
this.propertyBridgesByDatabase=D2RQUtil.makeDatabaseMapFromPropertyBridges(propertyBridges);
// TODO clean up
this.propertyBridgesByClassMap = parser.propertyBridgesByClassMap();
this.nodeMakersByClassMap = parser.NodeMakersByClassMap();
}

/**
Expand Down Expand Up @@ -191,4 +196,97 @@ public ArrayList propertyBridgesForTriple(Triple t, Database db) {
public Map getPropertyBridgesByDatabase() {
return propertyBridgesByDatabase;
}

/**
* TODO This section was done as a quick hack for D2R Server 0.3 and really shouldn't be here
*/
private String inventoryBaseURI = null;
private String directoryURI = null;
private Map propertyBridgesByClassMap;
private Map nodeMakersByClassMap;
private Map classMapInventoryBridges = new HashMap();
private Map classMapNodeMakers = new HashMap();

public void initInventory(String directoryURI, String inventoryBaseURI) {
this.directoryURI = directoryURI;
this.inventoryBaseURI = inventoryBaseURI;
Iterator it = this.propertyBridgesByClassMap.entrySet().iterator();
while (it.hasNext()) {
Entry entry = (Entry) it.next();
Node classMap = (Node) entry.getKey();
List propertyBridges = (List) entry.getValue();
List inventoryBridges = new ArrayList();
Iterator bridgeIt = propertyBridges.iterator();
while (bridgeIt.hasNext()) {
PropertyBridge bridge = (PropertyBridge) bridgeIt.next();
if (bridge.couldFit(new Triple(Node.ANY, RDF.Nodes.type, Node.ANY),
new QueryContext())) {
inventoryBridges.add(bridge);
}
if (bridge.couldFit(new Triple(Node.ANY, RDFS.label.asNode(), Node.ANY),
new QueryContext())) {
inventoryBridges.add(bridge);
}
}
NodeMaker classMapNodeMaker = new FixedNodeMaker(Node.createURI(
this.inventoryBaseURI + toClassMapName(classMap)));
NodeMaker seeAlsoNodeMaker = new FixedNodeMaker(RDFS.seeAlso.asNode());
if (!propertyBridges.isEmpty()) {
PropertyBridge aBridge = (PropertyBridge) propertyBridges.iterator().next();
inventoryBridges.add(new PropertyBridge(
Node.createAnon(),
classMapNodeMaker,
seeAlsoNodeMaker,
aBridge.getSubjectMaker(),
aBridge.getDatabase(),
new URIMatchPolicy()));
}
this.classMapInventoryBridges.put(toClassMapName(classMap), inventoryBridges);
this.classMapNodeMakers.put(toClassMapName(classMap),
(NodeMaker) this.nodeMakersByClassMap.get(classMap));
}
}

private String toClassMapName(Node classMap) {
return classMap.getLocalName();
}

public Collection classMapNames() {
return this.classMapInventoryBridges.keySet();
}

public Model classMapInventory(String classMapName) {
List inventoryBridges = (List) this.classMapInventoryBridges.get(classMapName);
if (inventoryBridges == null) {
return null;
}
Model result = ModelFactory.createDefaultModel();
// TODO Handle prefixes in a smart way -- no time now
// result.setNsPrefixes(this.getPrefixMapping());
result.getGraph().getBulkUpdateHandler().add(
new FindQuery(Triple.ANY, inventoryBridges).iterator());
Resource classMap = result.getResource(this.inventoryBaseURI + classMapName);
Resource directory = result.createResource(this.directoryURI);
classMap.addProperty(RDFS.seeAlso, directory);
classMap.addProperty(RDFS.label, "List of all instances: " + classMapName);
directory.addProperty(RDFS.label, "D2R Server contents");
return result;
}

public Collection classMapNamesForResource(Node resource) {
if (!resource.isURI()) {
return Collections.EMPTY_LIST;
}
List results = new ArrayList();
Iterator it = this.classMapNodeMakers.entrySet().iterator();
while (it.hasNext()) {
Entry entry = (Entry) it.next();
String classMapName = (String) entry.getKey();
NodeMaker nodeMaker = (NodeMaker) entry.getValue();
if (nodeMaker.couldFit(resource)) {
results.add(classMapName);
}
}
return results;
}
}
46 changes: 37 additions & 9 deletions src/de/fuberlin/wiwiss/d2rq/parser/MapParser.java
View file
@@ -1,12 +1,11 @@
/*
* $Id: MapParser.java,v 1.5 2006/08/31 01:50:47 cyganiak Exp $
*/
package de.fuberlin.wiwiss.d2rq.parser;

import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;

Expand Down Expand Up @@ -36,7 +35,7 @@
* of a D2RQ mapping file. Checks the map for consistency.
*
* @author Richard Cyganiak (richard@cyganiak.de)
* @version $Id: MapParser.java,v 1.5 2006/08/31 01:50:47 cyganiak Exp $
* @version $Id: MapParser.java,v 1.6 2006/09/01 08:49:27 cyganiak Exp $
*/
public class MapParser {
private Model model;
Expand Down Expand Up @@ -209,21 +208,24 @@ private void parsePropertyBridges() {
while (it.hasNext()) {
Triple t = (Triple) it.next();
Node propBridgeNode = t.getSubject();
NodeMakerSpec subjectSpec = classMapSpecForNode(t.getObject());
Node classMapNode = t.getObject();
NodeMakerSpec subjectSpec = classMapSpecForNode(classMapNode);
if (subjectSpec == null) {
Logger.instance().error("d2rq:belongsToClassMap for " +
t.getSubject() + " is no d2rq:ClassMap");
propBridgeNode + " is no d2rq:ClassMap");
return;
}
if (this.nodesToPropertyBridges.containsKey(propBridgeNode)) {
Logger.instance().error("Multiple d2rq:belongsToClassMap in " + propBridgeNode);
return;
}
createPropertyBridge(
PropertyBridge bridge = createPropertyBridge(
classMapNode,
propBridgeNode,
subjectSpec,
NodeMakerSpec.createFixed(findPropertyForBridge(propBridgeNode)),
buildObjectSpec(propBridgeNode, subjectSpec.database()));
registerBridgeForClassMap(classMapNode, bridge);
}
it = this.graph.find(Node.ANY, RDF.Nodes.type, D2RQ.DatatypePropertyBridge);
while (it.hasNext()) {
Expand Down Expand Up @@ -344,7 +346,7 @@ private boolean isObjectPropertyBridge(Node node) {
return this.graph.contains(node, RDF.Nodes.type, D2RQ.ObjectPropertyBridge);
}

private PropertyBridge createPropertyBridge(Node node,
private PropertyBridge createPropertyBridge(Node classMap, Node node,
NodeMakerSpec subjectsSpec, NodeMakerSpec predicatesSpec, NodeMakerSpec objectsSpec) {
URIMatchPolicy policy = new URIMatchPolicy();
policy.setSubjectBasedOnURIColumn(subjectsSpec.isURIColumnSpec());
Expand All @@ -358,6 +360,7 @@ private PropertyBridge createPropertyBridge(Node node,
subjects, predicates, objects,
subjectsSpec.database(), policy);
this.nodesToPropertyBridges.put(node, bridge);
registerBridgeForClassMap(classMap, bridge);
return bridge;
}

Expand Down Expand Up @@ -402,6 +405,7 @@ private void parseAdditionalProperties() {
continue;
}
createPropertyBridge(
t.getSubject(),
t.getObject(),
subjectSpec,
NodeMakerSpec.createFixed(findOneNode(t.getObject(), D2RQ.propertyName)),
Expand Down Expand Up @@ -429,7 +433,7 @@ private void addRDFTypePropertyBridge(Node toClassMap, Node rdfsClass) {
rdfsClass + ", is no d2rq:ClassMap");
return;
}
createPropertyBridge(Node.createAnon(),
createPropertyBridge(toClassMap, Node.createAnon(),
spec,
NodeMakerSpec.createFixed(RDF.Nodes.type),
NodeMakerSpec.createFixed(rdfsClass));
Expand Down Expand Up @@ -577,4 +581,28 @@ private String ensureIsAbsolute(String uriPattern) {
}
return uriPattern;
}

/**
* TODO This section was added as a quick hack for D2R Server 0.3 and should probably not be here
*/
private Map nodesToClassMapBridgeLists = new HashMap();
private Map nodesToClassMapMakers = new HashMap();

public Map propertyBridgesByClassMap() {
return this.nodesToClassMapBridgeLists;
}

public Map NodeMakersByClassMap() {
return this.nodesToClassMapMakers;
}

private void registerBridgeForClassMap(Node classMap, PropertyBridge bridge) {
List bridgeList = (List) this.nodesToClassMapBridgeLists.get(classMap);
if (bridgeList == null) {
bridgeList = new ArrayList();
this.nodesToClassMapBridgeLists.put(classMap, bridgeList);
}
bridgeList.add(bridge);
nodesToClassMapMakers.put(classMap, bridge.getSubjectMaker());
}
}

0 comments on commit cede6ee

Please sign in to comment.