0001544: API - transactions aren't being committed in the sequence se…

…rvice api for applications (outside of symmetricds) that use the api
JumpMind · Jan 23, 2014 · abaf161 · abaf161
1 parent 7bc2d4c
commit abaf161
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 4 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/SequenceService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/SequenceService.java
@@ -74,7 +74,9 @@ public long nextVal(String name) {
         ISqlTransaction transaction = null;
         try {
             transaction = sqlTemplate.startSqlTransaction();
-            return nextVal(transaction, name);
+            long val = nextVal(transaction, name);
+            transaction.commit();
+            return val;
         } catch (Error ex) {
             if (transaction != null) {
                 transaction.rollback();
@@ -160,7 +162,9 @@ public long currVal(String name) {
         ISqlTransaction transaction = null;
         try {
             transaction = sqlTemplate.startSqlTransaction();
-            return currVal(transaction, name);
+            long val = currVal(transaction, name);
+            transaction.commit();
+            return val;
         } catch (Error ex) {
             if (transaction != null) {
                 transaction.rollback();

diff --git a/symmetric-jdbc/src/main/java/org/jumpmind/db/sql/JdbcSqlTransaction.java b/symmetric-jdbc/src/main/java/org/jumpmind/db/sql/JdbcSqlTransaction.java
@@ -163,11 +163,19 @@ public int flush() {
     }
 
     public int queryForInt(String sql, Object... args) {
-        return queryForObject(sql, Integer.class, args);
+        Integer val = queryForObject(sql, Integer.class, args);
+        if (val == null) {
+            val = Integer.MIN_VALUE;
+        }
+        return val;
     }
 
     public long queryForLong(String sql, Object... args) {
-        return queryForObject(sql, Long.class, args);
+        Long val = queryForObject(sql, Long.class, args);
+        if (val == null) {
+            val = Long.MIN_VALUE;
+        }
+        return val;
     }
 
     public <T> T queryForObject(final String sql, final Class<T> clazz, final Object... args) {