litvinovg/vitro
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

incremental development

Browse source
This commit is contained in:
stellamit 2012-05-22 14:41:55 +00:00
parent 401fb2208c
commit 9e210249b9
1 changed files with 22 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

27
webapp/src/edu/cornell/mannlib/vitro/webapp/rdfservice/impl/RDFServiceImpl.java
View file

@ -5,7 +5,6 @@ package edu.cornell.mannlib.vitro.webapp.rdfservice.impl;
import java.io.ByteArrayInputStream; import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream; import java.io.ByteArrayOutputStream;
import java.io.InputStream; import java.io.InputStream;
import java.util.ArrayList;
import java.util.HashSet; import java.util.HashSet;
import java.util.Iterator; import java.util.Iterator;
import java.util.List; import java.util.List;
@ -392,7 +391,7 @@ public class RDFServiceImpl implements RDFService {
+ ((graphURI != null) ? " } " : ""); + ((graphURI != null) ? " } " : "");
executeUpdate(updateString); executeUpdate(updateString);
notifyListeners(t, ModelChange.Operation.ADD, graphURI);
} }
protected void removeTriple(Triple t, String graphURI) { protected void removeTriple(Triple t, String graphURI) {
@ -404,23 +403,39 @@ public class RDFServiceImpl implements RDFService {
+ ((graphURI != null) ? " } " : ""); + ((graphURI != null) ? " } " : "");
executeUpdate(updateString); executeUpdate(updateString);
notifyListeners(t, ModelChange.Operation.REMOVE, graphURI);
} }
protected synchronized void notifyListeners(Triple triple, ModelChange.Operation operation, String graphURI) {
protected synchronized void notifyListenersOfRemove(String serializedTriple, RDFService.ModelSerializationFormat serializationFormat, ModelChange.Operation operation) { if (!(triple.getSubject().isURI() && triple.getPredicate().isURI() && triple.getObject().isURI())) {
return;
}
Model model = ModelFactory.createDefaultModel();
Statement statement = model.createStatement(model.createResource(triple.getSubject().getURI()),
model.createProperty(triple.getPredicate().getURI()),
model.createResource(triple.getObject().getURI()));
model.add(statement);
ByteArrayOutputStream serializedModel = new ByteArrayOutputStream();
model.write(serializedModel,getSerializationFormatString(RDFService.ModelSerializationFormat.N3));
String serializedTriple = serializedModel.toString();
Iterator<ChangeListener> iter = registeredListeners.iterator(); Iterator<ChangeListener> iter = registeredListeners.iterator();
while (iter.hasNext()) { while (iter.hasNext()) {
ChangeListener listener = iter.next(); ChangeListener listener = iter.next();
if (operation == ModelChange.Operation.ADD) {
listener.addedStatement(serializedTriple, RDFService.ModelSerializationFormat.N3, graphURI);
} else {
listener.addedStatement(serializedTriple, RDFService.ModelSerializationFormat.N3, graphURI);
}
} }
} }
protected boolean isPreconditionSatisfied(String query, protected boolean isPreconditionSatisfied(String query,
RDFService.SPARQLQueryType queryType) RDFService.SPARQLQueryType queryType)
throws RDFServiceException { throws RDFServiceException {
Model model = ModelFactory.createDefaultModel(); Model model = ModelFactory.createDefaultModel();
switch (queryType) { switch (queryType) {
@ -439,7 +454,6 @@ public class RDFServiceImpl implements RDFService {
} }
} }
protected boolean sparqlSelectQueryHasResults(String queryStr) throws RDFServiceException { protected boolean sparqlSelectQueryHasResults(String queryStr) throws RDFServiceException {
Query query = QueryFactory.create(queryStr); Query query = QueryFactory.create(queryStr);
@ -453,7 +467,6 @@ public class RDFServiceImpl implements RDFService {
} }
} }
protected void performAdd(ModelChange modelChange) throws RDFServiceException { protected void performAdd(ModelChange modelChange) throws RDFServiceException {
Model model = ModelFactory.createDefaultModel(); Model model = ModelFactory.createDefaultModel();