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() ;
+ }
}