diff options
| author | Brian S. O'Neill <bronee@gmail.com> | 2012-05-06 15:32:56 +0000 |
|---|---|---|
| committer | Brian S. O'Neill <bronee@gmail.com> | 2012-05-06 15:32:56 +0000 |
| commit | a57babd5403f7532049bc9584395236193709df9 (patch) | |
| tree | 270fba1cf4ff14e42cb28fa3a7f16c703b51729c /src/test/java/com/amazon | |
| parent | 66ede0fed04c965b0e1cbcb5a368cd47e0f66f75 (diff) | |
Add another repair test.
Diffstat (limited to 'src/test/java/com/amazon')
| -rw-r--r-- | src/test/java/com/amazon/carbonado/repo/replicated/TestRepair.java | 43 |
1 files changed, 43 insertions, 0 deletions
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);
}
|