org.teiid.query.metadata

Class DatabaseStore

java.lang.Object

org.teiid.query.metadata.DatabaseStore

Direct Known Subclasses:

DeploymentBasedDatabaseStore

public abstract class DatabaseStore
extends Object

This holds the local state of all Database instances.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DatabaseStore.Mode

Field Summary

Fields

Modifier and Type	Field and Description
protected int	count
protected Schema	currentSchema

Constructor Summary

Constructors

Constructor and Description
DatabaseStore()

Method Summary

Modifier and Type	Method and Description
void	addOrSetOption(String recordName, Database.ResourceType type, String childName, Database.ResourceType childType, String key, String value, boolean reload)
void	addOrSetOption(String recordName, Database.ResourceType type, String key, String value, boolean reload)
void	alterBaseColumn(String objectName, Database.ResourceType type, String childName, SQLParserUtil.ParsedDataType datatype, boolean autoIncrement, boolean notNull)
protected boolean	assertInEditMode(DatabaseStore.Mode current)
void	createDomain(String name, String baseType, Integer length, Integer scale, boolean notNull)
static MetadataFactory	createMF(DatabaseStore events)
static MetadataFactory	createMF(DatabaseStore events, Schema schema, boolean useSchema, Properties modelProperties)
void	createNameSpace(String prefix, String uri)
void	databaseCreated(Database db)
void	databaseSwitched(String dbName, String version)
void	dataWrapperCreated(DataWrapper wrapper)
void	dataWrapperDropped(String wrapperName)
void	enableTableTriggerPlan(String tableName, Table.TriggerEvent event, boolean enable)
void	functionCreated(FunctionMethod function)
void	functionDropped(String functionName, Boolean virtual)
protected Database	getCurrentDatabase()
NamespaceContainer	getCurrentNamespaceContainer() Get the NamespaceContainer associated with the current database - this instance should not be modified unless in an edit context.
protected Schema	getCurrentSchema()
Database	getDatabase(String dbName, String version)
List<Database>	getDatabases()
Map<String,String>	getNameSpaces()
abstract Map<String,Datatype>	getRuntimeTypes()
Schema	getSchema(String schemaName)
AbstractMetadataRecord	getSchemaRecord(String name, Database.ResourceType type)
Server	getServer(String serverName)
Table	getTableForCreateColumn(String objectName, Database.ResourceType type)
protected TransformationMetadata	getTransformationMetadata()
void	grantCreated(Grant grant)
void	grantRevoked(Grant grant)
void	importDatabase(String dbName, String version, boolean importPolicies)
void	importSchema(String schemaName, String serverType, String serverName, String foreignSchemaName, List<String> includeTables, List<String> excludeTables, Map<String,String> properties)
void	modifyTableName(String name, Database.ResourceType type, String newName)
void	procedureCreated(Procedure procedure)
void	procedureDropped(String procedureName, Boolean virtual)
void	removeColumn(String objectName, Database.ResourceType type, String childName)
void	removeOption(String recordName, Database.ResourceType type, String key)
void	removeOption(String recordName, Database.ResourceType type, String childName, Database.ResourceType childType, String key)
void	renameBaseColumn(String objectName, Database.ResourceType type, String oldName, String newName)
void	roleCreated(Role role)
void	roleDropped(String roleName)
void	schemaCreated(Schema schema, List<String> serverNames)
void	schemaDropped(String schemaName, Boolean virtual)
void	schemaSwitched(String schemaName)
void	serverCreated(Server server)
void	serverDropped(String serverName)
void	setMode(DatabaseStore.Mode mode)
void	setProcedureDefinition(String procedureName, String definition)
void	setStrict(boolean strict)
void	setTableTriggerPlan(String triggerName, String tableName, Table.TriggerEvent event, String triggerDefinition, boolean isAfter)
void	setViewDefinition(String tableName, String definition)
protected boolean	shouldValidateDatabaseBeforeDeploy()
void	startEditing(boolean persist)
void	stopEditing()
void	tableCreated(Table table)
void	tableDropped(String tableName, boolean globalTemp, boolean view)
protected void	verifyCurrentDatabaseIsNotSame(String dbName, String version)
protected void	verifyDatabaseExists()
protected FunctionMethod	verifyFunctionExists(String functionName)
protected Role	verifyRoleExists(String roleName)
protected Schema	verifySchemaExists(String schemaName)
protected Server	verifyServerExists(String serverName)

Methods inherited from class java.lang.Object

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

Field Detail

currentSchema

protected Schema currentSchema

count

protected int count

Constructor Detail

DatabaseStore

public DatabaseStore()

Method Detail

getRuntimeTypes

public abstract Map<String,Datatype> getRuntimeTypes()

startEditing

public void startEditing(boolean persist)

stopEditing

public void stopEditing()
                 throws MetadataException

Throws:

MetadataException

getSchema

public Schema getSchema(String schemaName)

getServer

public Server getServer(String serverName)

databaseCreated

public void databaseCreated(Database db)

setMode

public void setMode(DatabaseStore.Mode mode)

setStrict

public void setStrict(boolean strict)

assertInEditMode

protected boolean assertInEditMode(DatabaseStore.Mode current)

databaseSwitched

public void databaseSwitched(String dbName,
                             String version)

shouldValidateDatabaseBeforeDeploy

protected boolean shouldValidateDatabaseBeforeDeploy()

schemaCreated

public void schemaCreated(Schema schema,
                          List<String> serverNames)

schemaDropped

public void schemaDropped(String schemaName,
                          Boolean virtual)

verifyFunctionExists

protected FunctionMethod verifyFunctionExists(String functionName)

verifySchemaExists

protected Schema verifySchemaExists(String schemaName)

verifyServerExists

protected Server verifyServerExists(String serverName)

verifyDatabaseExists

protected void verifyDatabaseExists()

verifyCurrentDatabaseIsNotSame

protected void verifyCurrentDatabaseIsNotSame(String dbName,
                                              String version)

schemaSwitched

public void schemaSwitched(String schemaName)

dataWrapperCreated

public void dataWrapperCreated(DataWrapper wrapper)

dataWrapperDropped

public void dataWrapperDropped(String wrapperName)

serverCreated

public void serverCreated(Server server)

serverDropped

public void serverDropped(String serverName)

getCurrentSchema

protected Schema getCurrentSchema()

getCurrentDatabase

protected Database getCurrentDatabase()

getDatabase

public Database getDatabase(String dbName,
                            String version)

getDatabases

public List<Database> getDatabases()

tableCreated

public void tableCreated(Table table)

setViewDefinition

public void setViewDefinition(String tableName,
                              String definition)

modifyTableName

public void modifyTableName(String name,
                            Database.ResourceType type,
                            String newName)

removeColumn

public void removeColumn(String objectName,
                         Database.ResourceType type,
                         String childName)

tableDropped

public void tableDropped(String tableName,
                         boolean globalTemp,
                         boolean view)

procedureCreated

public void procedureCreated(Procedure procedure)

setProcedureDefinition

public void setProcedureDefinition(String procedureName,
                                   String definition)

procedureDropped

public void procedureDropped(String procedureName,
                             Boolean virtual)

functionCreated

public void functionCreated(FunctionMethod function)

functionDropped

public void functionDropped(String functionName,
                            Boolean virtual)

setTableTriggerPlan

public void setTableTriggerPlan(String triggerName,
                                String tableName,
                                Table.TriggerEvent event,
                                String triggerDefinition,
                                boolean isAfter)

enableTableTriggerPlan

public void enableTableTriggerPlan(String tableName,
                                   Table.TriggerEvent event,
                                   boolean enable)

createNameSpace

public void createNameSpace(String prefix,
                            String uri)

createDomain

public void createDomain(String name,
                         String baseType,
                         Integer length,
                         Integer scale,
                         boolean notNull)

getNameSpaces

public Map<String,String> getNameSpaces()

addOrSetOption

public void addOrSetOption(String recordName,
                           Database.ResourceType type,
                           String key,
                           String value,
                           boolean reload)

getSchemaRecord

public AbstractMetadataRecord getSchemaRecord(String name,
                                              Database.ResourceType type)

getTransformationMetadata

protected TransformationMetadata getTransformationMetadata()

removeOption

public void removeOption(String recordName,
                         Database.ResourceType type,
                         String key)

addOrSetOption

public void addOrSetOption(String recordName,
                           Database.ResourceType type,
                           String childName,
                           Database.ResourceType childType,
                           String key,
                           String value,
                           boolean reload)

removeOption

public void removeOption(String recordName,
                         Database.ResourceType type,
                         String childName,
                         Database.ResourceType childType,
                         String key)

importSchema

public void importSchema(String schemaName,
                         String serverType,
                         String serverName,
                         String foreignSchemaName,
                         List<String> includeTables,
                         List<String> excludeTables,
                         Map<String,String> properties)

importDatabase

public void importDatabase(String dbName,
                           String version,
                           boolean importPolicies)

verifyRoleExists

protected Role verifyRoleExists(String roleName)

roleCreated

public void roleCreated(Role role)

roleDropped

public void roleDropped(String roleName)

grantCreated

public void grantCreated(Grant grant)

grantRevoked

public void grantRevoked(Grant grant)

renameBaseColumn

public void renameBaseColumn(String objectName,
                             Database.ResourceType type,
                             String oldName,
                             String newName)

alterBaseColumn

public void alterBaseColumn(String objectName,
                            Database.ResourceType type,
                            String childName,
                            SQLParserUtil.ParsedDataType datatype,
                            boolean autoIncrement,
                            boolean notNull)

createMF

public static MetadataFactory createMF(DatabaseStore events,
                                       Schema schema,
                                       boolean useSchema,
                                       Properties modelProperties)

createMF

public static MetadataFactory createMF(DatabaseStore events)

getTableForCreateColumn

public Table getTableForCreateColumn(String objectName,
                                     Database.ResourceType type)

getCurrentNamespaceContainer

public NamespaceContainer getCurrentNamespaceContainer()

Get the NamespaceContainer associated with the current database - this instance should not be modified unless in an edit context.