0002943: Add min and max sym_data.data_id to support snapshot

JumpMind · Dec 14, 2016 · dc61509 · dc61509
1 parent 494871e
commit dc61509
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/util/SnapshotUtil.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/util/SnapshotUtil.java
@@ -513,8 +513,12 @@ public synchronized Enumeration<Object> keys() {
                         Long.toString(gaps.get(0).getStartId()));
                 runtimeProperties.setProperty("data.gap.end.id",
                         Long.toString(gaps.get(gaps.size()-1).getEndId()));                
-
             }
+
+            runtimeProperties.setProperty("data.id.min",
+                    Long.toString(engine.getDataService().findMinDataId()));            
+            runtimeProperties.setProperty("data.id.max",
+                    Long.toString(engine.getDataService().findMaxDataId()));            
 
             runtimeProperties.put("jvm.title", Runtime.class.getPackage().getImplementationTitle());
             runtimeProperties.put("jvm.vendor", Runtime.class.getPackage().getImplementationVendor());

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/IDataService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/IDataService.java
@@ -158,6 +158,8 @@ public void insertScriptEvent(ISqlTransaction transaction, String channelId,
 
     public long findMaxDataId();
 
+    public long findMinDataId();
+
     public ISqlReadCursor<Data> selectDataFor(Batch batch);
 
     public ISqlReadCursor<Data> selectDataFor(Long batchId, String channelId);