songjinghe / temporal-storage Goto Github PK

    @Test
    public void test2fail0() throws Throwable {
        StoreBuilder stBuilder = new StoreBuilder(dbDir, true);
        store = stBuilder.store();

        for(int time=10; time<Integer.MAX_VALUE/100-6; time+=5){
            for(long entityId=1; entityId<5; entityId++){
                StoreBuilder.setIntProperty(store, time, entityId, 0, time);
            }
        }
        Slice val = store.getPointValue(1, 0, 9); // 1:entityid，0:proId，9:time
        if(val!=null) log.debug("{}", val.getInt(0));// val should be null, but can get 10
        store.shutDown();
    }

    @Test
    public void test2fail2() throws Throwable {
        StoreBuilder stBuilder = new StoreBuilder(dbDir, true);
        store = stBuilder.store();
        for(long entityId=1; entityId<5; entityId++){
            for(int proId=0; proId<Integer.MAX_VALUE/1000-6; proId+=5){
                StoreBuilder.setIntProperty(store, 0, entityId, proId, 0); // time为0
            }
            for(int proId=0; proId<Integer.MAX_VALUE/1000-6; proId+=3){
                StoreBuilder.setIntProperty(store, 10, entityId, proId, 10); // time为10
            }
            log.debug("version {} write finish", entityId);
        }
        Slice val = store.getPointValue(1, 3, 4); //1为entityid，3为proId，4为time
        log.debug("{}", val.getInt(0));
    }

    @Test
    public void test2fail() throws Throwable {
        this.store.getRangeValue(62254,1,0,Integer.MAX_VALUE-6, new CustomCallBack(62254){
            public void onCall(int time, Slice value) { log.info("{} {}", time, value.getInt(0));}
            public Object onReturn() { log.info("onReturn of test"); return null;}
        });
        log.info("=================");
        this.store.getRangeValue(62254,1,18360,18959, new CustomCallBack(62254){
            public void onCall(int time, Slice value) { log.info("{} {}", time, value.getInt(0));}
            public Object onReturn() { log.info("onReturn of test"); return null;}
        });
    }

    @Test
    public void test2fail() throws Throwable {
        StoreBuilder stBuilder = new StoreBuilder(dbDir, true);
        this.store = stBuilder.store();
        for(int version=1; version<5; version++){
            for(int time=0; time<Integer.MAX_VALUE/1000-6; time+=1){
                StoreBuilder.setIntProperty(store, time, 0, 0, version);
            }
            log.debug("version {} write finish", version);
        }
        EntityIdCallBack callback = new EntityIdCallBack();
        this.store.getRangeValue(0,0,0,Integer.MAX_VALUE/1000-6, callback);
    }

    private class EntityIdCallBack extends RangeQueryCallBack {
        public void onCall(int time, Slice value) {
            int val = value.getInt(0);
            if(val!=4){ // 这里会出现1,3但是没有2,不知道什么情况
                log.info("value not latest, get "+ val+" at time "+ time);
            }
        }
        public void setValueType(String valueType) {}
        public void onCallBatch(Slice batchValue) {}
        public Object onReturn() {
            return null;
        }
        public RangeQueryCallBack.CallBackType getType() {
            log.info("getType called");
            return RangeQueryCallBack.CallBackType.USER;
        }
    }