gudusoft.gsqlparser.dlineage.dataflow.model

Class ModelBindingManager

Object

gudusoft.gsqlparser.dlineage.dataflow.model.ModelBindingManager

public class ModelBindingManager
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
Map<String,Long>	DISPLAY_ID
Map<Long,String>	DISPLAY_NAME
long	RELATION_ID
long	TABLE_COLUMN_ID
int	virtualTableIndex
Map<String,String>	virtualTableNames

Constructor Summary

Constructors

Constructor and Description
ModelBindingManager()

Method Summary

Modifier and Type	Method and Description
void	addRelation(Relationship relation)
void	appendDblinkTable(String name)
void	bindCreateModel(String tableName, Table tableModel)
void	bindCreateModel(TObjectName tableName, Table tableModel)
void	bindCreateModel(TTable table, Table tableModel)
void	bindCursorIndex(TObjectName indexName, TObjectName cursorName)
void	bindCursorModel(TCursorDeclStmt stmt, Variable resultSet)
void	bindCursorModel(TForStmt stmt, Variable resultSet)
void	bindCursorModel(TLoopStmt stmt, Variable resultSet)
void	bindCursorModel(TMssqlDeclare stmt, Variable resultSet)
void	bindCursorModel(TOpenforStmt stmt, Variable resultSet)
void	bindInsertModel(Object gspModel, Object relationModel)
void	bindMergeModel(Object gspModel, Object relationModel)
void	bindModel(Object gspModel, Object relationModel)
void	bindOraclePackageByName(String oraclePackageName, OraclePackage oraclePackageModel)
void	bindProcedureByName(String procedureName, Procedure procedureModel)
void	bindProcessModel(TParseTreeNode gspModel, Object relationModel)
void	bindTableByName(String tableName, Table tableModel)
void	bindTableFunction(Object gspModel, Object functionTable)
void	bindUpdateModel(Object gspModel, Object relationModel)
void	bindViewModel(Object gspModel, Object relationModel)
void	cleanTempTable()
void	collectDynamicSqlHash(TCustomSqlStatement stmt)
void	collectSqlHash(TCustomSqlStatement stmt)
void	dropTable(Table table)
static ModelBindingManager	get()
List<TParseTreeNode>	getAliases()
List<TTable>	getBaseTables()
Table	getCreateModel(TTable table)
Table	getCreateTable(TTable table)
List<TCTE>	getCTEs()
List<TParseTreeNode>	getCursors()
Set<Table>	getDropTables()
Map	getDynamicSQLMap()
Set<Object>	getFunctionTable(Object gspModel)
List<TParseTreeNode>	getFunctoinCalls()
static String	getGlobalDatabase()
static String	getGlobalHash()
static Option	getGlobalOption()
static OraclePackage	getGlobalOraclePackage()
static TStoredProcedureSqlStatement	getGlobalProcedure()
static String	getGlobalSchema()
static String	getGlobalServer()
static TSQLEnv	getGlobalSQLEnv()
static IndexedLinkedHashMap<String,List<SqlInfo>>	getGlobalSqlInfo()
static Stack<TCustomSqlStatement>	getGlobalStmtStack()
static EDbVendor	getGlobalVendor()
Map	getHashSQLMap()
Object	getInsertModel(Object gspModel)
Object	getMergeModel(Object gspModel)
List<TParseTreeNode>	getMergeResultSets()
Object	getModel(Object gspModel)
OraclePackage	getOraclePackageByName(String oraclePackageName)
List<OraclePackage>	getOraclePackageModels()
List<TParseTreeNode>	getOutputResultSets()
List<TParseTreeNode>	getPivotdTables()
Procedure	getProcedureByName(String procedureName)
List<Procedure>	getProcedureModels()
List<TStoredProcedureSqlStatement>	getProcedures()
Process	getProcessModel(TParseTreeNode gspModel)
List<Process>	getProcessModels()
List<TObjectNameList>	getQueryAliasTables()
Relationship[]	getRelations()
Set<ResultSet>	getResultSets()
List<TResultColumnList>	getSelectResultSets()
List<TSelectSqlStatement>	getSelectSetResultSets()
String	getSqlHash(TCustomSqlStatement stmt)
TTable	getTable(TCustomSqlStatement stmt, TObjectName column)
Table	getTableByName(String tableName)
TObjectName[]	getTableColumns(TTable table)
TTable	getTableFromColumn(TObjectName column)
List<Table>	getTablesByName()
List<TTable>	getTableWithSelectSetResultSets()
Object	getUpdateModel(Object gspModel)
List<TParseTreeNode>	getUpdateResultSets()
Object	getViewModel(Object gspModel)
List<TCustomSqlStatement>	getViews()
TTable	guessTable(TCustomSqlStatement stmt, TObjectName column)
boolean	isDblinkTable(String name)
static void	remove()
static void	removeGlobalDatabase()
static void	removeGlobalHash()
static void	removeGlobalOption()
static void	removeGlobalOraclePackage()
static void	removeGlobalProcedure()
static void	removeGlobalSchema()
static void	removeGlobalSQLEnv()
static void	removeGlobalSqlInfo()
static void	removeGlobalStmtStack()
static void	removeGlobalVendor()
void	removeRelation(ImpactRelationship relation)
void	reset()
static void	set(ModelBindingManager modelManager)
static void	setGlobalDatabase(String database)
static void	setGlobalHash(String hash)
static void	setGlobalOption(Option option)
static void	setGlobalOraclePackage(OraclePackage currentOraclePackage)
static void	setGlobalProcedure(TStoredProcedureSqlStatement procedureSqlStatement)
static void	setGlobalSchema(String schema)
static void	setGlobalSQLEnv(TSQLEnv sqlenv)
static void	setGlobalSqlInfo(IndexedLinkedHashMap<String,List<SqlInfo>> sqlInfoMap)
static void	setGlobalStmtStack(Stack<TCustomSqlStatement> stack)
static void	setGlobalVendor(EDbVendor vendor)
void	unbindProcessModel(TParseTreeNode gspModel)
protected void	updateTableAliasMap(TTable table)

Methods inherited from class Object

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

Field Detail

DISPLAY_ID

public Map<String,Long> DISPLAY_ID

DISPLAY_NAME

public Map<Long,String> DISPLAY_NAME

virtualTableNames

public Map<String,String> virtualTableNames

TABLE_COLUMN_ID

public long TABLE_COLUMN_ID

RELATION_ID

public long RELATION_ID

virtualTableIndex

public int virtualTableIndex

Constructor Detail

ModelBindingManager

public ModelBindingManager()

Method Detail

set

public static void set(ModelBindingManager modelManager)

get

public static ModelBindingManager get()

setGlobalDatabase

public static void setGlobalDatabase(String database)

getGlobalDatabase

public static String getGlobalDatabase()

removeGlobalDatabase

public static void removeGlobalDatabase()

setGlobalSchema

public static void setGlobalSchema(String schema)

removeGlobalSchema

public static void removeGlobalSchema()

getGlobalSchema

public static String getGlobalSchema()

setGlobalHash

public static void setGlobalHash(String hash)

removeGlobalHash

public static void removeGlobalHash()

getGlobalHash

public static String getGlobalHash()

setGlobalOraclePackage

public static void setGlobalOraclePackage(OraclePackage currentOraclePackage)

removeGlobalOraclePackage

public static void removeGlobalOraclePackage()

getGlobalOraclePackage

public static OraclePackage getGlobalOraclePackage()

setGlobalProcedure

public static void setGlobalProcedure(TStoredProcedureSqlStatement procedureSqlStatement)

removeGlobalProcedure

public static void removeGlobalProcedure()

getGlobalProcedure

public static TStoredProcedureSqlStatement getGlobalProcedure()

setGlobalVendor

public static void setGlobalVendor(EDbVendor vendor)

removeGlobalVendor

public static void removeGlobalVendor()

getGlobalVendor

public static EDbVendor getGlobalVendor()

setGlobalSQLEnv

public static void setGlobalSQLEnv(TSQLEnv sqlenv)

removeGlobalSQLEnv

public static void removeGlobalSQLEnv()

getGlobalSQLEnv

public static TSQLEnv getGlobalSQLEnv()

getGlobalServer

public static String getGlobalServer()

setGlobalStmtStack

public static void setGlobalStmtStack(Stack<TCustomSqlStatement> stack)

removeGlobalStmtStack

public static void removeGlobalStmtStack()

setGlobalSqlInfo

public static void setGlobalSqlInfo(IndexedLinkedHashMap<String,List<SqlInfo>> sqlInfoMap)

removeGlobalSqlInfo

public static void removeGlobalSqlInfo()

getGlobalSqlInfo

public static IndexedLinkedHashMap<String,List<SqlInfo>> getGlobalSqlInfo()

setGlobalOption

public static void setGlobalOption(Option option)

getGlobalOption

public static Option getGlobalOption()

removeGlobalOption

public static void removeGlobalOption()

getGlobalStmtStack

public static Stack<TCustomSqlStatement> getGlobalStmtStack()

remove

public static void remove()

bindModel

public void bindModel(Object gspModel,
                      Object relationModel)

updateTableAliasMap

protected void updateTableAliasMap(TTable table)

getModel

public Object getModel(Object gspModel)

getProcedureModels

public List<Procedure> getProcedureModels()

getOraclePackageModels

public List<OraclePackage> getOraclePackageModels()

getProcessModels

public List<Process> getProcessModels()

bindProcessModel

public void bindProcessModel(TParseTreeNode gspModel,
                             Object relationModel)

unbindProcessModel

public void unbindProcessModel(TParseTreeNode gspModel)

getProcessModel

public Process getProcessModel(TParseTreeNode gspModel)

bindViewModel

public void bindViewModel(Object gspModel,
                          Object relationModel)

getViewModel

public Object getViewModel(Object gspModel)

bindUpdateModel

public void bindUpdateModel(Object gspModel,
                            Object relationModel)

getUpdateModel

public Object getUpdateModel(Object gspModel)

bindMergeModel

public void bindMergeModel(Object gspModel,
                           Object relationModel)

getMergeModel

public Object getMergeModel(Object gspModel)

bindInsertModel

public void bindInsertModel(Object gspModel,
                            Object relationModel)

getInsertModel

public Object getInsertModel(Object gspModel)

bindTableFunction

public void bindTableFunction(Object gspModel,
                              Object functionTable)

getFunctionTable

public Set<Object> getFunctionTable(Object gspModel)

getCreateTable

public Table getCreateTable(TTable table)

getCreateModel

public Table getCreateModel(TTable table)

bindCreateModel

public void bindCreateModel(TTable table,
                            Table tableModel)

bindCreateModel

public void bindCreateModel(TObjectName tableName,
                            Table tableModel)

bindCreateModel

public void bindCreateModel(String tableName,
                            Table tableModel)

getTableColumns

public TObjectName[] getTableColumns(TTable table)

getTableFromColumn

public TTable getTableFromColumn(TObjectName column)

getTable

public TTable getTable(TCustomSqlStatement stmt,
                       TObjectName column)

guessTable

public TTable guessTable(TCustomSqlStatement stmt,
                         TObjectName column)

getTablesByName

public List<Table> getTablesByName()

getBaseTables

public List<TTable> getBaseTables()

getViews

public List<TCustomSqlStatement> getViews()

getSelectResultSets

public List<TResultColumnList> getSelectResultSets()

getQueryAliasTables

public List<TObjectNameList> getQueryAliasTables()

getSelectSetResultSets

public List<TSelectSqlStatement> getSelectSetResultSets()

getCTEs

public List<TCTE> getCTEs()

getTableWithSelectSetResultSets

public List<TTable> getTableWithSelectSetResultSets()

getMergeResultSets

public List<TParseTreeNode> getMergeResultSets()

getOutputResultSets

public List<TParseTreeNode> getOutputResultSets()

getUpdateResultSets

public List<TParseTreeNode> getUpdateResultSets()

getFunctoinCalls

public List<TParseTreeNode> getFunctoinCalls()

getAliases

public List<TParseTreeNode> getAliases()

getCursors

public List<TParseTreeNode> getCursors()

getPivotdTables

public List<TParseTreeNode> getPivotdTables()

addRelation

public void addRelation(Relationship relation)

removeRelation

public void removeRelation(ImpactRelationship relation)

getRelations

public Relationship[] getRelations()

reset

public void reset()

bindCursorModel

public void bindCursorModel(TCursorDeclStmt stmt,
                            Variable resultSet)

bindCursorModel

public void bindCursorModel(TMssqlDeclare stmt,
                            Variable resultSet)

bindCursorModel

public void bindCursorModel(TOpenforStmt stmt,
                            Variable resultSet)

bindCursorModel

public void bindCursorModel(TForStmt stmt,
                            Variable resultSet)

bindCursorModel

public void bindCursorModel(TLoopStmt stmt,
                            Variable resultSet)

bindCursorIndex

public void bindCursorIndex(TObjectName indexName,
                            TObjectName cursorName)

getProcedures

public List<TStoredProcedureSqlStatement> getProcedures()

bindTableByName

public void bindTableByName(String tableName,
                            Table tableModel)

getTableByName

public Table getTableByName(String tableName)

bindProcedureByName

public void bindProcedureByName(String procedureName,
                                Procedure procedureModel)

getProcedureByName

public Procedure getProcedureByName(String procedureName)

bindOraclePackageByName

public void bindOraclePackageByName(String oraclePackageName,
                                    OraclePackage oraclePackageModel)

getOraclePackageByName

public OraclePackage getOraclePackageByName(String oraclePackageName)

getSqlHash

public String getSqlHash(TCustomSqlStatement stmt)

getHashSQLMap

public Map getHashSQLMap()

getDynamicSQLMap

public Map getDynamicSQLMap()

collectSqlHash

public void collectSqlHash(TCustomSqlStatement stmt)

collectDynamicSqlHash

public void collectDynamicSqlHash(TCustomSqlStatement stmt)

appendDblinkTable

public void appendDblinkTable(String name)

isDblinkTable

public boolean isDblinkTable(String name)

getResultSets

public Set<ResultSet> getResultSets()

dropTable

public void dropTable(Table table)

cleanTempTable

public void cleanTempTable()

getDropTables

public Set<Table> getDropTables()