Support updates to replicated LOBs.

1 files changed, 52 insertions, 6 deletions

diff --git a/src/test/java/com/amazon/carbonado/repo/replicated/TestStorables.java b/src/test/java/com/amazon/carbonado/repo/replicated/TestStorables.java
index 31b2c72..60251fb 100644
--- a/src/test/java/com/amazon/carbonado/repo/replicated/TestStorables.java
+++ b/src/test/java/com/amazon/carbonado/repo/replicated/TestStorables.java
@@ -105,16 +105,16 @@ public class TestStorables extends com.amazon.carbonado.TestStorables {
     public void testBlobReplication() throws Exception {

         Storage<StorableWithLobs> storage = getRepository().storageFor(StorableWithLobs.class);

 

-        Storage<StorableWithLobs> replica = ((ReplicatedRepository) getRepository())

+        Storage<StorableWithLobs> replicaStorage = ((ReplicatedRepository) getRepository())

             .getReplicaRepository().storageFor(StorableWithLobs.class);

-        Storage<StorableWithLobs> master = ((ReplicatedRepository) getRepository())

+        Storage<StorableWithLobs> masterStorage = ((ReplicatedRepository) getRepository())

             .getMasterRepository().storageFor(StorableWithLobs.class);

 

         StorableWithLobs lobs = storage.prepare();

         lobs.setBlobValue(new ByteArrayBlob("hello".getBytes()));

         lobs.insert();

 

-        StorableWithLobs maLobs = master.prepare();

+        StorableWithLobs maLobs = masterStorage.prepare();

         maLobs.setId(lobs.getId());

         maLobs.load();

         assertEquals("hello", maLobs.getBlobValue().asString());

@@ -137,21 +137,44 @@ public class TestStorables extends com.amazon.carbonado.TestStorables {
 

         assertEquals("world!", blob.asString());

         assertEquals("world!", maLobs.getBlobValue().asString());

+

+        // Do again after a fresh load

+        lobs.load();

+        blob = lobs.getBlobValue();

+

+        assertEquals("world!", blob.asString());

+        assertEquals("world!", maLobs.getBlobValue().asString());

+

+        out = blob.openOutputStream();

+        out.write("the quick brown fox".getBytes());

+        out.close();

+        

+        assertEquals("the quick brown fox", blob.asString());

+        assertEquals("the quick brown fox", maLobs.getBlobValue().asString());

+

+        // Test length change.

+        blob.setLength(3);

+

+        assertEquals(3, blob.getLength());

+        assertEquals(3, maLobs.getBlobValue().getLength());

+

+        assertEquals("the", blob.asString());

+        assertEquals("the", maLobs.getBlobValue().asString());

     }

 

     public void testClobReplication() throws Exception {

         Storage<StorableWithLobs> storage = getRepository().storageFor(StorableWithLobs.class);

 

-        Storage<StorableWithLobs> replica = ((ReplicatedRepository) getRepository())

+        Storage<StorableWithLobs> replicaStorage = ((ReplicatedRepository) getRepository())

             .getReplicaRepository().storageFor(StorableWithLobs.class);

-        Storage<StorableWithLobs> master = ((ReplicatedRepository) getRepository())

+        Storage<StorableWithLobs> masterStorage = ((ReplicatedRepository) getRepository())

             .getMasterRepository().storageFor(StorableWithLobs.class);

 

         StorableWithLobs lobs = storage.prepare();

         lobs.setClobValue(new StringClob("hello"));

         lobs.insert();

 

-        StorableWithLobs maLobs = master.prepare();

+        StorableWithLobs maLobs = masterStorage.prepare();

         maLobs.setId(lobs.getId());

         maLobs.load();

         assertEquals("hello", maLobs.getClobValue().asString());

@@ -174,5 +197,28 @@ public class TestStorables extends com.amazon.carbonado.TestStorables {
 

         assertEquals("world!", clob.asString());

         assertEquals("world!", maLobs.getClobValue().asString());

+

+        // Do again after a fresh load

+        lobs.load();

+        clob = lobs.getClobValue();

+

+        assertEquals("world!", clob.asString());

+        assertEquals("world!", maLobs.getClobValue().asString());

+

+        out = clob.openWriter();

+        out.write("the quick brown fox");

+        out.close();

+        

+        assertEquals("the quick brown fox", clob.asString());

+        assertEquals("the quick brown fox", maLobs.getClobValue().asString());

+

+        // Test length change.

+        clob.setLength(3);

+

+        assertEquals(3, clob.getLength());

+        assertEquals(3, maLobs.getClobValue().getLength());

+

+        assertEquals("the", clob.asString());

+        assertEquals("the", maLobs.getClobValue().asString());

     }

 }