public abstract class AbstractJdbcRecordStore extends AbstractRecordStore implements JdbcRecordStore, RecordStoreExtension
| Modifier and Type | Field and Description |
|---|---|
static List<String> |
DEFAULT_PERMISSIONS |
| Constructor and Description |
|---|
AbstractJdbcRecordStore() |
AbstractJdbcRecordStore(DataSource dataSource) |
AbstractJdbcRecordStore(JdbcDatabaseFactory databaseFactory) |
AbstractJdbcRecordStore(JdbcDatabaseFactory databaseFactory,
RecordFactory recordFactory) |
AbstractJdbcRecordStore(RecordFactory recordFactory) |
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, toStringclearProperties, getProperties, getProperty, getProperty, removeProperty, setProperties, setProperty, setPropertySoft, setPropertyWeakclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitcreateReader, getLabel, getNextPrimaryKey, getNextPrimaryKey, getStatistics, setLabeladdCodeTable, 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, setRecordFactoryclearProperties, getProperties, getProperty, getProperty, removeProperty, setProperties, setProperty, setPropertySoft, setPropertyWeakpublic AbstractJdbcRecordStore()
public AbstractJdbcRecordStore(DataSource dataSource)
public AbstractJdbcRecordStore(JdbcDatabaseFactory databaseFactory)
public AbstractJdbcRecordStore(JdbcDatabaseFactory databaseFactory, RecordFactory recordFactory)
public AbstractJdbcRecordStore(RecordFactory recordFactory)
public static final AbstractIterator<Record> createJdbcIterator(AbstractJdbcRecordStore recordStore, Query query, Map<String,Object> properties)
protected void addAllSchemaNames(String schemaName)
public 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) throws SQLException
SQLExceptionpublic void addFieldAdder(String sqlTypeName, JdbcFieldAdder adder)
@PreDestroy public void close()
close in interface RecordStoreclose in interface AutoCloseableclose in class AbstractRecordStorepublic <T> T createPrimaryIdValue(String typePath)
createPrimaryIdValue in interface RecordStorecreatePrimaryIdValue in class AbstractRecordStoreprotected RecordStoreQueryReader createReader(Query query)
public JdbcWriter createWriter()
createWriter in interface RecordStorecreateWriter in interface JdbcRecordStorepublic JdbcWriter createWriter(int batchSize)
public int delete(Query query)
delete in interface RecordStoredelete in class AbstractRecordStorepublic void delete(Record record)
delete in interface RecordStoredelete in class AbstractRecordStorepublic void deleteAll(Collection<Record> records)
deleteAll in interface RecordStoredeleteAll in class AbstractRecordStorepublic int getBatchSize()
public String getDatabaseQualifiedTableName(String typePath)
getDatabaseQualifiedTableName in interface JdbcRecordStorepublic String getDatabaseSchemaName(RecordStoreSchema schema)
public String getDatabaseSchemaName(String schemaPath)
getDatabaseSchemaName in interface JdbcRecordStorepublic String getDatabaseTableName(String typePath)
getDatabaseTableName in interface JdbcRecordStoreprotected DataSource getDataSource()
public JdbcFieldDefinition getField(String schemaName, String tableName, String columnName)
public String getGeneratePrimaryKeySql(RecordDefinition recordDefinition)
getGeneratePrimaryKeySql in interface JdbcRecordStorepublic String getHints()
public JdbcConnection getJdbcConnection()
getJdbcConnection in interface JdbcRecordStorepublic JdbcConnection getJdbcConnection(boolean autoCommit)
getJdbcConnection in interface JdbcRecordStorepublic RecordDefinition getRecordDefinition(String typePath, ResultSetMetaData resultSetMetaData)
getRecordDefinition in interface JdbcRecordStorepublic int getRowCount(Query query)
getRowCount in interface RecordStoreprotected String getSequenceInsertSql(RecordDefinition recordDefinition)
public String getSqlPrefix()
public String getSqlSuffix()
public String getTablePermissionsSql()
public org.springframework.transaction.PlatformTransactionManager getTransactionManager()
getTransactionManager in interface RecordStoregetTransactionManager in class AbstractRecordStorepublic JdbcWriter getWriter()
getWriter in interface RecordStoregetWriter in class AbstractRecordStorepublic JdbcWriter getWriter(boolean throwExceptions)
getWriter in interface RecordStoregetWriter in class AbstractRecordStore@PostConstruct public void initialize()
initialize in interface RecordStoreinitialize in interface JdbcRecordStoreinitialize in class AbstractRecordStorepublic void initialize(RecordStore recordStore, Map<String,Object> connectionProperties)
initialize in interface RecordStoreExtensionpublic void insert(Record record)
insert in interface RecordStoreinsert in class AbstractRecordStorepublic void insertAll(Collection<Record> records)
insertAll in interface RecordStoreinsertAll in class AbstractRecordStorepublic boolean isAutoCommit()
public boolean isEditable(String typePath)
isEditable in interface RecordStoreisEditable in class AbstractRecordStorepublic boolean isEnabled(RecordStore recordStore)
isEnabled in interface RecordStoreExtensionpublic boolean isFlushBetweenTypes()
public abstract boolean isSchemaExcluded(String schemaName)
protected void loadSchemaTablePermissions(String schemaName, Map<String,List<String>> tablePermissionsMap, Map<String,String> tableDescriptionMap)
public ResultPager<Record> page(Query query)
page in interface RecordStorepage in class AbstractRecordStorepublic void postProcess(RecordStoreSchema schema)
postProcess in interface RecordStoreExtensionpublic void preProcess(RecordStoreSchema schema)
preProcess in interface RecordStoreExtensionprotected Map<String,? extends RecordStoreSchemaElement> refreshSchemaElements(RecordStoreSchema schema)
refreshSchemaElements in class AbstractRecordStorepublic void setBatchSize(int batchSize)
public void setCodeTables(List<AbstractCodeTable> codeTables)
public void setDataSource(DataSource dataSource)
public void setExcludeTablePaths(Collection<String> excludeTablePaths)
public void setExcludeTablePaths(String... excludeTablePaths)
public void setExcludeTablePatterns(String... excludeTablePatterns)
public void setFlushBetweenTypes(boolean flushBetweenTypes)
public void setHints(String hints)
public void setPrimaryKeySql(String primaryKeySql)
protected void setSchemaPermissionsSql(String scehmaPermissionsSql)
public void setSqlPrefix(String sqlPrefix)
public void setSqlSuffix(String sqlSuffix)
public void setTablePermissionsSql(String tablePermissionsSql)
public void update(Record record)
update in interface RecordStoreupdate in class AbstractRecordStorepublic void updateAll(Collection<Record> records)
updateAll in interface RecordStoreupdateAll in class AbstractRecordStoreprotected Record write(JdbcWriter writer, Record record, RecordState state)
protected void write(Record record, RecordState state)
protected void writeAll(Collection<Record> records, RecordState state)
Copyright © 2015 Revolution Systems Inc.. All rights reserved.