@Component(value="cassandra-client") public class CassandraClient extends Object
Constructor and Description |
---|
CassandraClient() |
Modifier and Type | Method and Description |
---|---|
void |
closeClient() |
fj.data.Either<org.apache.commons.lang3.tuple.ImmutablePair<com.datastax.driver.core.Session,com.datastax.driver.mapping.MappingManager>,CassandraOperationStatus> |
connect(String keyspace) |
<T> CassandraOperationStatus |
delete(String id,
Class<T> clazz,
com.datastax.driver.mapping.MappingManager manager) |
<T> fj.data.Either<T,CassandraOperationStatus> |
getById(String id,
Class<T> clazz,
com.datastax.driver.mapping.MappingManager manager) |
boolean |
isConnected() |
<T> CassandraOperationStatus |
save(T entity,
Class<T> clazz,
com.datastax.driver.mapping.MappingManager manager) |
public fj.data.Either<org.apache.commons.lang3.tuple.ImmutablePair<com.datastax.driver.core.Session,com.datastax.driver.mapping.MappingManager>,CassandraOperationStatus> connect(String keyspace)
keyspace
- - key space to connectpublic <T> CassandraOperationStatus save(T entity, Class<T> clazz, com.datastax.driver.mapping.MappingManager manager)
public <T> fj.data.Either<T,CassandraOperationStatus> getById(String id, Class<T> clazz, com.datastax.driver.mapping.MappingManager manager)
public <T> CassandraOperationStatus delete(String id, Class<T> clazz, com.datastax.driver.mapping.MappingManager manager)
public boolean isConnected()
@PreDestroy public void closeClient()
Copyright © 2017. All rights reserved.