Package org.xtreemfs.babudb.api.database

Examples of org.xtreemfs.babudb.api.database.Database.lookup()

234
235
236
237
238
239
240
241
242
243
244
        result = db.lookup(1, "Key2".getBytes(), null).get();
        assertNotNull(result);
        value = new String(result);
        assertEquals(value, "Value2");
       
        result = db.lookup(2, "Key3".getBytes(), null).get();
        assertNotNull(result);
        value = new String(result);
        assertEquals(value, "Value3");
       
        System.out.println("shutting down database...");
View Full Code Here
258
259
260
261
262
263
264
265
266
267
268
        ir.addInsert(2, "Key3".getBytes(), "Value3".getBytes());
        db.insert(ir, null).get();
       
        database.getCheckpointer().checkpoint();
       
        byte[] result = db.lookup(0, "Key1".getBytes(), null).get();
        assertNotNull(result);
        String value = new String(result);
        assertEquals(value, "Value1");
       
        result = db.lookup(1, "Key2".getBytes(), null).get();
View Full Code Here
263
264
265
266
267
268
269
270
271
272
273
        byte[] result = db.lookup(0, "Key1".getBytes(), null).get();
        assertNotNull(result);
        String value = new String(result);
        assertEquals(value, "Value1");
       
        result = db.lookup(1, "Key2".getBytes(), null).get();
        assertEquals("Value2", new String(result));
       
        result = db.lookup(2, "Key3".getBytes(), null).get();
        assertEquals("Value3", new String(result));
       
View Full Code Here
266
267
268
269
270
271
272
273
274
275
276
        assertEquals(value, "Value1");
       
        result = db.lookup(1, "Key2".getBytes(), null).get();
        assertEquals("Value2", new String(result));
       
        result = db.lookup(2, "Key3".getBytes(), null).get();
        assertEquals("Value3", new String(result));
       
        Iterator<Entry<byte[], byte[]>> iter = db.prefixLookup(3, "Key3".getBytes(), null).get();
        assertFalse(iter.hasNext());
       
View Full Code Here
347
348
349
350
351
352
353
354
355
356
357
       
        database.getCheckpointer().checkpoint();
       
        for (int i = 0; i < 100000; i++) {
           
            byte[] v0 = db.lookup(0, (i + "").getBytes(), null).get();
            byte[] v1 = db.lookup(1, (i + "").getBytes(), null).get();
           
            assertEquals("bla", new String(v0));
            assertEquals("bla", new String(v1));
        }
View Full Code Here
348
349
350
351
352
353
354
355
356
357
358
        database.getCheckpointer().checkpoint();
       
        for (int i = 0; i < 100000; i++) {
           
            byte[] v0 = db.lookup(0, (i + "").getBytes(), null).get();
            byte[] v1 = db.lookup(1, (i + "").getBytes(), null).get();
           
            assertEquals("bla", new String(v0));
            assertEquals("bla", new String(v1));
        }
       
View Full Code Here
387
388
389
390
391
392
393
394
395
396
397
       
        database.getCheckpointer().checkpoint();
       
        for (int i = 0; i < 1000; i++) {
           
            byte[] v0 = db.lookup(0, (i + "").getBytes(), null).get();
            byte[] v1 = db.lookup(1, (i + "").getBytes(), null).get();
            byte[] v2 = db.lookup(2, (i + "").getBytes(), null).get();
           
            assertNotNull(v0);
            assertNotNull(v1);
View Full Code Here
388
389
390
391
392
393
394
395
396
397
398
        database.getCheckpointer().checkpoint();
       
        for (int i = 0; i < 1000; i++) {
           
            byte[] v0 = db.lookup(0, (i + "").getBytes(), null).get();
            byte[] v1 = db.lookup(1, (i + "").getBytes(), null).get();
            byte[] v2 = db.lookup(2, (i + "").getBytes(), null).get();
           
            assertNotNull(v0);
            assertNotNull(v1);
            assertNotNull(v2);
View Full Code Here
389
390
391
392
393
394
395
396
397
398
399
       
        for (int i = 0; i < 1000; i++) {
           
            byte[] v0 = db.lookup(0, (i + "").getBytes(), null).get();
            byte[] v1 = db.lookup(1, (i + "").getBytes(), null).get();
            byte[] v2 = db.lookup(2, (i + "").getBytes(), null).get();
           
            assertNotNull(v0);
            assertNotNull(v1);
            assertNotNull(v2);
        }
View Full Code Here
406
407
408
409
410
411
412
413
414
415
416
            db.insert(ir, null).get();
        }
       
        for (int i = 0; i < 1000; i++) {
           
            byte[] v0 = db.lookup(0, (i + "").getBytes(), null).get();
            byte[] v1 = db.lookup(1, (i + "").getBytes(), null).get();
            byte[] v2 = db.lookup(2, (i + "").getBytes(), null).get();
           
            assertNull(v0);
            assertNull(v1);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.