Repository: marmotta Updated Branches: refs/heads/develop 478035e95 -> 9ee0cade6
fix statement existance checks in kiwi loader Project: http://git-wip-us.apache.org/repos/asf/marmotta/repo Commit: http://git-wip-us.apache.org/repos/asf/marmotta/commit/9ee0cade Tree: http://git-wip-us.apache.org/repos/asf/marmotta/tree/9ee0cade Diff: http://git-wip-us.apache.org/repos/asf/marmotta/diff/9ee0cade Branch: refs/heads/develop Commit: 9ee0cade67ac92c30c11ad773f2e863c60fd1e3d Parents: 478035e Author: Sebastian Schaffert <[email protected]> Authored: Tue Sep 23 11:36:45 2014 +0200 Committer: Sebastian Schaffert <[email protected]> Committed: Tue Sep 23 11:36:45 2014 +0200 ---------------------------------------------------------------------- .../org/apache/marmotta/kiwi/loader/generic/KiWiHandler.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/marmotta/blob/9ee0cade/libraries/kiwi/kiwi-loader/src/main/java/org/apache/marmotta/kiwi/loader/generic/KiWiHandler.java ---------------------------------------------------------------------- diff --git a/libraries/kiwi/kiwi-loader/src/main/java/org/apache/marmotta/kiwi/loader/generic/KiWiHandler.java b/libraries/kiwi/kiwi-loader/src/main/java/org/apache/marmotta/kiwi/loader/generic/KiWiHandler.java index 19b7c85..0584133 100644 --- a/libraries/kiwi/kiwi-loader/src/main/java/org/apache/marmotta/kiwi/loader/generic/KiWiHandler.java +++ b/libraries/kiwi/kiwi-loader/src/main/java/org/apache/marmotta/kiwi/loader/generic/KiWiHandler.java @@ -244,6 +244,8 @@ public class KiWiHandler implements RDFHandler { result.setId(tripleId); registry.registerKey(cacheKey, connection.getTransactionId(), result.getId()); + + storeTriple(result); } else { // not found in registry, try loading from database result.setId(connection.getTripleId(subject,predicate,object,context,true)); @@ -255,12 +257,15 @@ public class KiWiHandler implements RDFHandler { result.setNewTriple(true); registry.registerKey(cacheKey, connection.getTransactionId(), result.getId()); + + storeTriple(result); } } else { result.setId(connection.getNextSequence("triples")); + + storeTriple(result); } - storeTriple(result); } catch (SQLException | ExecutionException e) { throw new RDFHandlerException(e);
