GH-5210 Enable implementing sails to benefit from parent sail buffering

eclipse-rdf4j · Nov 26, 2024 · 9034649 · 9034649
1 parent 6e64a12
commit 9034649
Showing 1 changed file with 9 additions and 4 deletions.
diff --git a/core/sail/api/src/main/java/org/eclipse/rdf4j/sail/helpers/AbstractSailConnection.java b/core/sail/api/src/main/java/org/eclipse/rdf4j/sail/helpers/AbstractSailConnection.java
@@ -733,10 +733,8 @@ protected void endUpdateInternal(UpdateContext op) throws SailException {
 		synchronized (added) {
 			model = added.remove(op);
 		}
-		if (model != null) {
-			for (Statement st : model) {
-				addStatementInternal(st.getSubject(), st.getPredicate(), st.getObject(), st.getContext());
-			}
+		if (model != null && !model.isEmpty()) {
+			bulkAddStatementsInternal(model);
 		}
 	}
 
@@ -973,6 +971,13 @@ protected void prepareInternal() throws SailException {
 	protected abstract void addStatementInternal(Resource subj, IRI pred, Value obj, Resource... contexts)
 			throws SailException;
 
+	protected void bulkAddStatementsInternal(final Collection<? extends Statement> statements)
+			throws SailException {
+		for (final Statement st : statements) {
+			addStatementInternal(st.getSubject(), st.getPredicate(), st.getObject(), st.getContext());
+		}
+	}
+
 	protected abstract void removeStatementsInternal(Resource subj, IRI pred, Value obj, Resource... contexts)
 			throws SailException;