org.qbroker.net

Class RiakConnector

java.lang.Object

org.qbroker.net.RiakConnector

Direct Known Subclasses:

RiakMessenger

public class RiakConnector
extends java.lang.Object

RiakConnector connects to a Riak service and provides some basic Riak operation methods: list(), fetch(), store(), and delete().

This is NOT MT-Safe. Therefore, you need to use multiple instances to achieve your MT-Safty goal.

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
static int	ACTION_COUNT
static int	ACTION_DELETE
static int	ACTION_FETCH
static int	ACTION_LIST
static int	ACTION_STORE
protected java.lang.String	hostname
protected boolean	isConnected
protected java.lang.String	password
protected int	port
protected com.basho.riak.client.IRiakClient	riakClient
protected int	timeout
protected java.lang.String	uri
protected java.lang.String	username

Constructor Summary

Constructors

Constructor and Description
RiakConnector(java.util.Map props) Creates new RiakConnector

Method Summary

Modifier and Type	Method and Description
void	close() closes and shutdown the Riak client
int	delete(java.lang.String bucketName, java.lang.String key) deletes the key and returns number of keys removed or -1 on failure
com.basho.riak.client.IRiakObject	fetch(java.lang.String bucketName, java.lang.String key) returns IRiakObject for the key or null on failure
com.basho.riak.client.bucket.Bucket	fetchBucket(java.lang.String bucketName) returns the Bucket or null if name does not exist in Riak
java.lang.String	getURI()
boolean	isConnected()
java.lang.String[]	list() returns an array of all bucket names
static void	main(java.lang.String[] args) tests Riak basic operations
java.lang.String	reconnect() It reconnects and returns null or error message upon failure
java.lang.String	store(java.lang.String bucketName, java.lang.String key, java.lang.String data) returns id of the inserted doc or null on failure
java.lang.String	store(java.lang.String bucketName, java.lang.String key, java.lang.String data, java.util.Map<java.lang.String,java.lang.String> meta) returns id of the inserted doc with meta data or null on failure

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

hostname

protected java.lang.String hostname

username

protected java.lang.String username

password

protected java.lang.String password

uri

protected java.lang.String uri

port

protected int port

timeout

protected int timeout

isConnected

protected boolean isConnected

ACTION_LIST

public static final int ACTION_LIST

See Also:

Constant Field Values

ACTION_COUNT

public static final int ACTION_COUNT

See Also:

Constant Field Values

ACTION_FETCH

public static final int ACTION_FETCH

See Also:

Constant Field Values

ACTION_STORE

public static final int ACTION_STORE

See Also:

Constant Field Values

ACTION_DELETE

public static final int ACTION_DELETE

See Also:

Constant Field Values

riakClient

protected com.basho.riak.client.IRiakClient riakClient

Constructor Detail

RiakConnector

public RiakConnector(java.util.Map props)

Creates new RiakConnector

Method Detail

getURI

public java.lang.String getURI()

isConnected

public boolean isConnected()

reconnect

public java.lang.String reconnect()

It reconnects and returns null or error message upon failure

fetchBucket

public com.basho.riak.client.bucket.Bucket fetchBucket(java.lang.String bucketName)
                                                throws com.basho.riak.client.RiakException

returns the Bucket or null if name does not exist in Riak

Throws:

com.basho.riak.client.RiakException

fetch

public com.basho.riak.client.IRiakObject fetch(java.lang.String bucketName,
                                               java.lang.String key)
                                        throws com.basho.riak.client.RiakException

returns IRiakObject for the key or null on failure

Throws:

com.basho.riak.client.RiakException

store

public java.lang.String store(java.lang.String bucketName,
                              java.lang.String key,
                              java.lang.String data)
                       throws com.basho.riak.client.RiakException

returns id of the inserted doc or null on failure

Throws:

com.basho.riak.client.RiakException

store

public java.lang.String store(java.lang.String bucketName,
                              java.lang.String key,
                              java.lang.String data,
                              java.util.Map<java.lang.String,java.lang.String> meta)
                       throws com.basho.riak.client.RiakException

returns id of the inserted doc with meta data or null on failure

Throws:

com.basho.riak.client.RiakException

delete

public int delete(java.lang.String bucketName,
                  java.lang.String key)
           throws com.basho.riak.client.RiakException

deletes the key and returns number of keys removed or -1 on failure

Throws:

com.basho.riak.client.RiakException

list

public java.lang.String[] list()
                        throws com.basho.riak.client.RiakException

returns an array of all bucket names

Throws:

com.basho.riak.client.RiakException

close

public void close()

closes and shutdown the Riak client

main

public static void main(java.lang.String[] args)

tests Riak basic operations