Skip to content
This repository was archived by the owner on May 3, 2022. It is now read-only.

Update Builder Example

Otávio Santana edited this page Feb 13, 2014 · 8 revisions

The Class ID

public class SimpleID {

@Column(name = "idbuilder")
private Integer key;

@Column(name = "indexbuilder")
private Integer index;

@ElementCollection
@Column(name = "mapbuilder")
private Map<String, String> map;

@ElementCollection
@Column(name = "listbuilder")
private List<String> list;

@ElementCollection
@Column(name = "setbuilder")
private Set<String> set;

//getter and setter
}

The Class

@Entity(name = "simplequerybuilder")
public class SimpleQueryBuilder {

@EmbeddedId
private SimpleID id = new SimpleID();

@Index
@Column(name = "namebuilder")
private String name;

@Column(name = "valuebuilder")
private Double value;

//getter and setter
}

Call method

You can create the UpdateBuider using CassandraTemplate or Persistence

Using org.easycassandra.persistence.cassandra.Persistence

Persistence = //inject
UpdateBuilder<YourClass> update = persistence.updateBuilder(Class<YourClass>);
UpdateBuilder<YourClass> update = persistence.updateBuilder(Class<YourClass>, key);

Using org.easycassandra.persistence.cassandra.spring.CassandraTemplate

CassandraTemplate template = //inject
UpdateBuilder<YourClass> update = template.updateBuilder(Class<YourClass>);
UpdateBuilder<YourClass> update = template.updateBuilder(Class<YourClass>, key);

Running samples

update by key

    SimpleID id = new SimpleID();
    id.setIndex(ONE_HUNDRED_THIRTY);
    id.setKey(ONE_HUNDRED_THIRTY);
    UpdateBuilder<SimpleQueryBuilder> update = template.updateBuilder(SimpleQueryBuilder.class, key);
    update.put("map", "name", "otavioMap").value("value", TEN_DOUBLE).execute();

add List

UpdateBuilder<SimpleQueryBuilder> update = persistence.updateBuilder(SimpleQueryBuilder.class);
 update.whereEq(Constant.KEY, Constant.ONE).whereEq(Constant.INDEX, Constant.ONE).addList("list", "otavioList").execute();

add Set

UpdateBuilder<SimpleQueryBuilder> update = persistence.updateBuilder(SimpleQueryBuilder.class);
 update.whereEq(Constant.KEY, Constant.ONE).whereEq(Constant.INDEX, Constant.ONE).addSet("set", "otavioSet").execute();

add Map

UpdateBuilder<SimpleQueryBuilder> update = persistence.updateBuilder(SimpleQueryBuilder.class);
 update.whereEq(Constant.KEY, Constant.ONE).whereEq(Constant.INDEX, Constant.ONE).put("map", "name", "otavioMap").execute();

set value

UpdateBuilder<SimpleQueryBuilder> update = persistence.updateBuilder(SimpleQueryBuilder.class);
 update.whereEq(Constant.KEY, Constant.ONE).whereEq(Constant.INDEX, Constant.ONE).value("value", 12D).execute();

async process

 UpdateBuilder<SimpleQueryBuilder> update = persistence.updateBuilder(SimpleQueryBuilder.class);
 update.whereEq(Constant.KEY, Constant.ONE).whereEq(Constant.INDEX, Constant.ONE).value("value", 12D).executeAsync();

async process with callback

 UpdateBuilder<SimpleQueryBuilder> update = persistence.updateBuilder(SimpleQueryBuilder.class);
 update.whereEq(Constant.KEY, Constant.ONE).whereEq(Constant.INDEX, Constant.ONE).value("value", 12D).executeAsync(new ResultAsyncCallBack<Boolean>() {
    @Override
    public void result(Boolean bean) {
        // do some action
    }
});

Clone this wiki locally