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

transactional Sesame sync

Browse source
This commit is contained in:
bjl23 2010-02-17 20:20:02 +00:00
parent 79f0c67ce8
commit 609b18b940
1 changed files with 29 additions and 29 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
webapp/src/edu/cornell/mannlib/vitro/webapp/utils/jena/SesameSyncUtils.java
View file

@ -27,7 +27,9 @@ public class SesameSyncUtils {
Repository myRepository = new HTTPRepository(serverURI, repositoryId); Repository myRepository = new HTTPRepository(serverURI, repositoryId);
myRepository.initialize(); myRepository.initialize();
RepositoryConnection myConn = myRepository.getConnection(); RepositoryConnection myConn = myRepository.getConnection();
System.out.println(myConn.size()+" statements in remote Sesame");
myConn.setAutoCommit(false);
try {
Resource contextRes = (contextId != null) Resource contextRes = (contextId != null)
? new URIImpl(contextId) : null ; ? new URIImpl(contextId) : null ;
@ -38,29 +40,27 @@ public class SesameSyncUtils {
myConn.clear(); myConn.clear();
} }
System.out.println("Cleared");
System.out.println(myConn.size());
PipedInputStream in = new PipedInputStream(); PipedInputStream in = new PipedInputStream();
PipedOutputStream out = new PipedOutputStream(in); PipedOutputStream out = new PipedOutputStream(in);
try { try {
new Thread((new JenaOutputter(jenaModel, out))).start(); new Thread((new JenaOutputter(jenaModel, out))).start();
if (contextRes != null) { if (contextRes != null) {
myConn.add(in, null, RDFFormat.NTRIPLES, contextRes); myConn.add(in,"http://example.org/base/", RDFFormat.NTRIPLES, contextRes);
} else { } else {
myConn.add(in, null, RDFFormat.NTRIPLES); myConn.add(in,"http://example.org/base/", RDFFormat.NTRIPLES);
} }
} finally { } finally {
in.close(); in.close();
} }
System.out.println("Jena model added");
System.out.println(myConn.size());
myConn.commit(); myConn.commit();
} catch (Exception e) {
myConn.rollback();
e.printStackTrace();
} finally {
myConn.close(); myConn.close();
}
} }