Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package org.mapdb;
  
  import org.junit.Test;
  
  import java.util.Map;
  
  import static org.junit.Assert.*;
  
  public class TxEngineTest {
 
     TxEngine e = new TxEngine(new StoreWAL(Volume.memoryFactory(false, 0L)),false);
 
     @Test public void update(){
         long recid = .put(111, .);
         .commit();
         Engine snapshot = .snapshot();
         .update(recid, 222, .);
         assertEquals(Integer.valueOf(111), snapshot.get(recid.));
     }
 
     @Test public void compareAndSwap(){
         long recid = .put(111, .);
         .commit();
         Engine snapshot = .snapshot();
         .compareAndSwap(recid, 111, 222, .);
         assertEquals(Integer.valueOf(111), snapshot.get(recid.));
     }
 
     @Test public void delete(){
         long recid = .put(111, .);
         .commit();
         Engine snapshot = .snapshot();
         .delete(recid.);
         assertEquals(Integer.valueOf(111), snapshot.get(recid.));
     }
 
     @Test public void notExist(){
         Engine snapshot = .snapshot();
         long recid = .put(111, .);
         assertNull(snapshot.get(recid.));
     }
 
 
     @Test public void create_snapshot(){
         Engine e = DBMaker.newMemoryDB().snapshotEnable().makeEngine();
         Engine snapshot = TxEngine.createSnapshotFor(e);
         assertNotNull(snapshot);
     }
 
     @Test public void DB_snapshot(){
         DB db = DBMaker.newMemoryDB().snapshotEnable().asyncFlushDelay(100).transactionDisable().make();
         long recid = db.getEngine().put("aa".);
         DB db2 = db.snapshot();
         assertEquals("aa"db2.getEngine().get(recid,.));
         db.getEngine().update(recid"bb",.);
         assertEquals("aa"db2.getEngine().get(recid.));
     }
 
     @Test public void DB_snapshot2(){
         DB db = DBMaker.newMemoryDB().transactionDisable().snapshotEnable().make();
         long recid = db.getEngine().put("aa",.);
         DB db2 = db.snapshot();
         assertEquals("aa"db2.getEngine().get(recid,.));
         db.getEngine().update(recid"bb",.);
         assertEquals("aa"db2.getEngine().get(recid,.));
     }
 
 
     @Test public void BTreeMap_snapshot(){
         BTreeMap map =
                 DBMaker.newMemoryDB().transactionDisable().snapshotEnable()
                 .make().getTreeMap("aaa");
         map.put("aa","aa");
         Map map2 = map.snapshot();
         map.put("aa","bb");
         assertEquals("aa",map2.get("aa"));
     }
 
     @Test public void HTreeMap_snapshot(){
         HTreeMap map =
                 DBMaker.newMemoryDB().transactionDisable().snapshotEnable()
                 .make().getHashMap("aaa");
         map.put("aa","aa");
         Map map2 = map.snapshot();
         map.put("aa""bb");
         assertEquals("aa",map2.get("aa"));
     }
 
 //    @Test public void test_stress(){
 //        ExecutorService ex = Executors.newCachedThreadPool();
 //
 //        TxMaker tx = DBMaker.newMemoryDB().transactionDisable().makeTxMaker();
 //
 //        DB db = tx.makeTx();
 //        final long recid =
 //
 //        final int threadNum = 32;
 //        for(int i=0;i<threadNum;i++){
 //            ex.execute(new Runnable() { @Override public void run() {
//
//            }});
//        }
//    }
New to GrepCode? Check out our FAQ X