com.revolsys.jdbc.io

Class AbstractJdbcRecordStore

java.lang.Object

com.revolsys.io.AbstractObjectWithProperties

com.revolsys.data.record.schema.AbstractRecordStore

com.revolsys.jdbc.io.AbstractJdbcRecordStore

All Implemented Interfaces:

RecordStoreExtension, RecordDefinitionFactory, RecordStore, ObjectWithProperties, JdbcRecordStore, AutoCloseable

public abstract class AbstractJdbcRecordStore
extends AbstractRecordStore
implements JdbcRecordStore, RecordStoreExtension

Field Summary

Fields

Modifier and Type	Field and Description
static List<String>	DEFAULT_PERMISSIONS

Constructor Summary

Constructors

Constructor and Description
AbstractJdbcRecordStore()
AbstractJdbcRecordStore(DataSource dataSource)
AbstractJdbcRecordStore(JdbcDatabaseFactory databaseFactory)
AbstractJdbcRecordStore(JdbcDatabaseFactory databaseFactory, RecordFactory recordFactory)
AbstractJdbcRecordStore(RecordFactory recordFactory)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addAllSchemaNames(String schemaName)
void	addExcludeTablePaths(String tableName)
protected JdbcFieldDefinition	addField(RecordDefinitionImpl recordDefinition, String dbColumnName, String name, String dataType, int sqlType, int length, int scale, boolean required, String description)
protected void	addField(ResultSetMetaData resultSetMetaData, RecordDefinitionImpl recordDefinition, String name, int i, String description)
void	addFieldAdder(String sqlTypeName, JdbcFieldAdder adder)
void	close()
static AbstractIterator<Record>	createJdbcIterator(AbstractJdbcRecordStore recordStore, Query query, Map<String,Object> properties)
<T> T	createPrimaryIdValue(String typePath)
protected RecordStoreQueryReader	createReader(Query query)
JdbcWriter	createWriter()
JdbcWriter	createWriter(int batchSize)
int	delete(Query query)
void	delete(Record record)
void	deleteAll(Collection<Record> records)
Set<String>	getAllSchemaNames()
int	getBatchSize()
List<String>	getColumnNames(String typePath)
String	getDatabaseQualifiedTableName(String typePath)
String	getDatabaseSchemaName(RecordStoreSchema schema)
String	getDatabaseSchemaName(String schemaPath)
protected Set<String>	getDatabaseSchemaNames()
String	getDatabaseTableName(String typePath)
protected DataSource	getDataSource()
Set<String>	getExcludeTablePaths()
JdbcFieldDefinition	getField(String schemaName, String tableName, String columnName)
String	getGeneratePrimaryKeySql(RecordDefinition recordDefinition)
String	getHints()
String	getIdFieldName(String typePath)
JdbcConnection	getJdbcConnection()
JdbcConnection	getJdbcConnection(boolean autoCommit)
RecordDefinition	getRecordDefinition(String typePath, ResultSetMetaData resultSetMetaData)
int	getRowCount(Query query)
protected String	getSequenceInsertSql(RecordDefinition recordDefinition)
String	getSqlPrefix()
String	getSqlSuffix()
String	getTablePermissionsSql()
org.springframework.transaction.PlatformTransactionManager	getTransactionManager()
JdbcWriter	getWriter()
JdbcWriter	getWriter(boolean throwExceptions)
void	initialize()
void	initialize(RecordStore recordStore, Map<String,Object> connectionProperties)
void	insert(Record record)
void	insertAll(Collection<Record> records)
boolean	isAutoCommit()
boolean	isEditable(String typePath)
boolean	isEnabled(RecordStore recordStore)
protected boolean	isExcluded(String dbSchemaName, String tableName)
boolean	isFlushBetweenTypes()
abstract boolean	isSchemaExcluded(String schemaName)
protected Map<String,List<String>>	loadIdColumnNames(String dbSchemaName)
protected void	loadSchemaTablePermissions(String schemaName, Map<String,List<String>> tablePermissionsMap, Map<String,String> tableDescriptionMap)
ResultPager<Record>	page(Query query)
void	postProcess(RecordStoreSchema schema)
void	preProcess(RecordStoreSchema schema)
protected Map<String,? extends RecordStoreSchemaElement>	refreshSchemaElements(RecordStoreSchema schema)
void	setBatchSize(int batchSize)
void	setCodeTables(List<AbstractCodeTable> codeTables)
void	setDataSource(DataSource dataSource)
void	setExcludeTablePaths(Collection<String> excludeTablePaths)
void	setExcludeTablePaths(String... excludeTablePaths)
void	setExcludeTablePatterns(String... excludeTablePatterns)
void	setFlushBetweenTypes(boolean flushBetweenTypes)
void	setHints(String hints)
void	setPrimaryKeySql(String primaryKeySql)
protected void	setSchemaPermissionsSql(String scehmaPermissionsSql)
void	setSqlPrefix(String sqlPrefix)
void	setSqlSuffix(String sqlSuffix)
void	setTablePermissionsSql(String tablePermissionsSql)
void	update(Record record)
void	updateAll(Collection<Record> records)
protected Record	write(JdbcWriter writer, Record record, RecordState state)
protected void	write(Record record, RecordState state)
protected void	writeAll(Collection<Record> records, RecordState state)

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

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

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.jdbc.io.JdbcRecordStore

createReader, getLabel, getNextPrimaryKey, getNextPrimaryKey, getStatistics, setLabel

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

addCodeTable, addCodeTables, addStatistic, addStatistic, appendQueryValue, copy, create, create, create, createQuery, createTransaction, createWithId, getCodeTable, getCodeTableByFieldName, getCodeTableByFieldNameMap, getGeometryFactory, getRecordDefinition, getRecordDefinition, getRecordFactory, getRootSchema, getSchema, getSchemas, getStatistics, getTypeNames, getTypes, getUrl, getUsername, hasSchema, load, load, lock, query, query, query, queryFirst, setLogCounts, setRecordFactory

Methods inherited from interface com.revolsys.io.ObjectWithProperties

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

Field Detail

DEFAULT_PERMISSIONS

public static final List<String> DEFAULT_PERMISSIONS

Constructor Detail

AbstractJdbcRecordStore

public AbstractJdbcRecordStore()

AbstractJdbcRecordStore

public AbstractJdbcRecordStore(DataSource dataSource)

AbstractJdbcRecordStore

public AbstractJdbcRecordStore(JdbcDatabaseFactory databaseFactory)

AbstractJdbcRecordStore

public AbstractJdbcRecordStore(JdbcDatabaseFactory databaseFactory,
                       RecordFactory recordFactory)

AbstractJdbcRecordStore

public AbstractJdbcRecordStore(RecordFactory recordFactory)

Method Detail

createJdbcIterator

public static final AbstractIterator<Record> createJdbcIterator(AbstractJdbcRecordStore recordStore,
                                          Query query,
                                          Map<String,Object> properties)

addAllSchemaNames

protected void addAllSchemaNames(String schemaName)

addExcludeTablePaths

public void addExcludeTablePaths(String tableName)

addField

protected JdbcFieldDefinition addField(RecordDefinitionImpl recordDefinition,
                           String dbColumnName,
                           String name,
                           String dataType,
                           int sqlType,
                           int length,
                           int scale,
                           boolean required,
                           String description)

addField

protected void addField(ResultSetMetaData resultSetMetaData,
            RecordDefinitionImpl recordDefinition,
            String name,
            int i,
            String description)
                 throws SQLException

Throws:

SQLException

addFieldAdder

public void addFieldAdder(String sqlTypeName,
                 JdbcFieldAdder adder)

close

@PreDestroy
public void close()

Specified by:

close in interface RecordStore

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractRecordStore

createPrimaryIdValue

public <T> T createPrimaryIdValue(String typePath)

Specified by:

createPrimaryIdValue in interface RecordStore

Overrides:

createPrimaryIdValue in class AbstractRecordStore

createReader

protected RecordStoreQueryReader createReader(Query query)

createWriter

public JdbcWriter createWriter()

Specified by:

createWriter in interface RecordStore

Specified by:

createWriter in interface JdbcRecordStore

createWriter

public JdbcWriter createWriter(int batchSize)

delete

public int delete(Query query)

Specified by:

delete in interface RecordStore

Overrides:

delete in class AbstractRecordStore

delete

public void delete(Record record)

Specified by:

delete in interface RecordStore

Overrides:

delete in class AbstractRecordStore

deleteAll

public void deleteAll(Collection<Record> records)

Specified by:

deleteAll in interface RecordStore

Overrides:

deleteAll in class AbstractRecordStore

getAllSchemaNames

public Set<String> getAllSchemaNames()

getBatchSize

public int getBatchSize()

getColumnNames

public List<String> getColumnNames(String typePath)

getDatabaseQualifiedTableName

public String getDatabaseQualifiedTableName(String typePath)

Specified by:

getDatabaseQualifiedTableName in interface JdbcRecordStore

getDatabaseSchemaName

public String getDatabaseSchemaName(RecordStoreSchema schema)

getDatabaseSchemaName

public String getDatabaseSchemaName(String schemaPath)

Specified by:

getDatabaseSchemaName in interface JdbcRecordStore

getDatabaseSchemaNames

protected Set<String> getDatabaseSchemaNames()

getDatabaseTableName

public String getDatabaseTableName(String typePath)

Specified by:

getDatabaseTableName in interface JdbcRecordStore

getDataSource

protected DataSource getDataSource()

getExcludeTablePaths

public Set<String> getExcludeTablePaths()

getField

public JdbcFieldDefinition getField(String schemaName,
                           String tableName,
                           String columnName)

getGeneratePrimaryKeySql

public String getGeneratePrimaryKeySql(RecordDefinition recordDefinition)

Specified by:

getGeneratePrimaryKeySql in interface JdbcRecordStore

getHints

public String getHints()

getIdFieldName

public String getIdFieldName(String typePath)

getJdbcConnection

public JdbcConnection getJdbcConnection()

Specified by:

getJdbcConnection in interface JdbcRecordStore

getJdbcConnection

public JdbcConnection getJdbcConnection(boolean autoCommit)

Specified by:

getJdbcConnection in interface JdbcRecordStore

getRecordDefinition

public RecordDefinition getRecordDefinition(String typePath,
                                   ResultSetMetaData resultSetMetaData)

Specified by:

getRecordDefinition in interface JdbcRecordStore

getRowCount

public int getRowCount(Query query)

Specified by:

getRowCount in interface RecordStore

getSequenceInsertSql

protected String getSequenceInsertSql(RecordDefinition recordDefinition)

getSqlPrefix

public String getSqlPrefix()

getSqlSuffix

public String getSqlSuffix()

getTablePermissionsSql

public String getTablePermissionsSql()

getTransactionManager

public org.springframework.transaction.PlatformTransactionManager getTransactionManager()

Specified by:

getTransactionManager in interface RecordStore

Overrides:

getTransactionManager in class AbstractRecordStore

getWriter

public JdbcWriter getWriter()

Specified by:

getWriter in interface RecordStore

Overrides:

getWriter in class AbstractRecordStore

getWriter

public JdbcWriter getWriter(boolean throwExceptions)

Specified by:

getWriter in interface RecordStore

Overrides:

getWriter in class AbstractRecordStore

initialize

@PostConstruct
public void initialize()

Specified by:

initialize in interface RecordStore

Specified by:

initialize in interface JdbcRecordStore

Overrides:

initialize in class AbstractRecordStore

initialize

public void initialize(RecordStore recordStore,
              Map<String,Object> connectionProperties)

Specified by:

initialize in interface RecordStoreExtension

insert

public void insert(Record record)

Specified by:

insert in interface RecordStore

Overrides:

insert in class AbstractRecordStore

insertAll

public void insertAll(Collection<Record> records)

Specified by:

insertAll in interface RecordStore

Overrides:

insertAll in class AbstractRecordStore

isAutoCommit

public boolean isAutoCommit()

isEditable

public boolean isEditable(String typePath)

Specified by:

isEditable in interface RecordStore

Overrides:

isEditable in class AbstractRecordStore

isEnabled

public boolean isEnabled(RecordStore recordStore)

Specified by:

isEnabled in interface RecordStoreExtension

isExcluded

protected boolean isExcluded(String dbSchemaName,
                 String tableName)

isFlushBetweenTypes

public boolean isFlushBetweenTypes()

isSchemaExcluded

public abstract boolean isSchemaExcluded(String schemaName)

loadIdColumnNames

protected Map<String,List<String>> loadIdColumnNames(String dbSchemaName)

loadSchemaTablePermissions

protected void loadSchemaTablePermissions(String schemaName,
                              Map<String,List<String>> tablePermissionsMap,
                              Map<String,String> tableDescriptionMap)

page

public ResultPager<Record> page(Query query)

Specified by:

page in interface RecordStore

Overrides:

page in class AbstractRecordStore

postProcess

public void postProcess(RecordStoreSchema schema)

Specified by:

postProcess in interface RecordStoreExtension

preProcess

public void preProcess(RecordStoreSchema schema)

Specified by:

preProcess in interface RecordStoreExtension

refreshSchemaElements

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

Overrides:

refreshSchemaElements in class AbstractRecordStore

setBatchSize

public void setBatchSize(int batchSize)

setCodeTables

public void setCodeTables(List<AbstractCodeTable> codeTables)

setDataSource

public void setDataSource(DataSource dataSource)

setExcludeTablePaths

public void setExcludeTablePaths(Collection<String> excludeTablePaths)

setExcludeTablePaths

public void setExcludeTablePaths(String... excludeTablePaths)

setExcludeTablePatterns

public void setExcludeTablePatterns(String... excludeTablePatterns)

setFlushBetweenTypes

public void setFlushBetweenTypes(boolean flushBetweenTypes)

setHints

public void setHints(String hints)

setPrimaryKeySql

public void setPrimaryKeySql(String primaryKeySql)

setSchemaPermissionsSql

protected void setSchemaPermissionsSql(String scehmaPermissionsSql)

setSqlPrefix

public void setSqlPrefix(String sqlPrefix)

setSqlSuffix

public void setSqlSuffix(String sqlSuffix)

setTablePermissionsSql

public void setTablePermissionsSql(String tablePermissionsSql)

update

public void update(Record record)

Specified by:

update in interface RecordStore

Overrides:

update in class AbstractRecordStore

updateAll

public void updateAll(Collection<Record> records)

Specified by:

updateAll in interface RecordStore

Overrides:

updateAll in class AbstractRecordStore

write

protected Record write(JdbcWriter writer,
           Record record,
           RecordState state)

write

protected void write(Record record,
         RecordState state)

writeAll

protected void writeAll(Collection<Record> records,
            RecordState state)