gudusoft.gsqlparser.dlineage.dataflow.model

Class ModelFactory

Object

gudusoft.gsqlparser.dlineage.dataflow.model.ModelFactory

public class ModelFactory
extends Object

Constructor Summary

Constructors

Constructor and Description
ModelFactory(ModelBindingManager modelManager)

Method Summary

Modifier and Type	Method and Description
protected void	appendTableColumns(Table tableModel)
Alias	createAlias(TAliasClause aliasClause)
ResultColumn	createAndBindingSelectSetResultColumn(ResultSet resultSet, TResultColumn resultColumn, int index)
CallRelationship	createCallRelation()
Table	createConstantsTable(String sqlHash)
Table	createConstantsTable(TCustomSqlStatement stmt)
CrudRelationship	createCrudRelation()
Variable	createCursor(TCursorDeclStmt stmt)
Variable	createCursor(TForStmt stmt)
Variable	createCursor(TLoopStmt stmt)
Variable	createCursor(TMssqlDeclare stmt)
Variable	createCursor(TOpenforStmt stmt)
Database	createDatabase(TObjectName databaseName)
DataFlowRelationship	createDataFlowRelation()
Table	createDataSource(TObjectName dataSourceName)
ERRelationship	createERRelation()
TableColumn	createFileUri(Table table, TObjectName fileUri)
Function	createFunction(TCaseExpression caseExpression)
Function	createFunction(TFunctionCall functionCall)
Function	createFunction(TObjectName functionName)
FunctionResultColumn	createFunctionResultColumn(Function function, TObjectName functionName)
FunctionResultColumn	createFunctionResultColumn(Function function, TWhenClauseItemList caseFunction)
ImpactRelationship	createImpactRelation()
IndirectImpactRelationship	createIndirectImpactRelation()
TableColumn	createInsertTableColumn(Table tableModel, String columnName)
TableColumn	createInsertTableColumn(Table tableModel, TConstant column, int columnIndex)
TableColumn	createInsertTableColumn(Table tableModel, TExpression column, int columnIndex)
TableColumn	createInsertTableColumn(Table tableModel, TObjectName column)
JoinRelationship	createJoinRelation()
Table	createJsonTable(TTable table)
TableColumn	createJsonTableColumn(Table table, TObjectName column)
Table	createJsonVariable(TObjectName jsonVariable)
ResultColumn	createMergeResultColumn(ResultSet resultSet, TObjectName resultColumn)
OraclePackage	createOraclePackage(TPlsqlCreatePackage stmt)
PivotedTable	createPivotdTable(TPivotClause pivotedTable)
Procedure	createProcedure(TStoredProcedureSqlStatement stmt)
Argument	createProcedureArgument(OraclePackage oraclePackage, TParameterDeclaration parameter, int index)
Argument	createProcedureArgument(Procedure procedure, TParameterDeclaration parameter, int index)
Procedure	createProcedureByName(TObjectName procedureName, int argumentSize)
Procedure	createProcedureFromFunctionCall(TFunctionCall function)
Process	createProcess(TCustomSqlStatement processStmt)
Process	createProcess(TFunctionCall functionCall)
QueryTable	createQueryTable(TTable table)
RecordSetRelationship	createRecordSetRelation()
ResultColumn	createResultColumn(QueryTable queryTableModel, TResultColumn resultColumn)
ResultColumn	createResultColumn(ResultSet resultSet, TExpression expression)
ResultColumn	createResultColumn(ResultSet resultSet, TObjectName resultColumn)
ResultColumn	createResultColumn(ResultSet resultSet, TObjectName resultColumn, boolean forceCreate)
ResultColumn	createResultColumn(ResultSet resultSet, TResultColumn resultColumn)
ResultSet	createResultSet(TParseTreeNode gspObject, boolean isTarget)
ResultSet	createResultSet(TSelectSqlStatement select, boolean isTarget)
Schema	createSchema(TObjectName schemaName)
ResultColumn	createSelectSetResultColumn(ResultSet resultSet, ResultColumn resultColumn)
ResultColumn	createSelectSetResultColumn(ResultSet resultSet, TResultColumn resultColumn, int index)
SelectSetResultSet	createSelectSetResultSet(TSelectSqlStatement stmt)
Table	createStage(TObjectName stageName)
TableColumn	createStageLocation(Table table, TObjectName location)
ResultColumn	createStarResultColumn(ResultSet resultSetModel, TResultColumn resultColumn, String refColumnName)
ResultColumn	createStarResultColumn(SelectResultSet resultSet, Pair<TResultColumn,TObjectName> starColumnPair)
Table	createStream(TObjectName streamName)
Table	createTable(TTable table)
Table	createTable(TTable table, TObjectName tableBinding)
Table	createTableByName(String tableName, boolean create)
Table	createTableByName(TObjectName tableName)
Table	createTableByName(TObjectName tableName, boolean create)
TableColumn	createTableColumn(Table table, TConstant constant)
TableColumn	createTableColumn(Table table, TFunctionCall constantFunction)
TableColumn	createTableColumn(Table table, TObjectName column, boolean fromCreateTable)
TableColumn	createTableColumn(Table table, TResultColumn column)
Table	createTableFromCreateDDL(TTable table, boolean fromDDL)
Table	createTableFromCreateDDL(TTable table, boolean fromDDL, String tableName)
Table	createTriggerOnTable(TTable table)
ResultColumn	createUpdateResultColumn(ResultSet resultSet, TObjectName resultColumn)
Variable	createVariable(Procedure procedure, String variableName, boolean create)
Variable	createVariable(String variableName)
Variable	createVariable(String variableName, boolean create)
Variable	createVariable(TObjectName variableName)
TableColumn	createVariableProperty(Table variableTable, TDeclareVariable variable)
Table	createView(TCustomSqlStatement viewStmt, TObjectName viewName)
Table	createView(TCustomSqlStatement viewStmt, TObjectName viewName, boolean fromCreateView)
TableColumn	createViewColumn(Table viewModel, TObjectName column, int index, boolean fromCreateView)
protected static String	getDefaultDatabase()
protected static String	getDefaultSchema()
static String	getQualifiedTableName(Table table)

Methods inherited from class Object

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

Constructor Detail

ModelFactory

public ModelFactory(ModelBindingManager modelManager)

Method Detail

createResultSet

public ResultSet createResultSet(TSelectSqlStatement select,
                                 boolean isTarget)

createResultSet

public ResultSet createResultSet(TParseTreeNode gspObject,
                                 boolean isTarget)

createResultColumn

public ResultColumn createResultColumn(ResultSet resultSet,
                                       TResultColumn resultColumn)

createStarResultColumn

public ResultColumn createStarResultColumn(ResultSet resultSetModel,
                                           TResultColumn resultColumn,
                                           String refColumnName)

createSelectSetResultColumn

public ResultColumn createSelectSetResultColumn(ResultSet resultSet,
                                                ResultColumn resultColumn)

createSelectSetResultColumn

public ResultColumn createSelectSetResultColumn(ResultSet resultSet,
                                                TResultColumn resultColumn,
                                                int index)

createAndBindingSelectSetResultColumn

public ResultColumn createAndBindingSelectSetResultColumn(ResultSet resultSet,
                                                          TResultColumn resultColumn,
                                                          int index)

createResultColumn

public ResultColumn createResultColumn(ResultSet resultSet,
                                       TObjectName resultColumn)

createResultColumn

public ResultColumn createResultColumn(ResultSet resultSet,
                                       TExpression expression)

createResultColumn

public ResultColumn createResultColumn(ResultSet resultSet,
                                       TObjectName resultColumn,
                                       boolean forceCreate)

createFunctionResultColumn

public FunctionResultColumn createFunctionResultColumn(Function function,
                                                       TObjectName functionName)

createFunctionResultColumn

public FunctionResultColumn createFunctionResultColumn(Function function,
                                                       TWhenClauseItemList caseFunction)

createMergeResultColumn

public ResultColumn createMergeResultColumn(ResultSet resultSet,
                                            TObjectName resultColumn)

createUpdateResultColumn

public ResultColumn createUpdateResultColumn(ResultSet resultSet,
                                             TObjectName resultColumn)

createResultColumn

public ResultColumn createResultColumn(QueryTable queryTableModel,
                                       TResultColumn resultColumn)

createTableFromCreateDDL

public Table createTableFromCreateDDL(TTable table,
                                      boolean fromDDL,
                                      String tableName)

createTableFromCreateDDL

public Table createTableFromCreateDDL(TTable table,
                                      boolean fromDDL)

createJsonTable

public Table createJsonTable(TTable table)

createTable

public Table createTable(TTable table,
                         TObjectName tableBinding)

createTable

public Table createTable(TTable table)

appendTableColumns

protected void appendTableColumns(Table tableModel)

createTriggerOnTable

public Table createTriggerOnTable(TTable table)

createTableByName

public Table createTableByName(TObjectName tableName)

createTableByName

public Table createTableByName(TObjectName tableName,
                               boolean create)

createTableByName

public Table createTableByName(String tableName,
                               boolean create)

createStage

public Table createStage(TObjectName stageName)

createDataSource

public Table createDataSource(TObjectName dataSourceName)

createStream

public Table createStream(TObjectName streamName)

createConstantsTable

public Table createConstantsTable(TCustomSqlStatement stmt)

createConstantsTable

public Table createConstantsTable(String sqlHash)

createJsonVariable

public Table createJsonVariable(TObjectName jsonVariable)

createAlias

public Alias createAlias(TAliasClause aliasClause)

createFunction

public Function createFunction(TFunctionCall functionCall)

createFunction

public Function createFunction(TObjectName functionName)

createFunction

public Function createFunction(TCaseExpression caseExpression)

createQueryTable

public QueryTable createQueryTable(TTable table)

createTableColumn

public TableColumn createTableColumn(Table table,
                                     TObjectName column,
                                     boolean fromCreateTable)

getQualifiedTableName

public static String getQualifiedTableName(Table table)

getDefaultSchema

protected static String getDefaultSchema()

getDefaultDatabase

protected static String getDefaultDatabase()

createStageLocation

public TableColumn createStageLocation(Table table,
                                       TObjectName location)

createFileUri

public TableColumn createFileUri(Table table,
                                 TObjectName fileUri)

createVariableProperty

public TableColumn createVariableProperty(Table variableTable,
                                          TDeclareVariable variable)

createJsonTableColumn

public TableColumn createJsonTableColumn(Table table,
                                         TObjectName column)

createDataFlowRelation

public DataFlowRelationship createDataFlowRelation()

createCallRelation

public CallRelationship createCallRelation()

createCrudRelation

public CrudRelationship createCrudRelation()

createERRelation

public ERRelationship createERRelation()

createTableColumn

public TableColumn createTableColumn(Table table,
                                     TResultColumn column)

createTableColumn

public TableColumn createTableColumn(Table table,
                                     TConstant constant)

createTableColumn

public TableColumn createTableColumn(Table table,
                                     TFunctionCall constantFunction)

createRecordSetRelation

public RecordSetRelationship createRecordSetRelation()

createImpactRelation

public ImpactRelationship createImpactRelation()

createIndirectImpactRelation

public IndirectImpactRelationship createIndirectImpactRelation()

createJoinRelation

public JoinRelationship createJoinRelation()

createView

public Table createView(TCustomSqlStatement viewStmt,
                        TObjectName viewName)

createView

public Table createView(TCustomSqlStatement viewStmt,
                        TObjectName viewName,
                        boolean fromCreateView)

createProcess

public Process createProcess(TCustomSqlStatement processStmt)

createProcess

public Process createProcess(TFunctionCall functionCall)

createViewColumn

public TableColumn createViewColumn(Table viewModel,
                                    TObjectName column,
                                    int index,
                                    boolean fromCreateView)

createInsertTableColumn

public TableColumn createInsertTableColumn(Table tableModel,
                                           String columnName)

createInsertTableColumn

public TableColumn createInsertTableColumn(Table tableModel,
                                           TObjectName column)

createInsertTableColumn

public TableColumn createInsertTableColumn(Table tableModel,
                                           TExpression column,
                                           int columnIndex)

createInsertTableColumn

public TableColumn createInsertTableColumn(Table tableModel,
                                           TConstant column,
                                           int columnIndex)

createSelectSetResultSet

public SelectSetResultSet createSelectSetResultSet(TSelectSqlStatement stmt)

createStarResultColumn

public ResultColumn createStarResultColumn(SelectResultSet resultSet,
                                           Pair<TResultColumn,TObjectName> starColumnPair)

createCursor

public Variable createCursor(TCursorDeclStmt stmt)

createCursor

public Variable createCursor(TMssqlDeclare stmt)

createCursor

public Variable createCursor(TLoopStmt stmt)

createCursor

public Variable createCursor(TForStmt stmt)

createCursor

public Variable createCursor(TOpenforStmt stmt)

createVariable

public Variable createVariable(TObjectName variableName)

createVariable

public Variable createVariable(String variableName)

createVariable

public Variable createVariable(String variableName,
                               boolean create)

createVariable

public Variable createVariable(Procedure procedure,
                               String variableName,
                               boolean create)

createDatabase

public Database createDatabase(TObjectName databaseName)

createSchema

public Schema createSchema(TObjectName schemaName)

createPivotdTable

public PivotedTable createPivotdTable(TPivotClause pivotedTable)

createProcedure

public Procedure createProcedure(TStoredProcedureSqlStatement stmt)

createOraclePackage

public OraclePackage createOraclePackage(TPlsqlCreatePackage stmt)

createProcedureFromFunctionCall

public Procedure createProcedureFromFunctionCall(TFunctionCall function)

createProcedureByName

public Procedure createProcedureByName(TObjectName procedureName,
                                       int argumentSize)

createProcedureArgument

public Argument createProcedureArgument(Procedure procedure,
                                        TParameterDeclaration parameter,
                                        int index)

createProcedureArgument

public Argument createProcedureArgument(OraclePackage oraclePackage,
                                        TParameterDeclaration parameter,
                                        int index)