svn commit: r1403448 - /jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/modify/UpdateEngineMain.java

[rv...@apache.org]

Author: rvesse
Date: Mon Oct 29 17:59:33 2012
New Revision: 1403448

URL: http://svn.apache.org/viewvc?rev=1403448&view=rev
Log:
Minor refactor to UpdateEngineMain to make it easier to extend for users who just wish to use an alternative UpdateVisitor

Modified:
    jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/modify/UpdateEngineMain.java

Modified: jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/modify/UpdateEngineMain.java
URL: http://svn.apache.org/viewvc/jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/modify/UpdateEngineMain.java?rev=1403448&r1=1403447&r2=1403448&view=diff
==============================================================================
--- jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/modify/UpdateEngineMain.java (original)
+++ jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/modify/UpdateEngineMain.java Mon Oct 29 17:59:33 2012
@@ -19,28 +19,55 @@
 package com.hp.hpl.jena.sparql.modify;
 
 import com.hp.hpl.jena.sparql.engine.binding.Binding ;
+import com.hp.hpl.jena.sparql.modify.request.UpdateVisitor;
 import com.hp.hpl.jena.sparql.util.Context ;
 import com.hp.hpl.jena.update.GraphStore ;
 import com.hp.hpl.jena.update.Update ;
 import com.hp.hpl.jena.update.UpdateRequest ;
 
+/**
+ * Default implementation of an update engine
+ * <p>
+ * Developers who only want to change/extend the processing of individual updates can easily 
+ * </p>
+ */
 public class UpdateEngineMain extends UpdateEngineBase 
 {
+    /**
+     * Creates a new Update Engine
+     * @param graphStore Graph Store the updates operate over
+     * @param request Update Request
+     * @param initialBinding Initial Bindings
+     * @param context Execution Context
+     */
     public UpdateEngineMain(GraphStore graphStore, UpdateRequest request, Binding initialBinding, Context context)
     {
         super(graphStore, request, initialBinding, context) ;
     }
 
+    /**
+     * Executes the updates by creating a {@link UpdateVisitor} using the {@link #prepareWorker()} method and then using that to visit each update command in the Update Request
+     */
+    @SuppressWarnings("javadoc")
     @Override
     public void execute()
     {
         graphStore.startRequest(request) ;
-        UpdateEngineWorker worker = new UpdateEngineWorker(graphStore, startBinding, context) ;
-        for ( Update up : request )
+        UpdateVisitor worker = this.prepareWorker();
+        for ( Update up : request ) {
             up.visit(worker) ;
+        }
         graphStore.finishRequest(request) ;
     }
     
+    /**
+     * Creates the {@link UpdateVisitor} which will do the work of applying the updates
+     * @return The update visitor to be used to apply the updates
+     */
+    protected UpdateVisitor prepareWorker() {
+        return new UpdateEngineWorker(graphStore, startBinding, context) ;
+    }
+    
     private static UpdateEngineFactory factory = new UpdateEngineFactory()
     {
         @Override