Examples of Conditional PUTS using the riak-java-client.

gistfile1.java

import com.basho.riak.client.IRiakClient;
import com.basho.riak.client.IRiakObject;
import com.basho.riak.client.RiakFactory;
import com.basho.riak.client.bucket.Bucket;
import com.basho.riak.client.builders.RiakObjectBuilder;


public class RiakSandbox {
	public static final String BUCKET_NAME = "conditionalPutTest";
	
	public static void main(String[] args) throws Exception {

		conditionalPutTestHTTP();
		conditionalPutTestPBC();
		return;
		
	}

	
	public static void conditionalPutTestPBC() throws Exception {
		// Create a riak client
		IRiakClient pbcClient = RiakFactory.pbcClient("127.0.0.1", 8081);

		Bucket myBucket = pbcClient.createBucket(BUCKET_NAME).execute();
		// Create an abject.
		IRiakObject riakObject = RiakObjectBuilder.
				newBuilder(BUCKET_NAME, "object-test").
				withValue("Value").
				build();
		
		IRiakObject riakObject2 = RiakObjectBuilder.
				newBuilder(BUCKET_NAME, "object-test").
				withValue("Value").
				build();
		try {
			riakObject = myBucket.store(riakObject).ifNoneMatch(true).returnBody(true).execute();		
			System.out.println(riakObject.getVtag());
			riakObject2 = myBucket.store(riakObject2).ifNoneMatch(true).returnBody(true).execute();
			System.out.println(riakObject2.getVtag());
			riakObject2 = myBucket.store(riakObject2).ifNoneMatch(true).returnBody(true).execute();
			System.out.println(riakObject2.getVtag());

			
		} catch (Exception e) {
			System.out.println("Exception "+e.getClass().getName());
		}
	
		myBucket.delete("object-test").execute();

	}
	
	public static void conditionalPutTestHTTP() throws Exception {
		// Create a riak client
		IRiakClient riakClient = RiakFactory.httpClient("http://127.0.0.1:8091/riak");

		Bucket myBucket = riakClient.createBucket(BUCKET_NAME).execute();
		// Create an abject.
		IRiakObject riakObject = RiakObjectBuilder.
				newBuilder(BUCKET_NAME, "object-test").
				withValue("Value").
				build();
		
		IRiakObject riakObject2 = RiakObjectBuilder.
				newBuilder(BUCKET_NAME, "object-test").
				withValue("Value").
				build();
		try {
			riakObject = myBucket.store(riakObject).ifNoneMatch(true).returnBody(true).execute();		
			System.out.println(riakObject.getVtag());
			riakObject2 = myBucket.store(riakObject2).ifNoneMatch(true).returnBody(true).execute();
			System.out.println(riakObject2.getVtag());
			riakObject2 = myBucket.store(riakObject2).ifNoneMatch(true).returnBody(true).execute();
			System.out.println(riakObject2.getVtag());

		} catch (Exception e) {
			System.out.println("Exception "+e.getClass().getName());
		}
	
		myBucket.delete("object-test").execute();

	}
	
}