Class WriteAheadLogTest

src/test/java/org/mapdb/WriteAheadLogTest.java:13–518

import static org.junit.Assert.*;

public class WriteAheadLogTest {


    @Test
    public void null_record() {
        testRecord(11111L, null);
    }

    @Test
    public void zero_record() {
        testRecord(11111L, new byte[0]);
    }

    @Test
    public void ten_record() {
        testRecord(11111L, TT.randomByteArray(10,0));
    }


    @Test
    public void large_record() {
        testRecord(11111L, TT.randomByteArray(1000000,0));
    }


    void testRecord(final long recid, final byte[] data) {
        WriteAheadLog wal = new WriteAheadLog(null);
        wal.open(WriteAheadLog.NOREPLAY);
        wal.startNextFile();

        final AtomicBoolean called = new AtomicBoolean();

        final long pointer = wal.walPutRecord(recid, data, 0, data == null ? 0 : data.length);

        for (int i = 0; i < 1; i++) {
            byte[] val = wal.walGetRecord(pointer, recid);

            if (data == null)
                assertNull(val);
            else
                assertTrue(Arrays.equals(data, val));
            wal.seal();
        }

        WriteAheadLog.WALReplay r = new WriteAheadLog.WALReplay() {
            @Override
            public void beforeReplayStart() {
            }

            @Override
            public void afterReplayFinished() {

            }

            @Override
            public void writeLong(long offset, long value) {
                fail();
            }