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	addPendingPipelinedCallSite(PendingPipelinedCallSite callSite)
void	addPipelinedSignature(PipelinedFunctionSignature sig)
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)
PipelinedFunctionSignature	findPipelinedSignature(List<String> candidates, int argCount)
PipelinedFunctionSignature	findPipelinedSignatureAny(List<String> candidates)
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()
static String	getEffectiveDefaultDatabase() Resolve the effective default database (catalog) used to qualify unqualified / partial object names, with a three-tier precedence: the active global database — an in-script USE database, or the per-group database set by DataFlowAnalyzer; the per-analysis Option.getDefaultDatabase(); the attached TSQLEnv default catalog; TSQLEnv.DEFAULT_DB_NAME. Each lower tier is consulted only when the higher tier is null/empty.
static String	getEffectiveDefaultSchema() The schema an unqualified name defaults to right now.
String	getElementTypeName(String collectionName)
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)
List<String>	getObjectTypeFields(String normalizedName)
OraclePackage	getOraclePackageByName(String oraclePackageName)
List<OraclePackage>	getOraclePackageModels()
List<TParseTreeNode>	getOutputResultSets()
List<PendingPipelinedCallSite>	getPendingPipelinedCallSites()
Map<String,List<PipelinedFunctionSignature>>	getPipelinedSignatures()
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<String>	getResolvingPipelinedFunctions()
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	hasIdentityScope()
void	indexCollectionType(String collectionName, String elementTypeName)
void	indexObjectType(String normalizedName, List<String> fieldNames)
boolean	isDblinkTable(String name)
static boolean	isGlobalSchemaUnset() Whether the statement being analyzed right now has no current schema because a Snowflake USE <database> unset it.
String	peekIdentityScope()
void	popIdentityScope()
void	pushIdentityScope(String identityScopeKey)
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)
static void	removeSchemaUnsetStatements()
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)
static void	setSchemaUnsetStatements(Set<TCustomSqlStatement> statements) The statements that a Snowflake USE <database> left with NO current schema, i.e.
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()

setSchemaUnsetStatements

public static void setSchemaUnsetStatements(Set<TCustomSqlStatement> statements)

The statements that a Snowflake USE <database> left with NO current schema, i.e. everything after such a switch up to the next schema switch.

Recorded as a set of statements rather than as a running flag on purpose. The analyzer walks the statement list several times - one pass for CREATE TABLE, another for views, another for procedures - replaying the USE statements in each. A running flag set during one pass is still set when a LATER pass reaches a statement that precedes the switch, so it would apply the clearing backwards and strip an already-exact qualification off a statement that ran while the old schema was still current. Keyed by statement, the answer is the same no matter which pass asks.

See GitHub #715 / MantisBT 4677.

removeSchemaUnsetStatements

public static void removeSchemaUnsetStatements()

isGlobalSchemaUnset

public static boolean isGlobalSchemaUnset()

Whether the statement being analyzed right now has no current schema because a Snowflake USE <database> unset it.

See Also:

setSchemaUnsetStatements(Set)

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()

getEffectiveDefaultDatabase

public static String getEffectiveDefaultDatabase()

Resolve the effective default database (catalog) used to qualify unqualified / partial object names, with a three-tier precedence:

1. the active global database — an in-script USE database, or the per-group database set by DataFlowAnalyzer;
2. the per-analysis Option.getDefaultDatabase();
3. the attached TSQLEnv default catalog;
4. TSQLEnv.DEFAULT_DB_NAME.

Each lower tier is consulted only when the higher tier is null/empty. This lets a shared multi-catalog TSQLEnv be reused across analyses with different per-analysis default databases (tier 2) without mutating the env, while still honoring an in-script USE database (tier 1).

getEffectiveDefaultSchema

public static String getEffectiveDefaultSchema()

The schema an unqualified name defaults to right now.

Six model classes used to carry an identical copy of this fallback; it lives here so the unset rule cannot be applied to some of them and forgotten on the others. Returns TSQLEnv.DEFAULT_SCHEMA_NAME when there is no schema to default to.

See Also:

getEffectiveDefaultDatabase()

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)

pushIdentityScope

public void pushIdentityScope(String identityScopeKey)

popIdentityScope

public void popIdentityScope()

hasIdentityScope

public boolean hasIdentityScope()

peekIdentityScope

public String peekIdentityScope()

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()

indexObjectType

public void indexObjectType(String normalizedName,
                            List<String> fieldNames)

getObjectTypeFields

public List<String> getObjectTypeFields(String normalizedName)

indexCollectionType

public void indexCollectionType(String collectionName,
                                String elementTypeName)

getElementTypeName

public String getElementTypeName(String collectionName)

addPipelinedSignature

public void addPipelinedSignature(PipelinedFunctionSignature sig)

findPipelinedSignature

public PipelinedFunctionSignature findPipelinedSignature(List<String> candidates,
                                                         int argCount)

findPipelinedSignatureAny

public PipelinedFunctionSignature findPipelinedSignatureAny(List<String> candidates)

addPendingPipelinedCallSite

public void addPendingPipelinedCallSite(PendingPipelinedCallSite callSite)

getPendingPipelinedCallSites

public List<PendingPipelinedCallSite> getPendingPipelinedCallSites()

getResolvingPipelinedFunctions

public Set<String> getResolvingPipelinedFunctions()

getPipelinedSignatures

public Map<String,List<PipelinedFunctionSignature>> getPipelinedSignatures()