From eff6bb61f0a5f7ff3e4c758d93c4eb9df805827f Mon Sep 17 00:00:00 2001
From: lukaseder <lukas.eder@gmail.com>
Date: Tue, 21 Apr 2015 17:51:05 +0200
Subject: [PATCH] [#3765] HANA doesn't support savepoints

---
 .../jooq/impl/DefaultTransactionProvider.java | 45 ++++++++++++++++---
 1 file changed, 40 insertions(+), 5 deletions(-)

diff --git a/jOOQ/src/main/java/org/jooq/impl/DefaultTransactionProvider.java b/jOOQ/src/main/java/org/jooq/impl/DefaultTransactionProvider.java
index 41f4f6ee48..6d8dde14f9 100644
--- a/jOOQ/src/main/java/org/jooq/impl/DefaultTransactionProvider.java
+++ b/jOOQ/src/main/java/org/jooq/impl/DefaultTransactionProvider.java
@@ -45,6 +45,7 @@ import static org.jooq.impl.Utils.DATA_DEFAULT_TRANSACTION_PROVIDER_CONNECTION;
 import static org.jooq.impl.Utils.DATA_DEFAULT_TRANSACTION_PROVIDER_SAVEPOINTS;
 
 import java.sql.Connection;
+import java.sql.SQLException;
 import java.sql.Savepoint;
 import java.util.Stack;
 
@@ -67,8 +68,14 @@ import org.jooq.exception.DataAccessException;
  */
 public class DefaultTransactionProvider implements TransactionProvider {
 
-    private final ConnectionProvider  provider;
-    private Connection                connection;
+    /**
+     * This dummy {@link Savepoint} serves as a marker for top level
+     * transactions in dialects that do not support Savepoints.
+     */
+    private static final Savepoint   DUMMY_SAVEPOINT = new DefaultSavepoint();
+
+    private final ConnectionProvider provider;
+    private Connection               connection;
 
     public DefaultTransactionProvider(ConnectionProvider provider) {
         this.provider = provider;
@@ -117,7 +124,23 @@ public class DefaultTransactionProvider implements TransactionProvider {
             brace(ctx.configuration(), true);
         }
 
-        savepoints.push(connection(ctx.configuration()).setSavepoint());
+        Savepoint savepoint = setSavepoint(ctx.configuration());
+
+        if (savepoint == DUMMY_SAVEPOINT && savepoints.size() > 0)
+            throw new DataAccessException("Cannot nest transactions because Savepoints are not supported");
+
+        savepoints.push(savepoint);
+    }
+
+    private Savepoint setSavepoint(Configuration configuration) {
+        switch (configuration.family()) {
+            /* [pro] xx
+            xxxx xxxxx
+                xxxxxx xxxxxxxxxxxxxxxx
+            xx [/pro] */
+            default:
+                return connection(configuration).setSavepoint();
+        }
     }
 
     @Override
@@ -126,7 +149,7 @@ public class DefaultTransactionProvider implements TransactionProvider {
         Savepoint savepoint = savepoints.pop();
 
         // [#3489] Explicitly release savepoints prior to commit
-        if (savepoint != null)
+        if (savepoint != null && savepoint != DUMMY_SAVEPOINT)
             try {
                 connection(ctx.configuration()).releaseSavepoint(savepoint);
             }
@@ -156,7 +179,7 @@ public class DefaultTransactionProvider implements TransactionProvider {
             savepoint = savepoints.pop();
 
         try {
-            if (savepoint == null)
+            if (savepoint == null || savepoint == DUMMY_SAVEPOINT)
                 connection(ctx.configuration()).rollback();
             else
                 connection(ctx.configuration()).rollback(savepoint);
@@ -198,4 +221,16 @@ public class DefaultTransactionProvider implements TransactionProvider {
             }
         }
     }
+
+    private static class DefaultSavepoint implements Savepoint {
+        @Override
+        public int getSavepointId() throws SQLException {
+            return 0;
+        }
+
+        @Override
+        public String getSavepointName() throws SQLException {
+            return null;
+        }
+    }
 }