xmartlabs / rxsimplenosql Goto Github PK

bucket.newQuery()
        .filter(sampleBean -> sampleBean.getName().startsWith("S"))
        .delete()
        .subscribe();

 Completable completable = Completable.concat(
                                Observable.from(deletedItems)
                                    .map(item -> localBucket
                                                    .newQuery()
                                                    .entityId(item.getId())
                                                    .delete()));
return completable.andThen(Observable.just(true));

public String getName() {
    return name;
}

public void setName(String name) {
    this.name = name;
}

@Override
public String getId() {
    return id;
}

public void setId(String id) {
    this.id = id;
}

public Map<String, Integer> getMapping() {
    return mapping;
}

public void setMapping(Map<String, Integer> mapping) {
    this.mapping = mapping;
}

class sss{
    Bucket<SampleBean> bucket;
    public sss(Context context){
        Bucket<SampleBean> bucket = new Bucket<>(context, SampleBean.class, "bucketId");
    }

    public void single(){
        SampleBean entity = new SampleBean();
        entity.setId("1");
        entity.setName("Colin");
        Map<String, Integer> birthday = new HashMap<String, Integer>();
        birthday.put("day", 17);
        birthday.put("month", 2);
        birthday.put("year", 1982);
        entity.setMapping(birthday);

        bucket.newQuery()
                .save(entity)
                .subscribe();
    }
}