summaryrefslogtreecommitdiff
path: root/src/test/java/com
diff options
context:
space:
mode:
Diffstat (limited to 'src/test/java/com')
-rw-r--r--src/test/java/com/amazon/carbonado/cursor/TestMergeSortBuffer.java55
1 files changed, 43 insertions, 12 deletions
diff --git a/src/test/java/com/amazon/carbonado/cursor/TestMergeSortBuffer.java b/src/test/java/com/amazon/carbonado/cursor/TestMergeSortBuffer.java
index 59119ec..dd7fff8 100644
--- a/src/test/java/com/amazon/carbonado/cursor/TestMergeSortBuffer.java
+++ b/src/test/java/com/amazon/carbonado/cursor/TestMergeSortBuffer.java
@@ -72,7 +72,14 @@ public class TestMergeSortBuffer extends TestCase {
}
public void testEmptyBuffer() throws Exception {
- Storage<StorableTestBasic> storage = mRepository.storageFor(StorableTestBasic.class);
+ testEmptyBuffer(mRepository.storageFor(StorableTestBasic.class));
+ }
+
+ public void testEmptyBufferAutoStorage() throws Exception {
+ testEmptyBuffer(null);
+ }
+
+ private void testEmptyBuffer(Storage<StorableTestBasic> storage) throws Exception {
SortBuffer<StorableTestBasic> buffer = new MergeSortBuffer<StorableTestBasic>(storage);
buffer.prepare(mComparator);
@@ -98,38 +105,59 @@ public class TestMergeSortBuffer extends TestCase {
}
public void testSmallBuffer() throws Exception {
- testBuffer(SMALL_BUFFER_SIZE);
+ testBuffer(mRepository.storageFor(StorableTestBasic.class), SMALL_BUFFER_SIZE);
+ }
+
+ public void testSmallBufferAutoStorage() throws Exception {
+ testBuffer(null, SMALL_BUFFER_SIZE);
}
public void testMedium() throws Exception {
- testBuffer(MEDIUM_BUFFER_SIZE);
+ testBuffer(mRepository.storageFor(StorableTestBasic.class), MEDIUM_BUFFER_SIZE);
+ }
+
+ public void testMediumAutoStorage() throws Exception {
+ testBuffer(null, MEDIUM_BUFFER_SIZE);
}
public void testMediumOdd() throws Exception {
- testBuffer(MEDIUM_BUFFER_SIZE + 13);
+ testBuffer(mRepository.storageFor(StorableTestBasic.class), MEDIUM_BUFFER_SIZE + 13);
+ }
+
+ public void testMediumOddAutoStorage() throws Exception {
+ testBuffer(null, MEDIUM_BUFFER_SIZE + 13);
}
public void testLarge() throws Exception {
- testBuffer(LARGE_BUFFER_SIZE);
+ testBuffer(mRepository.storageFor(StorableTestBasic.class), LARGE_BUFFER_SIZE);
+ }
+
+ public void testLargeAutoStorage() throws Exception {
+ testBuffer(null, LARGE_BUFFER_SIZE);
}
public void testLargeOdd() throws Exception {
- testBuffer(LARGE_BUFFER_SIZE + 13);
+ testBuffer(mRepository.storageFor(StorableTestBasic.class), LARGE_BUFFER_SIZE + 13);
}
- public void testHuge() throws Exception {
- testBuffer(HUGE_BUFFER_SIZE);
+ public void testLargeOddAutoStorage() throws Exception {
+ testBuffer(null, LARGE_BUFFER_SIZE + 13);
+ }
+
+ public void testHugeAutoStorage() throws Exception {
+ testBuffer(null, HUGE_BUFFER_SIZE);
}
public void testLobs() throws Exception {
Comparator<StorableWithLobs> c = BeanComparator.forClass(StorableWithLobs.class)
.orderBy("-id");
- Storage<StorableWithLobs> storage = mRepository.storageFor(StorableWithLobs.class);
SortBuffer<StorableWithLobs> buffer =
- new MergeSortBuffer<StorableWithLobs>(storage, null, 100);
+ new MergeSortBuffer<StorableWithLobs>(null, null, 100);
buffer.prepare(c);
+ Storage<StorableWithLobs> storage = mRepository.storageFor(StorableWithLobs.class);
+
for (int i=0; i<5000; i++) {
StorableWithLobs s = storage.prepare();
s.setBlobValue(new ByteArrayBlob(("hello " + i).getBytes()));
@@ -151,11 +179,14 @@ public class TestMergeSortBuffer extends TestCase {
buffer.close();
}
- private void testBuffer(int size) throws Exception {
- Storage<StorableTestBasic> storage = mRepository.storageFor(StorableTestBasic.class);
+ private void testBuffer(Storage<StorableTestBasic> storage, int size) throws Exception {
SortBuffer<StorableTestBasic> buffer = new MergeSortBuffer<StorableTestBasic>(storage);
buffer.prepare(mComparator);
+ if (storage == null) {
+ storage = mRepository.storageFor(StorableTestBasic.class);
+ }
+
final long seed = 345891237L;
Random rnd = new Random(seed);