com.revolsys.io.directory

Class DirectoryRecordStore

java.lang.Object

com.revolsys.io.AbstractObjectWithProperties

com.revolsys.data.record.schema.AbstractRecordStore

com.revolsys.io.directory.DirectoryRecordStore

All Implemented Interfaces:

RecordDefinitionFactory, RecordStore, ObjectWithProperties, AutoCloseable

public class DirectoryRecordStore
extends AbstractRecordStore

Constructor Summary

Constructors

Constructor and Description
DirectoryRecordStore(File directory, Collection<String> fileExtensions)
DirectoryRecordStore(File directory, String... fileExtensions)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
AbstractIterator<Record>	createIterator(Query query, Map<String,Object> properties)
Writer<Record>	createWriter()
void	delete(Record record)
File	getDirectory()
String	getFileExtension()
List<String>	getFileExtensions()
RecordDefinition	getRecordDefinition(RecordDefinition recordDefinition)
protected org.springframework.core.io.Resource	getResource(String path)
protected org.springframework.core.io.Resource	getResource(String path, RecordDefinition recordDefinition)
int	getRowCount(Query query)
Writer<Record>	getWriter()
void	initialize()
void	insert(Record record)
boolean	isCreateMissingRecordStore()
boolean	isCreateMissingTables()
protected RecordDefinition	loadRecordDefinition(RecordStoreSchema schema, String schemaName, org.springframework.core.io.Resource resource)
RecordReader	query(String path)
protected Map<String,RecordStoreSchemaElement>	refreshSchemaElements(RecordStoreSchema schema)
void	setCreateMissingRecordStore(boolean createMissingRecordStore)
void	setCreateMissingTables(boolean createMissingTables)
void	setDirectory(File directory)
protected void	setFileExtensions(List<String> fileExtensions)
protected void	superDelete(Record record)
protected void	superUpdate(Record record)
String	toString()
void	update(Record record)

Methods inherited from class com.revolsys.data.record.schema.AbstractRecordStore

addCodeTable, addCodeTable, addCodeTables, addRecordDefinition, addRecordDefinitionProperties, addRecordStoreExtension, addStatistic, addStatistic, appendQueryValue, copy, create, create, create, createPrimaryIdValue, createQuery, createReader, createTransaction, createWithId, delete, deleteAll, findRecordDefinition, getCodeTable, getCodeTableByFieldName, getCodeTableByFieldNameMap, getCodeTableColumNames, getConnectionProperties, getGeometryFactory, getIteratorFactory, getLabel, getRecordDefinition, getRecordFactory, getRecordStoreExtensions, getRootSchema, getSchema, getSchemas, getSharedAttribute, getSharedAttributes, getStatistics, getStatistics, getString, getTransactionManager, getTypeNames, getTypes, getUrl, getUsername, getWriter, hasSchema, insertAll, isEditable, load, load, lock, page, query, query, queryFirst, refreshSchema, refreshSchema, setCodeTableColumNames, setCommonRecordDefinitionProperties, setConnectionProperties, setGeometryFactory, setIteratorFactory, setLabel, setLogCounts, setRecordFactory, setSharedAttribute, setTypeRecordDefinitionProperties, updateAll

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.io.ObjectWithProperties

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

Constructor Detail

DirectoryRecordStore

public DirectoryRecordStore(File directory,
                    Collection<String> fileExtensions)

DirectoryRecordStore

public DirectoryRecordStore(File directory,
                    String... fileExtensions)

Method Detail

close

public void close()

Specified by:

close in interface RecordStore

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractRecordStore

createIterator

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

Overrides:

createIterator in class AbstractRecordStore

createWriter

public Writer<Record> createWriter()

delete

public void delete(Record record)

Specified by:

delete in interface RecordStore

Overrides:

delete in class AbstractRecordStore

getDirectory

public File getDirectory()

getFileExtension

public String getFileExtension()

getFileExtensions

public List<String> getFileExtensions()

getRecordDefinition

public RecordDefinition getRecordDefinition(RecordDefinition recordDefinition)

Specified by:

getRecordDefinition in interface RecordStore

Overrides:

getRecordDefinition in class AbstractRecordStore

getResource

protected org.springframework.core.io.Resource getResource(String path)

getResource

protected org.springframework.core.io.Resource getResource(String path,
                                               RecordDefinition recordDefinition)

getRowCount

public int getRowCount(Query query)

getWriter

public Writer<Record> getWriter()

Specified by:

getWriter in interface RecordStore

Overrides:

getWriter in class AbstractRecordStore

initialize

@PostConstruct
public void initialize()

Specified by:

initialize in interface RecordStore

Overrides:

initialize in class AbstractRecordStore

insert

public void insert(Record record)

Specified by:

insert in interface RecordStore

Overrides:

insert in class AbstractRecordStore

isCreateMissingRecordStore

public boolean isCreateMissingRecordStore()

isCreateMissingTables

public boolean isCreateMissingTables()

loadRecordDefinition

protected RecordDefinition loadRecordDefinition(RecordStoreSchema schema,
                                    String schemaName,
                                    org.springframework.core.io.Resource resource)

query

public RecordReader query(String path)

Specified by:

query in interface RecordStore

Overrides:

query in class AbstractRecordStore

refreshSchemaElements

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

Overrides:

refreshSchemaElements in class AbstractRecordStore

setCreateMissingRecordStore

public void setCreateMissingRecordStore(boolean createMissingRecordStore)

setCreateMissingTables

public void setCreateMissingTables(boolean createMissingTables)

setDirectory

public void setDirectory(File directory)

setFileExtensions

protected void setFileExtensions(List<String> fileExtensions)

superDelete

protected void superDelete(Record record)

superUpdate

protected void superUpdate(Record record)

toString

public String toString()

Overrides:

toString in class AbstractRecordStore

update

public void update(Record record)

Specified by:

update in interface RecordStore

Overrides:

update in class AbstractRecordStore