diff --git a/core/src/com/cloud/dc/dao/DataCenterIpAddressDaoImpl.java b/core/src/com/cloud/dc/dao/DataCenterIpAddressDaoImpl.java
index 1179b188a99..8ff6876c74a 100755
--- a/core/src/com/cloud/dc/dao/DataCenterIpAddressDaoImpl.java
+++ b/core/src/com/cloud/dc/dao/DataCenterIpAddressDaoImpl.java
@@ -55,6 +55,7 @@ public class DataCenterIpAddressDaoImpl extends GenericDaoBase<DataCenterIpAddre
         txn.start();
         DataCenterIpAddressVO  vo = lockOneRandomRow(sc, true);
         if (vo == null) {
+            txn.rollback();
             return null;
         }
         vo.setTakenAt(new Date());
@@ -102,10 +103,11 @@ public class DataCenterIpAddressDaoImpl extends GenericDaoBase<DataCenterIpAddre
                 stmt.setLong(3, podId);
                 stmt.addBatch();
             }
+            stmt.executeBatch();
             txn.commit();
         } catch (SQLException ex) {
             throw new CloudRuntimeException("Unable to persist ip address range ", ex);
-        }
+        } 
     }
     
     public void releaseIpAddress(String ipAddress, long dcId, Long instanceId) {
diff --git a/core/src/com/cloud/dc/dao/DataCenterLinkLocalIpAddressDaoImpl.java b/core/src/com/cloud/dc/dao/DataCenterLinkLocalIpAddressDaoImpl.java
index d4acd6962d0..1f12d20acdb 100644
--- a/core/src/com/cloud/dc/dao/DataCenterLinkLocalIpAddressDaoImpl.java
+++ b/core/src/com/cloud/dc/dao/DataCenterLinkLocalIpAddressDaoImpl.java
@@ -94,6 +94,7 @@ public class DataCenterLinkLocalIpAddressDaoImpl extends GenericDaoBase<DataCent
                     stmt.setLong(3, podId);
                     stmt.addBatch();
             }
+            stmt.executeBatch();
             txn.commit();
         } catch (SQLException e) {
             throw new CloudRuntimeException("Unable to insert", e);