svn commit: r1201763 - in /incubator/jena/Scratch/AFS/Jena-Dev/trunk/src: dev/Run.java tx/api/DatasetTransactional.java

[an...@apache.org]

Author: andy
Date: Mon Nov 14 15:50:09 2011
New Revision: 1201763

URL: http://svn.apache.org/viewvc?rev=1201763&view=rev
Log: (empty)

Modified:
    incubator/jena/Scratch/AFS/Jena-Dev/trunk/src/dev/Run.java
    incubator/jena/Scratch/AFS/Jena-Dev/trunk/src/tx/api/DatasetTransactional.java

Modified: incubator/jena/Scratch/AFS/Jena-Dev/trunk/src/dev/Run.java
URL: http://svn.apache.org/viewvc/incubator/jena/Scratch/AFS/Jena-Dev/trunk/src/dev/Run.java?rev=1201763&r1=1201762&r2=1201763&view=diff
==============================================================================
--- incubator/jena/Scratch/AFS/Jena-Dev/trunk/src/dev/Run.java (original)
+++ incubator/jena/Scratch/AFS/Jena-Dev/trunk/src/dev/Run.java Mon Nov 14 15:50:09 2011
@@ -26,6 +26,7 @@ import org.openjena.atlas.lib.FileOps ;
 import org.openjena.atlas.lib.Lib ;
 import org.openjena.atlas.logging.Log ;
 import tx.api.DatasetGraphTX ;
+import tx.api.DatasetTransactional ;
 import arq.update ;
 
 import com.hp.hpl.jena.query.Dataset ;
@@ -48,6 +49,7 @@ import com.hp.hpl.jena.tdb.TDBFactory ;
 import com.hp.hpl.jena.tdb.TDBLoader ;
 import com.hp.hpl.jena.tdb.base.file.Location ;
 import com.hp.hpl.jena.tdb.store.DatasetGraphTDB ;
+import com.hp.hpl.jena.util.FileManager ;
 
 public class Run extends RunBase
 {
@@ -55,6 +57,20 @@ public class Run extends RunBase
     
     public static void main(String[] argv) throws Exception
     {
+        Dataset ds = new DatasetTransactional(new DatasetGraphTX(Location.mem())) ;
+        ds.begin(ReadWrite.WRITE) ;
+        FileManager.get().readModel(ds.getDefaultModel(), "D.nt") ;
+        ds.commit() ;
+        //ds.close() ;
+        
+        ds.begin(ReadWrite.READ) ;
+        SSE.write(ds.asDatasetGraph()) ;
+        ds.close() ;
+        
+        exit(0) ;
+        
+        
+        
         DatasetGraphTX dsg = new DatasetGraphTX(Location.mem()) ;
         dsg.begin(ReadWrite.WRITE) ;
         dsg.add(SSE.parseQuad("(<g> <s> <p> <o>)")) ;

Modified: incubator/jena/Scratch/AFS/Jena-Dev/trunk/src/tx/api/DatasetTransactional.java
URL: http://svn.apache.org/viewvc/incubator/jena/Scratch/AFS/Jena-Dev/trunk/src/tx/api/DatasetTransactional.java?rev=1201763&r1=1201762&r2=1201763&view=diff
==============================================================================
--- incubator/jena/Scratch/AFS/Jena-Dev/trunk/src/tx/api/DatasetTransactional.java (original)
+++ incubator/jena/Scratch/AFS/Jena-Dev/trunk/src/tx/api/DatasetTransactional.java Mon Nov 14 15:50:09 2011
@@ -32,7 +32,9 @@ public class DatasetTransactional extend
     
     @Override public boolean supportsTransactions() { return true ; }
     @Override public void begin(ReadWrite mode)     { dsgTxn.begin(mode) ; }
-    @Override public void commit()                  {  }
-    @Override public void abort()                   {  }
+    @Override public void commit()                  { dsgTxn.commit() ; }
+    @Override public void abort()                   { dsgTxn.abort() ; }
 }
 
+
+