com.revolsys.data.record.schema

Class AbstractRecordStore

java.lang.Object

com.revolsys.io.AbstractObjectWithProperties

com.revolsys.data.record.schema.AbstractRecordStore

All Implemented Interfaces:

RecordDefinitionFactory, RecordStore, ObjectWithProperties, AutoCloseable

Direct Known Subclasses:

AbstractJdbcRecordStore, CapiFileGdbRecordStore, CsvRecordStore, DelegatingRecordStore, DirectoryRecordStore, OgrRecordStore, ShapefileRecordStore

public abstract class AbstractRecordStore
extends AbstractObjectWithProperties
implements RecordStore

Constructor Summary

Constructors

Constructor and Description
AbstractRecordStore()
AbstractRecordStore(RecordFactory recordFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	addCodeTable(CodeTable codeTable)
void	addCodeTable(String columnName, CodeTable codeTable)
void	addCodeTables(Collection<CodeTable> codeTables)
protected void	addRecordDefinition(RecordDefinition recordDefinition)
protected void	addRecordDefinitionProperties(RecordDefinitionImpl recordDefinition)
void	addRecordStoreExtension(RecordStoreExtension extension)
void	addStatistic(String statisticName, Record object)
void	addStatistic(String statisticName, String typePath, int count)
void	appendQueryValue(Query query, StringBuilder sql, QueryValue queryValue)
void	close()
Record	copy(Record record)
Record	create(RecordDefinition objectRecordDefinition)
Record	create(String typePath)
Record	create(String typePath, Map<String,? extends Object> values)
AbstractIterator<Record>	createIterator(Query query, Map<String,Object> properties)
<T> T	createPrimaryIdValue(String typePath)
Query	createQuery(String typePath, String whereClause, BoundingBoxDoubleGf boundingBox)
RecordStoreQueryReader	createReader()
Transaction	createTransaction(Propagation propagation)
Record	createWithId(RecordDefinition recordDefinition)
int	delete(Query query)
void	delete(Record object)
void	deleteAll(Collection<Record> objects)
protected RecordDefinition	findRecordDefinition(String typePath)
<V extends CodeTable> V	getCodeTable(String typePath)
CodeTable	getCodeTableByFieldName(String columnName)
Map<String,CodeTable>	getCodeTableByFieldNameMap()
Map<String,List<String>>	getCodeTableColumNames()
protected Map<String,Object>	getConnectionProperties()
GeometryFactory	getGeometryFactory()
RecordStoreIteratorFactory	getIteratorFactory()
String	getLabel()
RecordDefinition	getRecordDefinition(RecordDefinition objectRecordDefinition)
RecordDefinition	getRecordDefinition(String typePath) Get the meta data for the specified type.
RecordFactory	getRecordFactory()
Collection<RecordStoreExtension>	getRecordStoreExtensions()
RecordStoreSchema	getRootSchema()
RecordStoreSchema	getSchema(String path)
List<RecordStoreSchema>	getSchemas() Get the list of name space names provided by the record store.
protected <T> T	getSharedAttribute(String name)
protected Map<String,Object>	getSharedAttributes()
StatisticsMap	getStatistics()
Statistics	getStatistics(String name)
String	getString(Object name)
org.springframework.transaction.PlatformTransactionManager	getTransactionManager()
List<String>	getTypeNames(String schemaName) Get the list of type names (including name space) in the name space.
List<RecordDefinition>	getTypes(String namespace)
String	getUrl()
String	getUsername()
Writer<Record>	getWriter()
Writer<Record>	getWriter(boolean throwExceptions)
boolean	hasSchema(String schemaName)
void	initialize()
void	insert(Record record)
void	insertAll(Collection<Record> objects)
boolean	isEditable(String typePath)
Record	load(String typePath, Identifier id)
Record	load(String typePath, Object... id)
Record	lock(String typePath, Object id)
ResultPager<Record>	page(Query query)
Reader<Record>	query(List<?> queries)
Reader<Record>	query(Query... queries)
Reader<Record>	query(String path)
Record	queryFirst(Query query)
protected void	refreshSchema()
protected void	refreshSchema(String schemaName)
protected Map<String,? extends RecordStoreSchemaElement>	refreshSchemaElements(RecordStoreSchema schema)
void	setCodeTableColumNames(Map<String,List<String>> domainColumNames)
void	setCommonRecordDefinitionProperties(List<RecordDefinitionProperty> commonRecordDefinitionProperties)
protected void	setConnectionProperties(Map<String,? extends Object> connectionProperties)
void	setGeometryFactory(GeometryFactory geometryFactory)
void	setIteratorFactory(RecordStoreIteratorFactory iteratorFactory)
void	setLabel(String label)
void	setLogCounts(boolean logCounts)
void	setRecordFactory(RecordFactory recordFactory)
protected void	setSharedAttribute(String name, Object value)
void	setTypeRecordDefinitionProperties(Map<String,List<RecordDefinitionProperty>> typeRecordDefinitionProperties)
String	toString()
void	update(Record object)
void	updateAll(Collection<Record> objects)

Methods inherited from class com.revolsys.io.AbstractObjectWithProperties

clearProperties, getProperties, getProperty, getProperty, removeProperty, setProperties, setProperty, setPropertySoft, setPropertyWeak

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.revolsys.data.record.schema.RecordStore

createWriter, getRowCount

Methods inherited from interface com.revolsys.io.ObjectWithProperties

clearProperties, getProperties, getProperty, getProperty, removeProperty, setProperties, setProperty, setPropertySoft, setPropertyWeak

Constructor Detail

AbstractRecordStore

public AbstractRecordStore()

AbstractRecordStore

public AbstractRecordStore(RecordFactory recordFactory)

Method Detail

addCodeTable

public void addCodeTable(CodeTable codeTable)

Specified by:

addCodeTable in interface RecordStore

addCodeTable

public void addCodeTable(String columnName,
                CodeTable codeTable)

addCodeTables

public void addCodeTables(Collection<CodeTable> codeTables)

Specified by:

addCodeTables in interface RecordStore

addRecordDefinition

protected void addRecordDefinition(RecordDefinition recordDefinition)

addRecordDefinitionProperties

protected void addRecordDefinitionProperties(RecordDefinitionImpl recordDefinition)

addRecordStoreExtension

public void addRecordStoreExtension(RecordStoreExtension extension)

addStatistic

public void addStatistic(String statisticName,
                Record object)

Specified by:

addStatistic in interface RecordStore

addStatistic

public void addStatistic(String statisticName,
                String typePath,
                int count)

Specified by:

addStatistic in interface RecordStore

appendQueryValue

public void appendQueryValue(Query query,
                    StringBuilder sql,
                    QueryValue queryValue)

Specified by:

appendQueryValue in interface RecordStore

close

@PreDestroy
public void close()

Specified by:

close in interface RecordStore

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractObjectWithProperties

copy

public Record copy(Record record)

Specified by:

copy in interface RecordStore

create

public Record create(RecordDefinition objectRecordDefinition)

Specified by:

create in interface RecordStore

create

public Record create(String typePath)

Specified by:

create in interface RecordStore

create

public Record create(String typePath,
            Map<String,? extends Object> values)

Specified by:

create in interface RecordStore

createIterator

public AbstractIterator<Record> createIterator(Query query,
                                      Map<String,Object> properties)

createPrimaryIdValue

public <T> T createPrimaryIdValue(String typePath)

Specified by:

createPrimaryIdValue in interface RecordStore

createQuery

public Query createQuery(String typePath,
                String whereClause,
                BoundingBoxDoubleGf boundingBox)

Specified by:

createQuery in interface RecordStore

createReader

public RecordStoreQueryReader createReader()

createTransaction

public Transaction createTransaction(Propagation propagation)

Specified by:

createTransaction in interface RecordStore

createWithId

public Record createWithId(RecordDefinition recordDefinition)

Specified by:

createWithId in interface RecordStore

delete

public int delete(Query query)

Specified by:

delete in interface RecordStore

delete

public void delete(Record object)

Specified by:

delete in interface RecordStore

deleteAll

public void deleteAll(Collection<Record> objects)

Specified by:

deleteAll in interface RecordStore

findRecordDefinition

protected RecordDefinition findRecordDefinition(String typePath)

getCodeTable

public <V extends CodeTable> V getCodeTable(String typePath)

Specified by:

getCodeTable in interface RecordStore

getCodeTableByFieldName

public CodeTable getCodeTableByFieldName(String columnName)

Specified by:

getCodeTableByFieldName in interface RecordStore

getCodeTableByFieldNameMap

public Map<String,CodeTable> getCodeTableByFieldNameMap()

Specified by:

getCodeTableByFieldNameMap in interface RecordStore

getCodeTableColumNames

public Map<String,List<String>> getCodeTableColumNames()

getConnectionProperties

protected Map<String,Object> getConnectionProperties()

getGeometryFactory

public GeometryFactory getGeometryFactory()

Specified by:

getGeometryFactory in interface RecordStore

getIteratorFactory

public RecordStoreIteratorFactory getIteratorFactory()

getLabel

public String getLabel()

Specified by:

getLabel in interface RecordStore

getRecordDefinition

public RecordDefinition getRecordDefinition(RecordDefinition objectRecordDefinition)

Specified by:

getRecordDefinition in interface RecordStore

getRecordDefinition

public RecordDefinition getRecordDefinition(String typePath)

Description copied from interface: RecordStore

Get the meta data for the specified type.

Specified by:

getRecordDefinition in interface RecordDefinitionFactory

Specified by:

getRecordDefinition in interface RecordStore

Parameters:

typePath - The type name.

Returns:

The meta data.

getRecordFactory

public RecordFactory getRecordFactory()

Specified by:

getRecordFactory in interface RecordStore

getRecordStoreExtensions

public Collection<RecordStoreExtension> getRecordStoreExtensions()

getRootSchema

public RecordStoreSchema getRootSchema()

Specified by:

getRootSchema in interface RecordStore

getSchema

public RecordStoreSchema getSchema(String path)

Specified by:

getSchema in interface RecordStore

getSchemas

public List<RecordStoreSchema> getSchemas()

Description copied from interface: RecordStore

Get the list of name space names provided by the record store.

Specified by:

getSchemas in interface RecordStore

Returns:

The name space names.

getSharedAttribute

protected <T> T getSharedAttribute(String name)

getSharedAttributes

protected Map<String,Object> getSharedAttributes()

getStatistics

public StatisticsMap getStatistics()

Specified by:

getStatistics in interface RecordStore

getStatistics

public Statistics getStatistics(String name)

Specified by:

getStatistics in interface RecordStore

getString

public String getString(Object name)

getTransactionManager

public org.springframework.transaction.PlatformTransactionManager getTransactionManager()

Specified by:

getTransactionManager in interface RecordStore

getTypeNames

public List<String> getTypeNames(String schemaName)

Description copied from interface: RecordStore

Get the list of type names (including name space) in the name space.

Specified by:

getTypeNames in interface RecordStore

Parameters:

schemaName - The name space.

Returns:

The type names.

getTypes

public List<RecordDefinition> getTypes(String namespace)

Specified by:

getTypes in interface RecordStore

getUrl

public String getUrl()

Specified by:

getUrl in interface RecordStore

getUsername

public String getUsername()

Specified by:

getUsername in interface RecordStore

getWriter

public Writer<Record> getWriter()

Specified by:

getWriter in interface RecordStore

getWriter

public Writer<Record> getWriter(boolean throwExceptions)

Specified by:

getWriter in interface RecordStore

hasSchema

public boolean hasSchema(String schemaName)

Specified by:

hasSchema in interface RecordStore

initialize

@PostConstruct
public void initialize()

Specified by:

initialize in interface RecordStore

insert

public void insert(Record record)

Specified by:

insert in interface RecordStore

insertAll

public void insertAll(Collection<Record> objects)

Specified by:

insertAll in interface RecordStore

isEditable

public boolean isEditable(String typePath)

Specified by:

isEditable in interface RecordStore

load

public Record load(String typePath,
          Identifier id)

Specified by:

load in interface RecordStore

load

public Record load(String typePath,
          Object... id)

Specified by:

load in interface RecordStore

lock

public Record lock(String typePath,
          Object id)

Specified by:

lock in interface RecordStore

page

public ResultPager<Record> page(Query query)

Specified by:

page in interface RecordStore

query

public Reader<Record> query(List<?> queries)

Specified by:

query in interface RecordStore

query

public Reader<Record> query(Query... queries)

Specified by:

query in interface RecordStore

query

public Reader<Record> query(String path)

Specified by:

query in interface RecordStore

queryFirst

public Record queryFirst(Query query)

Specified by:

queryFirst in interface RecordStore

refreshSchema

protected void refreshSchema()

refreshSchema

protected void refreshSchema(String schemaName)

refreshSchemaElements

protected Map<String,? extends RecordStoreSchemaElement> refreshSchemaElements(RecordStoreSchema schema)

setCodeTableColumNames

public void setCodeTableColumNames(Map<String,List<String>> domainColumNames)

setCommonRecordDefinitionProperties

public void setCommonRecordDefinitionProperties(List<RecordDefinitionProperty> commonRecordDefinitionProperties)

setConnectionProperties

protected void setConnectionProperties(Map<String,? extends Object> connectionProperties)

setGeometryFactory

public void setGeometryFactory(GeometryFactory geometryFactory)

setIteratorFactory

public void setIteratorFactory(RecordStoreIteratorFactory iteratorFactory)

setLabel

public void setLabel(String label)

Specified by:

setLabel in interface RecordStore

setLogCounts

public void setLogCounts(boolean logCounts)

Specified by:

setLogCounts in interface RecordStore

setRecordFactory

public void setRecordFactory(RecordFactory recordFactory)

Specified by:

setRecordFactory in interface RecordStore

setSharedAttribute

protected void setSharedAttribute(String name,
                      Object value)

setTypeRecordDefinitionProperties

public void setTypeRecordDefinitionProperties(Map<String,List<RecordDefinitionProperty>> typeRecordDefinitionProperties)

toString

public String toString()

Overrides:

toString in class Object

update

public void update(Record object)

Specified by:

update in interface RecordStore

updateAll

public void updateAll(Collection<Record> objects)

Specified by:

updateAll in interface RecordStore