public class MappingCassandraConverter extends AbstractCassandraConverter implements CassandraConverter, ApplicationContextAware, BeanClassLoaderAware
InitializingBean
,
ApplicationContextAware
,
BeanClassLoaderAware
,
EntityConverter
,
EntityReader
,
EntityWriter
conversions, conversionService, instantiators
Constructor and Description |
---|
MappingCassandraConverter()
Creates a new
MappingCassandraConverter with a BasicCassandraMappingContext . |
MappingCassandraConverter(CassandraMappingContext mappingContext)
Creates a new
MappingCassandraConverter with the given CassandraMappingContext . |
Modifier and Type | Method and Description |
---|---|
Object |
convertToCassandraColumn(Object obj,
TypeInformation<?> typeInformation)
Converts the given object into one Cassandra will be able to store natively in a column.
|
Object |
getId(Object object,
CassandraPersistentEntity<?> entity)
Returns the Id for an entity.
|
CassandraMappingContext |
getMappingContext() |
protected Object |
instantiatePrimaryKey(CassandraPersistentEntity<?> entity,
CassandraPersistentProperty keyProperty,
CassandraValueProvider propertyProvider) |
<R> R |
read(Class<R> type,
Object row) |
protected <S> S |
readEntityFromRow(CassandraPersistentEntity<S> entity,
com.datastax.driver.core.Row row) |
protected <S> S |
readEntityFromUdt(CassandraPersistentEntity<S> entity,
com.datastax.driver.core.UDTValue udtValue) |
protected void |
readProperties(CassandraPersistentEntity<?> entity,
CassandraValueProvider valueProvider,
PersistentPropertyAccessor propertyAccessor) |
protected void |
readPropertiesFromRow(CassandraPersistentEntity<?> entity,
CassandraRowValueProvider row,
PersistentPropertyAccessor propertyAccessor) |
protected void |
readProperty(CassandraPersistentEntity<?> entity,
CassandraPersistentProperty property,
CassandraValueProvider valueProvider,
PersistentPropertyAccessor propertyAccessor) |
protected void |
readPropertyFromRow(CassandraPersistentEntity<?> entity,
CassandraPersistentProperty property,
CassandraRowValueProvider valueProvider,
PersistentPropertyAccessor propertyAccessor)
|
<R> R |
readRow(Class<R> type,
com.datastax.driver.core.Row row) |
void |
setApplicationContext(ApplicationContext applicationContext) |
void |
setBeanClassLoader(ClassLoader classLoader) |
protected <T> Class<T> |
transformClassToBeanClassLoaderClass(Class<T> entity) |
void |
write(Object source,
Object sink) |
void |
write(Object source,
Object sink,
CassandraPersistentEntity<?> entity)
|
protected void |
writeDeleteWhereFromObject(Object object,
com.datastax.driver.core.querybuilder.Delete.Where where,
CassandraPersistentEntity<?> entity) |
protected void |
writeInsertFromObject(Object object,
com.datastax.driver.core.querybuilder.Insert insert,
CassandraPersistentEntity<?> entity) |
protected void |
writeInsertFromWrapper(ConvertingPropertyAccessor accessor,
com.datastax.driver.core.querybuilder.Insert insert,
CassandraPersistentEntity<?> entity) |
protected void |
writeSelectWhereFromObject(Object object,
com.datastax.driver.core.querybuilder.Select.Where where,
CassandraPersistentEntity<?> entity) |
protected void |
writeUDTValueWhereFromObject(ConvertingPropertyAccessor accessor,
com.datastax.driver.core.UDTValue udtValue,
CassandraPersistentEntity<?> entity) |
protected void |
writeUpdateFromObject(Object object,
com.datastax.driver.core.querybuilder.Update update,
CassandraPersistentEntity<?> entity) |
protected void |
writeUpdateFromWrapper(ConvertingPropertyAccessor accessor,
com.datastax.driver.core.querybuilder.Update update,
CassandraPersistentEntity<?> entity) |
afterPropertiesSet, getConversionService, getCustomConversions, setCustomConversions, setInstantiators
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getCustomConversions
getConversionService
public MappingCassandraConverter()
MappingCassandraConverter
with a BasicCassandraMappingContext
.public MappingCassandraConverter(CassandraMappingContext mappingContext)
MappingCassandraConverter
with the given CassandraMappingContext
.mappingContext
- must not be null.public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
setApplicationContext
in interface ApplicationContextAware
BeansException
public void setBeanClassLoader(ClassLoader classLoader)
setBeanClassLoader
in interface BeanClassLoaderAware
public CassandraMappingContext getMappingContext()
getMappingContext
in interface CassandraConverter
getMappingContext
in interface EntityConverter<CassandraPersistentEntity<?>,CassandraPersistentProperty,Object,Object>
public <R> R readRow(Class<R> type, com.datastax.driver.core.Row row)
protected <S> S readEntityFromRow(CassandraPersistentEntity<S> entity, com.datastax.driver.core.Row row)
protected <S> S readEntityFromUdt(CassandraPersistentEntity<S> entity, com.datastax.driver.core.UDTValue udtValue)
protected void readPropertiesFromRow(CassandraPersistentEntity<?> entity, CassandraRowValueProvider row, PersistentPropertyAccessor propertyAccessor)
protected void readProperties(CassandraPersistentEntity<?> entity, CassandraValueProvider valueProvider, PersistentPropertyAccessor propertyAccessor)
@Deprecated protected void readPropertyFromRow(CassandraPersistentEntity<?> entity, CassandraPersistentProperty property, CassandraRowValueProvider valueProvider, PersistentPropertyAccessor propertyAccessor)
protected void readProperty(CassandraPersistentEntity<?> entity, CassandraPersistentProperty property, CassandraValueProvider valueProvider, PersistentPropertyAccessor propertyAccessor)
protected Object instantiatePrimaryKey(CassandraPersistentEntity<?> entity, CassandraPersistentProperty keyProperty, CassandraValueProvider propertyProvider)
public <R> R read(Class<R> type, Object row)
read
in interface EntityReader<Object,Object>
public Object convertToCassandraColumn(Object obj, TypeInformation<?> typeInformation)
CassandraConverter
convertToCassandraColumn
in interface CassandraConverter
obj
- Object
to convert; can be null.typeInformation
- TypeInformation
used to describe the object type; must not be null.public void write(Object source, Object sink)
write
in interface EntityWriter<Object,Object>
public void write(Object source, Object sink, CassandraPersistentEntity<?> entity)
CassandraConverter
write
in interface CassandraConverter
source
- the source, may be null.sink
- must not be null.entity
- must not be null.protected void writeInsertFromObject(Object object, com.datastax.driver.core.querybuilder.Insert insert, CassandraPersistentEntity<?> entity)
protected void writeInsertFromWrapper(ConvertingPropertyAccessor accessor, com.datastax.driver.core.querybuilder.Insert insert, CassandraPersistentEntity<?> entity)
protected void writeUpdateFromObject(Object object, com.datastax.driver.core.querybuilder.Update update, CassandraPersistentEntity<?> entity)
protected void writeUpdateFromWrapper(ConvertingPropertyAccessor accessor, com.datastax.driver.core.querybuilder.Update update, CassandraPersistentEntity<?> entity)
protected void writeSelectWhereFromObject(Object object, com.datastax.driver.core.querybuilder.Select.Where where, CassandraPersistentEntity<?> entity)
protected void writeDeleteWhereFromObject(Object object, com.datastax.driver.core.querybuilder.Delete.Where where, CassandraPersistentEntity<?> entity)
protected void writeUDTValueWhereFromObject(ConvertingPropertyAccessor accessor, com.datastax.driver.core.UDTValue udtValue, CassandraPersistentEntity<?> entity)
public Object getId(Object object, CassandraPersistentEntity<?> entity)
CassandraConverter
Id
or
PrimaryKey
IdMapId
for composite
PrimaryKeyColumn
Id'sPrimaryKey
using a
PrimaryKeyClass
getId
in interface CassandraConverter
object
- must not be null.entity
- must not be null.Copyright © 2011–2018 Pivotal Software, Inc.. All rights reserved.