You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jena.apache.org by rv...@apache.org on 2013/04/08 21:46:28 UTC

svn commit: r1465740 - /jena/Experimental/jena-jdbc/jena-jdbc-core/src/main/java/org/apache/jena/jdbc/connections/DatasetConnection.java

Author: rvesse
Date: Mon Apr  8 19:46:17 2013
New Revision: 1465740

URL: http://svn.apache.org/r1465740
Log:
Minor fix to transaction behaviour

Modified:
    jena/Experimental/jena-jdbc/jena-jdbc-core/src/main/java/org/apache/jena/jdbc/connections/DatasetConnection.java

Modified: jena/Experimental/jena-jdbc/jena-jdbc-core/src/main/java/org/apache/jena/jdbc/connections/DatasetConnection.java
URL: http://svn.apache.org/viewvc/jena/Experimental/jena-jdbc/jena-jdbc-core/src/main/java/org/apache/jena/jdbc/connections/DatasetConnection.java?rev=1465740&r1=1465739&r2=1465740&view=diff
==============================================================================
--- jena/Experimental/jena-jdbc/jena-jdbc-core/src/main/java/org/apache/jena/jdbc/connections/DatasetConnection.java (original)
+++ jena/Experimental/jena-jdbc/jena-jdbc-core/src/main/java/org/apache/jena/jdbc/connections/DatasetConnection.java Mon Apr  8 19:46:17 2013
@@ -164,9 +164,11 @@ public abstract class DatasetConnection 
     @Override
     protected void commitInternal() throws SQLException {
         try {
-            if (ds.isInTransaction()) {
-                ds.commit();
-                ds.end();
+            if (ds.supportsTransactions()) {
+                if (ds.isInTransaction()) {
+                    ds.commit();
+                    ds.end();
+                }
             }
         } catch (Exception e) {
             throw new SQLException("Unexpected error committing the transaction", e);
@@ -176,9 +178,11 @@ public abstract class DatasetConnection 
     @Override
     protected void rollbackInternal() throws SQLException {
         try {
-            if (ds.isInTransaction()) {
-                ds.abort();
-                ds.end();
+            if (ds.supportsTransactions()) {
+                if (ds.isInTransaction()) {
+                    ds.abort();
+                    ds.end();
+                }
             }
         } catch (Exception e) {
             throw new SQLException("Unexpected error rolling back the transaction", e);