Package gudusoft.gsqlparser.dlineage

Class ParallelDataFlowAnalyzer

Object

gudusoft.gsqlparser.dlineage.ParallelDataFlowAnalyzer

All Implemented Interfaces:

IDataFlowAnalyzer

public class ParallelDataFlowAnalyzer
extends Object
implements IDataFlowAnalyzer

Constructor Summary

Constructors

Constructor	Description
ParallelDataFlowAnalyzer(SqlInfo[] sqlInfos, Option option)
ParallelDataFlowAnalyzer(SqlInfo[] sqlInfos, EDbVendor dbVendor, boolean simpleOutput)
ParallelDataFlowAnalyzer(File[] sqlFiles, Option option)
ParallelDataFlowAnalyzer(String[] sqlContents, EDbVendor dbVendor, boolean simpleOutput)
ParallelDataFlowAnalyzer(String[] sqlContents, EDbVendor dbVendor, boolean simpleOutput, String defaultServer, String defaultDatabase, String defaltSchema)

Method Summary

Modifier and Type	Method	Description
protected List<SqlInfo>	convertSQL(EDbVendor vendor, String json)
void	dispose()
String	generateDataFlow()
String	generateDataFlow(boolean withExtraInfo)
String	generateSqlInfos()
dataflow	getDataFlow()
List<ErrorInfo>	getErrorMessages()
Map<String,String>	getHashSQLMap()
Option	getOption()
DbObjectPosition	getSelectedDbObjectInfo(Coordinate start, Coordinate end)
Map<String,List<SqlInfo>>	getSqlInfos()
boolean	isIgnoreCoordinate()
boolean	isIgnoreRecordSet()
boolean	isLinkOrphanColumnToFirstTable()
boolean	isShowConstantTable()
boolean	isShowCountTableColumn()
boolean	isShowImplicitSchema()
boolean	isShowJoin()
boolean	isSimpleShowFunction()
boolean	isSimpleShowTopSelectResultSet()
boolean	isTransform()
boolean	isTransformCoordinate()
static void	main(String[] args)
static dataflow	mergeDataFlows(Collection<dataflow> dataflows, EDbVendor vendor)
void	setHandleListener(DataFlowHandleListener listener)
void	setIgnoreCoordinate(boolean ignoreCoordinate)
void	setIgnoreRecordSet(boolean ignoreRecordSet)
void	setLinkOrphanColumnToFirstTable(boolean linkOrphanColumnToFirstTable)
void	setOption(Option option)
void	setShowConstantTable(boolean showConstantTable)
void	setShowCountTableColumn(boolean showCountTableColumn)
void	setShowImplicitSchema(boolean showImplicitSchema)
void	setShowJoin(boolean showJoin)
void	setSimpleShowFunction(boolean simpleShowFunction)
void	setSimpleShowTopSelectResultSet(boolean simpleShowTopSelectResultSet)
void	setSqlEnv(TSQLEnv sqlenv)
void	setTransform(boolean transform)
void	setTransformCoordinate(boolean transformCoordinate)

Methods inherited from class java.lang.Object

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

Constructor Details

ParallelDataFlowAnalyzer

public ParallelDataFlowAnalyzer(SqlInfo[] sqlInfos,
 EDbVendor dbVendor,
 boolean simpleOutput)

ParallelDataFlowAnalyzer

public ParallelDataFlowAnalyzer(String[] sqlContents,
 EDbVendor dbVendor,
 boolean simpleOutput,
 String defaultServer,
 String defaultDatabase,
 String defaltSchema)

ParallelDataFlowAnalyzer

public ParallelDataFlowAnalyzer(String[] sqlContents,
 EDbVendor dbVendor,
 boolean simpleOutput)

ParallelDataFlowAnalyzer

public ParallelDataFlowAnalyzer(SqlInfo[] sqlInfos,
 Option option)

ParallelDataFlowAnalyzer

public ParallelDataFlowAnalyzer(File[] sqlFiles,
 Option option)

Method Details

convertSQL

protected List<SqlInfo> convertSQL(EDbVendor vendor,
 String json)

isIgnoreRecordSet

public boolean isIgnoreRecordSet()

Specified by:

isIgnoreRecordSet in interface IDataFlowAnalyzer

setIgnoreRecordSet

public void setIgnoreRecordSet(boolean ignoreRecordSet)

Specified by:

setIgnoreRecordSet in interface IDataFlowAnalyzer

isSimpleShowTopSelectResultSet

public boolean isSimpleShowTopSelectResultSet()

Specified by:

isSimpleShowTopSelectResultSet in interface IDataFlowAnalyzer

setSimpleShowTopSelectResultSet

public void setSimpleShowTopSelectResultSet(boolean simpleShowTopSelectResultSet)

Specified by:

setSimpleShowTopSelectResultSet in interface IDataFlowAnalyzer

isSimpleShowFunction

public boolean isSimpleShowFunction()

Specified by:

isSimpleShowFunction in interface IDataFlowAnalyzer

setSimpleShowFunction

public void setSimpleShowFunction(boolean simpleShowFunction)

Specified by:

setSimpleShowFunction in interface IDataFlowAnalyzer

isShowJoin

public boolean isShowJoin()

Specified by:

isShowJoin in interface IDataFlowAnalyzer

setShowJoin

public void setShowJoin(boolean showJoin)

Specified by:

setShowJoin in interface IDataFlowAnalyzer

isShowImplicitSchema

public boolean isShowImplicitSchema()

Specified by:

isShowImplicitSchema in interface IDataFlowAnalyzer

setShowImplicitSchema

public void setShowImplicitSchema(boolean showImplicitSchema)

Specified by:

setShowImplicitSchema in interface IDataFlowAnalyzer

isShowConstantTable

public boolean isShowConstantTable()

Specified by:

isShowConstantTable in interface IDataFlowAnalyzer

setShowConstantTable

public void setShowConstantTable(boolean showConstantTable)

Specified by:

setShowConstantTable in interface IDataFlowAnalyzer

isShowCountTableColumn

public boolean isShowCountTableColumn()

Specified by:

isShowCountTableColumn in interface IDataFlowAnalyzer

setShowCountTableColumn

public void setShowCountTableColumn(boolean showCountTableColumn)

Specified by:

setShowCountTableColumn in interface IDataFlowAnalyzer

isTransform

public boolean isTransform()

Specified by:

isTransform in interface IDataFlowAnalyzer

setTransform

public void setTransform(boolean transform)

Specified by:

setTransform in interface IDataFlowAnalyzer

isTransformCoordinate

public boolean isTransformCoordinate()

Specified by:

isTransformCoordinate in interface IDataFlowAnalyzer

setTransformCoordinate

public void setTransformCoordinate(boolean transformCoordinate)

Specified by:

setTransformCoordinate in interface IDataFlowAnalyzer

isLinkOrphanColumnToFirstTable

public boolean isLinkOrphanColumnToFirstTable()

Specified by:

isLinkOrphanColumnToFirstTable in interface IDataFlowAnalyzer

setLinkOrphanColumnToFirstTable

public void setLinkOrphanColumnToFirstTable(boolean linkOrphanColumnToFirstTable)

Specified by:

setLinkOrphanColumnToFirstTable in interface IDataFlowAnalyzer

isIgnoreCoordinate

public boolean isIgnoreCoordinate()

Specified by:

isIgnoreCoordinate in interface IDataFlowAnalyzer

setIgnoreCoordinate

public void setIgnoreCoordinate(boolean ignoreCoordinate)

Specified by:

setIgnoreCoordinate in interface IDataFlowAnalyzer

setHandleListener

public void setHandleListener(DataFlowHandleListener listener)

Specified by:

setHandleListener in interface IDataFlowAnalyzer

setSqlEnv

public void setSqlEnv(TSQLEnv sqlenv)

Specified by:

setSqlEnv in interface IDataFlowAnalyzer

setOption

public void setOption(Option option)

Specified by:

setOption in interface IDataFlowAnalyzer

getOption

public Option getOption()

Specified by:

getOption in interface IDataFlowAnalyzer

getErrorMessages

public List<ErrorInfo> getErrorMessages()

Specified by:

getErrorMessages in interface IDataFlowAnalyzer

generateSqlInfos

public String generateSqlInfos()

Specified by:

generateSqlInfos in interface IDataFlowAnalyzer

generateDataFlow

public String generateDataFlow()

Specified by:

generateDataFlow in interface IDataFlowAnalyzer

getSqlInfos

public Map<String,List<SqlInfo>> getSqlInfos()

Specified by:

getSqlInfos in interface IDataFlowAnalyzer

getSelectedDbObjectInfo

public DbObjectPosition getSelectedDbObjectInfo(Coordinate start,
 Coordinate end)

Specified by:

getSelectedDbObjectInfo in interface IDataFlowAnalyzer

generateDataFlow

public String generateDataFlow(boolean withExtraInfo)

Specified by:

generateDataFlow in interface IDataFlowAnalyzer

dispose

public void dispose()

Specified by:

dispose in interface IDataFlowAnalyzer

mergeDataFlows

public static dataflow mergeDataFlows(Collection<dataflow> dataflows,
 EDbVendor vendor)

getDataFlow

public dataflow getDataFlow()

Specified by:

getDataFlow in interface IDataFlowAnalyzer

getHashSQLMap

public Map<String,String> getHashSQLMap()

Specified by:

getHashSQLMap in interface IDataFlowAnalyzer

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception