From a57babd5403f7532049bc9584395236193709df9 Mon Sep 17 00:00:00 2001
From: "Brian S. O'Neill" <bronee@gmail.com>
Date: Sun, 6 May 2012 15:32:56 +0000
Subject: Add another repair test.

---
 .../carbonado/repo/replicated/TestRepair.java      | 43 ++++++++++++++++++++++
 1 file changed, 43 insertions(+)

(limited to 'src')

diff --git a/src/test/java/com/amazon/carbonado/repo/replicated/TestRepair.java b/src/test/java/com/amazon/carbonado/repo/replicated/TestRepair.java
index 78ada70..6e3a7ee 100644
--- a/src/test/java/com/amazon/carbonado/repo/replicated/TestRepair.java
+++ b/src/test/java/com/amazon/carbonado/repo/replicated/TestRepair.java
@@ -373,6 +373,49 @@ public class TestRepair extends TestCase {
         }
     }
 
+    public void testDeletedEntry() throws Exception {
+        // Insert some entries into rr.
+        for (int i=0; i<10; i++) {
+            Storage<StorableTestBasic> storage = mReplicated.storageFor(StorableTestBasic.class);
+            StorableTestBasic stb = storage.prepare();
+            stb.setId(i);
+            stb.setStringProp("hello");
+            stb.setIntProp(1);
+            stb.setLongProp(1L);
+            stb.setDoubleProp(1.0);
+            stb.insert();
+        }
+
+        // Delete on record from from master.
+        {
+            Storage<StorableTestBasic> storage = mMaster.storageFor(StorableTestBasic.class);
+            StorableTestBasic stb = storage.prepare();
+            stb.setId(5);
+            stb.delete();
+        }
+
+        // Verify record is still available from rr.
+        {
+            Storage<StorableTestBasic> storage = mReplicated.storageFor(StorableTestBasic.class);
+            StorableTestBasic stb = storage.prepare();
+            stb.setId(5);
+            assertTrue(stb.tryLoad());
+            assertEquals("hello", stb.getStringProp());
+        }
+
+        ResyncCapability cap = mReplicated.getCapability(ResyncCapability.class);
+
+        cap.resync(StorableTestBasic.class, 1.0, "id=?", 5);
+
+        // Verify record is not available from rr anymore.
+        {
+            Storage<StorableTestBasic> storage = mReplicated.storageFor(StorableTestBasic.class);
+            StorableTestBasic stb = storage.prepare();
+            stb.setId(5);
+            assertFalse(stb.tryLoad());
+        }
+    }
+
     public void testCorruptEntry() throws Exception {
         testCorruptEntry(false, false);
     }
-- 
cgit v1.2.3