You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jena.apache.org by an...@apache.org on 2012/11/11 23:03:43 UTC

svn commit: r1408130 - /jena/trunk/jena-tdb/src/main/java/com/hp/hpl/jena/tdb/transaction/DatasetGraphTransaction.java

Author: andy
Date: Sun Nov 11 22:03:43 2012
New Revision: 1408130

URL: http://svn.apache.org/viewvc?rev=1408130&view=rev
Log:
sync on transactional is a no-op

Modified:
    jena/trunk/jena-tdb/src/main/java/com/hp/hpl/jena/tdb/transaction/DatasetGraphTransaction.java

Modified: jena/trunk/jena-tdb/src/main/java/com/hp/hpl/jena/tdb/transaction/DatasetGraphTransaction.java
URL: http://svn.apache.org/viewvc/jena/trunk/jena-tdb/src/main/java/com/hp/hpl/jena/tdb/transaction/DatasetGraphTransaction.java?rev=1408130&r1=1408129&r2=1408130&view=diff
==============================================================================
--- jena/trunk/jena-tdb/src/main/java/com/hp/hpl/jena/tdb/transaction/DatasetGraphTransaction.java (original)
+++ jena/trunk/jena-tdb/src/main/java/com/hp/hpl/jena/tdb/transaction/DatasetGraphTransaction.java Sun Nov 11 22:03:43 2012
@@ -18,6 +18,8 @@
 
 package com.hp.hpl.jena.tdb.transaction;
 
+import org.openjena.atlas.lib.Sync ;
+
 import com.hp.hpl.jena.query.Dataset ;
 import com.hp.hpl.jena.query.DatasetFactory ;
 import com.hp.hpl.jena.query.ReadWrite ;
@@ -35,7 +37,7 @@ import com.hp.hpl.jena.update.UpdateRequ
  * This is analogous to a "connection" in JDBC.
  */
 
-public class DatasetGraphTransaction extends DatasetGraphTrackActive implements GraphStore 
+public class DatasetGraphTransaction extends DatasetGraphTrackActive implements GraphStore, Sync
 {
     /* Initially, the app can use this DatasetGraph non-transactionally.
      * But as soon as it starts a transaction, the dataset can only be used
@@ -236,6 +238,11 @@ public class DatasetGraphTransaction ext
     @Override
     public void finishRequest(UpdateRequest request)
     {}
-    
-    
+
+    @Override
+    public void sync()
+    {
+        if ( ! sConn.haveUsedInTransaction() && get() != null )
+            get().sync() ;
+    }
 }