Author: elecharny
Date: Mon Mar 4 18:16:11 2013
New Revision: 1452427
URL: http://svn.apache.org/r1452427
Log:
Added tests for the RecordManager
Added:
labs/mavibot/trunk/mavibot/src/test/java/org/apache/mavibot/btree/store/
labs/mavibot/trunk/mavibot/src/test/java/org/apache/mavibot/btree/store/RecordManagerTest.java
labs/mavibot/trunk/mavibot/src/test/java/org/apache/mavibot/btree/store/storeBytesTest.java
Added:
labs/mavibot/trunk/mavibot/src/test/java/org/apache/mavibot/btree/store/RecordManagerTest.java
URL:
http://svn.apache.org/viewvc/labs/mavibot/trunk/mavibot/src/test/java/org/apache/mavibot/btree/store/RecordManagerTest.java?rev=1452427&view=auto
==============================================================================
---
labs/mavibot/trunk/mavibot/src/test/java/org/apache/mavibot/btree/store/RecordManagerTest.java
(added)
+++
labs/mavibot/trunk/mavibot/src/test/java/org/apache/mavibot/btree/store/RecordManagerTest.java
Mon Mar 4 18:16:11 2013
@@ -0,0 +1,42 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.mavibot.btree.store;
+
+
+import java.io.File;
+import java.io.IOException;
+
+import org.junit.Test;
+
+
+public class RecordManagerTest
+{
+
+ @Test
+ public void testRecordManager() throws IOException
+ {
+ File tempFile = File.createTempFile( "mavibot", ".db" );
+ String tempFileName = tempFile.getAbsolutePath();
+ tempFile.deleteOnExit();
+
+ RecordManager recordManager = new RecordManager( tempFileName );
+ }
+
+}
Added:
labs/mavibot/trunk/mavibot/src/test/java/org/apache/mavibot/btree/store/storeBytesTest.java
URL:
http://svn.apache.org/viewvc/labs/mavibot/trunk/mavibot/src/test/java/org/apache/mavibot/btree/store/storeBytesTest.java?rev=1452427&view=auto
==============================================================================
---
labs/mavibot/trunk/mavibot/src/test/java/org/apache/mavibot/btree/store/storeBytesTest.java
(added)
+++
labs/mavibot/trunk/mavibot/src/test/java/org/apache/mavibot/btree/store/storeBytesTest.java
Mon Mar 4 18:16:11 2013
@@ -0,0 +1,90 @@
+package org.apache.mavibot.btree.store;
+
+
+import static org.junit.Assert.assertEquals;
+
+import java.io.File;
+import java.lang.reflect.Method;
+import java.nio.ByteBuffer;
+
+import org.junit.Test;
+
+
+public class storeBytesTest
+{
+ @Test
+ public void testInjectIntoOnePage() throws Exception
+ {
+ File tempFile = File.createTempFile( "mavibot", ".db" );
+ String tempFileName = tempFile.getAbsolutePath();
+ tempFile.deleteOnExit();
+
+ RecordManager recordManager = new RecordManager( tempFileName );
+ Method method = RecordManager.class.getDeclaredMethod( "storeBytes",
PageIO[].class, long.class, int.class );
+ method.setAccessible( true );
+
+ // Allocate some Pages
+ PageIO[] pageIos = new PageIO[2];
+ pageIos[0] = new PageIO();
+ pageIos[0].setData( ByteBuffer.allocate( recordManager.getPageSize() )
);
+ pageIos[1] = new PageIO();
+ pageIos[1].setData( ByteBuffer.allocate( recordManager.getPageSize() )
);
+
+ // Set the int at the beginning
+ long position = ( Long ) method.invoke( recordManager, pageIos, 0,
0x12345678 );
+
+ assertEquals( 4, position );
+ assertEquals( 0x12, pageIos[0].getData().get( 12 ) );
+ assertEquals( 0x34, pageIos[0].getData().get( 13 ) );
+ assertEquals( 0x56, pageIos[0].getData().get( 14 ) );
+ assertEquals( 0x78, pageIos[0].getData().get( 15 ) );
+
+ // Set the int at the end of the first page
+ position = ( Long ) method.invoke( recordManager, pageIos, 4080,
0x12345678 );
+
+ assertEquals( 4084, position );
+ assertEquals( 0x12, pageIos[0].getData().get( 4092 ) );
+ assertEquals( 0x34, pageIos[0].getData().get( 4093 ) );
+ assertEquals( 0x56, pageIos[0].getData().get( 4094 ) );
+ assertEquals( 0x78, pageIos[0].getData().get( 4095 ) );
+
+ // Set the int at the end of the first page and overlapping on the
second page
+ // 1 byte overlapping
+ position = ( Long ) method.invoke( recordManager, pageIos, 4081,
0x12345678 );
+
+ assertEquals( 4085, position );
+ assertEquals( 0x12, pageIos[0].getData().get( 4093 ) );
+ assertEquals( 0x34, pageIos[0].getData().get( 4094 ) );
+ assertEquals( 0x56, pageIos[0].getData().get( 4095 ) );
+ assertEquals( 0x78, pageIos[1].getData().get( 8 ) );
+
+ // Set the int at the end of the first page and overlapping on the
second page
+ // 2 bytes overlapping
+ position = ( Long ) method.invoke( recordManager, pageIos, 4082,
0x12345678 );
+
+ assertEquals( 4086, position );
+ assertEquals( 0x12, pageIos[0].getData().get( 4094 ) );
+ assertEquals( 0x34, pageIos[0].getData().get( 4095 ) );
+ assertEquals( 0x56, pageIos[1].getData().get( 8 ) );
+ assertEquals( 0x78, pageIos[1].getData().get( 9 ) );
+
+ // Set the int at the end of the first page and overlapping on the
second page
+ // 3 bytes overlapping
+ position = ( Long ) method.invoke( recordManager, pageIos, 4083,
0x12345678 );
+
+ assertEquals( 4087, position );
+ assertEquals( 0x12, pageIos[0].getData().get( 4095 ) );
+ assertEquals( 0x34, pageIos[1].getData().get( 8 ) );
+ assertEquals( 0x56, pageIos[1].getData().get( 9 ) );
+ assertEquals( 0x78, pageIos[1].getData().get( 10 ) );
+
+ // Set the int at the beginning of the second page
+ position = ( Long ) method.invoke( recordManager, pageIos, 4084,
0x12345678 );
+
+ assertEquals( 4088, position );
+ assertEquals( 0x12, pageIos[1].getData().get( 8 ) );
+ assertEquals( 0x34, pageIos[1].getData().get( 9 ) );
+ assertEquals( 0x56, pageIos[1].getData().get( 10 ) );
+ assertEquals( 0x78, pageIos[1].getData().get( 11 ) );
+ }
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
