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

NIHVIVO-3799 don't require mark/reset support on model InputStream

Browse source
This commit is contained in:
stellamit 2012-06-20 19:03:19 +00:00
parent d1336f05b2
commit 66f041443d
1 changed files with 5 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

5
webapp/src/edu/cornell/mannlib/vitro/webapp/rdfservice/impl/sparql/RDFServiceSparql.java
View file

@ -10,6 +10,7 @@ import java.util.ArrayList;
import java.util.Iterator; import java.util.Iterator;
import java.util.List; import java.util.List;
import org.apache.commons.io.IOUtils;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.openrdf.model.Resource; import org.openrdf.model.Resource;
@ -140,6 +141,10 @@ public class RDFServiceSparql extends RDFServiceImpl implements RDFService {
Iterator<ModelChange> csIt = changeSet.getModelChanges().iterator(); Iterator<ModelChange> csIt = changeSet.getModelChanges().iterator();
while (csIt.hasNext()) { while (csIt.hasNext()) {
ModelChange modelChange = csIt.next(); ModelChange modelChange = csIt.next();
if (!modelChange.getSerializedModel().markSupported()) {
byte[] bytes = IOUtils.toByteArray(modelChange.getSerializedModel());
modelChange.setSerializedModel(new ByteArrayInputStream(bytes));
}
modelChange.getSerializedModel().mark(Integer.MAX_VALUE); modelChange.getSerializedModel().mark(Integer.MAX_VALUE);
performChange(modelChange); performChange(modelChange);
} }