Changeset 339 for branches/release-0_71-bugfixes/Rapla/src/org/rapla/storage/dbsql/DBOperator.java

Timestamp:

04/22/02 14:57:50 (10 years ago)

Author:

team4

Message:

*** empty log message ***

Files:

• branches/release-0_71-bugfixes/Rapla/src/org/rapla/storage/dbsql/DBOperator.java (modified) (5 diffs)

branches/release-0_71-bugfixes/Rapla/src/org/rapla/storage/dbsql/DBOperator.java

@@ -85 +85 @@
         Connection con = null;
         Connection idcon = null;
+        boolean bAutoCommit = true;
         boolean bFailed = true;
         try {
@@ -90 +91 @@
                 con = openConnection();
                 idcon = openConnection();
-                con.setAutoCommit(false);
+                try {
+                    con.setAutoCommit(false);
+                    // Check if autocommit is disabled (Transaction Support)
+                    bAutoCommit = con.getAutoCommit();
+                } catch (SQLException ex) {
+                    config.getLog().log(3,"No Transaction support");
+                }
                 for (int i=0;i<obj.length;i++) 
                     raplaSQL.store(con,idcon,obj[i]);
@@ -96 +103 @@
                 bFailed = false;
             } finally {
-                if (bFailed && (con != null)) {
+                if (bFailed && (con != null) && !bAutoCommit) {
                     con.rollback();
                     config.getLog().log(4,"Doing rollback");
                 }
-                if (!bFailed && (con != null)) {
+                if (!bFailed && (con != null) && !bAutoCommit) {
                     con.commit();
                     config.getLog().log(4,"Commiting");
@@ -117 +124 @@
         checkNoDependencies(obj);
         Connection con = null;
+        boolean bAutoCommit = true;
         boolean bFailed = true;
         try {
             try {
                 con = openConnection();
-                con.setAutoCommit(false);
+                try {
+                    con.setAutoCommit(false);
+                    // Check if autocommit is disabled
+                    bAutoCommit = con.getAutoCommit();
+                } catch (SQLException ex) {
+                    config.getLog().log(3,"No Transaction support");
+                }
                 for (int i=0;i<obj.length;i++) {
                     raplaSQL.remove(con,obj[i]);
@@ -128 +142 @@
                 bFailed = false;
             } finally {
-                if (bFailed && (con != null)) {
+                if (bFailed && (con != null) && !bAutoCommit) {
                     con.rollback();
                     config.getLog().log(4,"Doing rollback");
                 }
-                if (!bFailed && (con != null)) {
+                if (!bFailed && (con != null) && !bAutoCommit) {
                     con.commit();
                     config.getLog().log(4,"Commiting");