public class MappingCassandraConverter extends AbstractCassandraConverter implements CassandraConverter, ApplicationContextAware, BeanClassLoaderAware
Modifier and Type | Field and Description |
---|---|
protected ApplicationContext |
applicationContext |
protected ClassLoader |
beanClassLoader |
protected org.slf4j.Logger |
log |
protected CassandraMappingContext |
mappingContext |
protected SpELContext |
spELContext |
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 |
getId(Object object,
CassandraPersistentEntity<?> entity) |
CassandraMappingContext |
getMappingContext() |
protected Object |
instantiatePrimaryKey(CassandraPersistentEntity<?> entity,
CassandraPersistentProperty keyProperty,
BasicCassandraRowValueProvider propertyProvider) |
<R> R |
read(Class<R> type,
Object row) |
protected <S> S |
readEntityFromRow(CassandraPersistentEntity<S> entity,
com.datastax.driver.core.Row row) |
protected void |
readPropertiesFromRow(CassandraPersistentEntity<?> entity,
BasicCassandraRowValueProvider row,
BeanWrapper<?> wrapper) |
protected void |
readPropertyFromRow(CassandraPersistentEntity<?> entity,
CassandraPersistentProperty prop,
BasicCassandraRowValueProvider row,
BeanWrapper<?> wrapper) |
<R> R |
readRow(Class<R> clazz,
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) |
protected void |
writeDeleteWhereFromObject(Object object,
com.datastax.driver.core.querybuilder.Delete.Where where,
CassandraPersistentEntity<?> entity) |
protected void |
writeDeleteWhereFromWrapper(BeanWrapper<Object> wrapper,
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(BeanWrapper<Object> wrapper,
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(BeanWrapper<Object> wrapper,
com.datastax.driver.core.querybuilder.Update update,
CassandraPersistentEntity<?> entity) |
afterPropertiesSet, getConversionService, setInstantiators
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConversionService
protected final org.slf4j.Logger log
protected final CassandraMappingContext mappingContext
protected ApplicationContext applicationContext
protected SpELContext spELContext
protected ClassLoader beanClassLoader
public MappingCassandraConverter()
MappingCassandraConverter
with a BasicCassandraMappingContext
.public MappingCassandraConverter(CassandraMappingContext mappingContext)
MappingCassandraConverter
with the given CassandraMappingContext
.mappingContext
- must not be null.public <R> R readRow(Class<R> clazz, com.datastax.driver.core.Row row)
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
setApplicationContext
in interface ApplicationContextAware
BeansException
protected <S> S readEntityFromRow(CassandraPersistentEntity<S> entity, com.datastax.driver.core.Row row)
protected void readPropertiesFromRow(CassandraPersistentEntity<?> entity, BasicCassandraRowValueProvider row, BeanWrapper<?> wrapper)
protected void readPropertyFromRow(CassandraPersistentEntity<?> entity, CassandraPersistentProperty prop, BasicCassandraRowValueProvider row, BeanWrapper<?> wrapper)
protected Object instantiatePrimaryKey(CassandraPersistentEntity<?> entity, CassandraPersistentProperty keyProperty, BasicCassandraRowValueProvider propertyProvider)
public <R> R read(Class<R> type, Object row)
read
in interface EntityReader<Object,Object>
public void write(Object source, Object sink)
write
in interface EntityWriter<Object,Object>
protected void writeInsertFromObject(Object object, com.datastax.driver.core.querybuilder.Insert insert, CassandraPersistentEntity<?> entity)
protected void writeInsertFromWrapper(BeanWrapper<Object> wrapper, 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(BeanWrapper<Object> wrapper, com.datastax.driver.core.querybuilder.Update update, CassandraPersistentEntity<?> entity)
protected void writeDeleteWhereFromObject(Object object, com.datastax.driver.core.querybuilder.Delete.Where where, CassandraPersistentEntity<?> entity)
protected void writeDeleteWhereFromWrapper(BeanWrapper<Object> wrapper, com.datastax.driver.core.querybuilder.Delete.Where where, CassandraPersistentEntity<?> entity)
public Object getId(Object object, CassandraPersistentEntity<?> entity)
getId
in interface CassandraConverter
protected <T> Class<T> transformClassToBeanClassLoaderClass(Class<T> entity)
public void setBeanClassLoader(ClassLoader classLoader)
setBeanClassLoader
in interface BeanClassLoaderAware
public CassandraMappingContext getMappingContext()
getMappingContext
in interface CassandraConverter
getMappingContext
in interface EntityConverter<CassandraPersistentEntity<?>,CassandraPersistentProperty,Object,Object>
Copyright © 2011-2014–2015 Pivotal Software, Inc.. All rights reserved.