org.b3log.latke.repository.redis

Class RedisRepository

java.lang.Object

org.b3log.latke.repository.redis.RedisRepository

All Implemented Interfaces:

Repository

public class RedisRepository
extends Object
implements Repository

Redis repository implementation.

Version:

1.1.0.1, Sep 4, 2016

Author:

Liang Ding

Field Summary

Fields

Modifier and Type	Field and Description
private static Logger	LOGGER Logger.
private String	name Repository name.
private boolean	writable Writable?

Constructor Summary

Constructors

Constructor and Description
RedisRepository(String name) Constructs a Redis repository with the specified name.

Method Summary

Methods

Modifier and Type	Method and Description
String	add(JSONObject jsonObject)
Transaction	beginTransaction()
long	count()
long	count(Query query)
Map<String,JSONObject>	get(Iterable<String> ids)
JSONObject	get(Query query)
JSONObject	get(String id)
static redis.clients.jedis.Jedis	getJedis() Gets the Redis client.
String	getName()
List<JSONObject>	getRandomly(int fetchSize)
boolean	has(String id)
boolean	hasTransactionBegun()
boolean	isWritable()
private Object	mapDataValue(String fieldName, String fieldValue) Maps the specified data.
void	remove(String id)
List<JSONObject>	select(String statement, Object... params)
void	setWritable(boolean writable)
void	update(String id, JSONObject jsonObject)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final Logger LOGGER

Logger.

name

private String name

Repository name.

writable

private boolean writable

Writable?

Constructor Detail

RedisRepository

public RedisRepository(String name)

Constructs a Redis repository with the specified name.

Parameters:

name - the specified name

Method Detail

add

public String add(JSONObject jsonObject)
           throws RepositoryException

Specified by:

add in interface Repository

Throws:

RepositoryException

update

public void update(String id,
          JSONObject jsonObject)
            throws RepositoryException

Specified by:

update in interface Repository

Throws:

RepositoryException

remove

public void remove(String id)
            throws RepositoryException

Specified by:

remove in interface Repository

Throws:

RepositoryException

get

public JSONObject get(String id)
               throws RepositoryException

Specified by:

get in interface Repository

Throws:

RepositoryException

get

public Map<String,JSONObject> get(Iterable<String> ids)
                           throws RepositoryException

Specified by:

get in interface Repository

Throws:

RepositoryException

has

public boolean has(String id)
            throws RepositoryException

Specified by:

has in interface Repository

Throws:

RepositoryException

get

public JSONObject get(Query query)
               throws RepositoryException

Specified by:

get in interface Repository

Throws:

RepositoryException

select

public List<JSONObject> select(String statement,
                      Object... params)
                        throws RepositoryException

Specified by:

select in interface Repository

Throws:

RepositoryException

getRandomly

public List<JSONObject> getRandomly(int fetchSize)
                             throws RepositoryException

Specified by:

getRandomly in interface Repository

Throws:

RepositoryException

count

public long count()
           throws RepositoryException

Specified by:

count in interface Repository

Throws:

RepositoryException

count

public long count(Query query)
           throws RepositoryException

Specified by:

count in interface Repository

Throws:

RepositoryException

getName

public String getName()

Specified by:

getName in interface Repository

beginTransaction

public Transaction beginTransaction()

Specified by:

beginTransaction in interface Repository

hasTransactionBegun

public boolean hasTransactionBegun()

Specified by:

hasTransactionBegun in interface Repository

isWritable

public boolean isWritable()

Specified by:

isWritable in interface Repository

setWritable

public void setWritable(boolean writable)

Specified by:

setWritable in interface Repository

getJedis

public static redis.clients.jedis.Jedis getJedis()

Gets the Redis client.

Returns:

Redis client

mapDataValue

private Object mapDataValue(String fieldName,
                  String fieldValue)

Maps the specified data.

Parameters:

fieldName - field name of the specified data

fieldValue - field value of the specified data

Returns:

mapped value