Package org.apache.flink.cdc.connectors.mysql.source.parser

Class CustomMySqlAntlrDdlParser

java.lang.Object

io.debezium.relational.ddl.AbstractDdlParser

io.debezium.antlr.AntlrDdlParser<io.debezium.ddl.parser.mysql.generated.MySqlLexer,io.debezium.ddl.parser.mysql.generated.MySqlParser>

io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser

org.apache.flink.cdc.connectors.mysql.source.parser.CustomMySqlAntlrDdlParser

All Implemented Interfaces:

io.debezium.relational.ddl.DdlParser

public class CustomMySqlAntlrDdlParser
extends io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser

A ddl parser that will use custom listener.

Field Summary

Fields inherited from class io.debezium.antlr.AntlrDdlParser

databaseTables, dataTypeResolver

Fields inherited from class io.debezium.relational.ddl.AbstractDdlParser

ddlChanges, logger, skipComments, skipViews, systemVariables

Constructor Summary

Constructors

Constructor	Description
CustomMySqlAntlrDdlParser(boolean includeComments, boolean tinyInt1isBit, boolean isTableIdCaseInsensitive)

Method Summary

Modifier and Type	Method	Description
protected io.debezium.antlr.AntlrDdlParserListener	createParseTreeWalkerListener()
List<SchemaChangeEvent>	getAndClearParsedEvents()
protected io.debezium.antlr.DataTypeResolver	initializeDataTypeResolver()

Methods inherited from class io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser

charsetForTable, charsetNameForDatabase, createNewLexerInstance, createNewParserInstance, createNewSystemVariablesInstance, currentDatabaseCharset, escapeOption, extractCharset, extractEnumAndSetOptions, getConverters, getTableFilter, isGrammarInUpperCase, parseName, parsePrimaryIndexColumnNames, parseQualifiedTableId, parseTree, runIfNotNull

Methods inherited from class io.debezium.antlr.AntlrDdlParser

databaseTables, dataTypeResolver, debugParsed, debugSkipped, getParsingExceptionsFromWalker, getText, getText, parse, signalAlterDatabase, signalAlterTable, signalAlterTable, signalAlterView, signalCreateDatabase, signalCreateIndex, signalCreateTable, signalCreateView, signalDropDatabase, signalDropIndex, signalDropTable, signalDropTable, signalDropView, signalSetVariable, signalTruncateTable, signalUseDatabase, skipComments, skipViews, withoutQuotes

Methods inherited from class io.debezium.relational.ddl.AbstractDdlParser

accumulateParsingFailure, accumulateParsingFailure, commentParsed, createColumnFromConstant, currentSchema, debugParsed, debugSkipped, getDdlChanges, isQuote, isQuoted, removeLineFeeds, resolveTableId, setCurrentDatabase, setCurrentSchema, setTypeInfoForConstant, signalAlterDatabase, signalAlterTable, signalAlterView, signalChangeEvent, signalCreateDatabase, signalCreateIndex, signalCreateTable, signalCreateView, signalDropDatabase, signalDropIndex, signalDropView, signalSetVariable, signalTruncateTable, signalUseDatabase, systemVariables, terminator, withoutQuotes

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomMySqlAntlrDdlParser

public CustomMySqlAntlrDdlParser(boolean includeComments,
                                 boolean tinyInt1isBit,
                                 boolean isTableIdCaseInsensitive)

Method Detail

initializeDataTypeResolver

protected io.debezium.antlr.DataTypeResolver initializeDataTypeResolver()

Overrides:

initializeDataTypeResolver in class io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser

createParseTreeWalkerListener

protected io.debezium.antlr.AntlrDdlParserListener createParseTreeWalkerListener()

Overrides:

createParseTreeWalkerListener in class io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser

getAndClearParsedEvents

public List<SchemaChangeEvent> getAndClearParsedEvents()