org.apache.flink.cdc.connectors.mysql.schema

Class MySqlFieldDefinition

java.lang.Object

org.apache.flink.cdc.connectors.mysql.schema.MySqlFieldDefinition

public class MySqlFieldDefinition
extends Object

used to generate field definition in ddl with "desc table".

Constructor Summary

Constructors

Constructor and Description
MySqlFieldDefinition()

Method Summary

Modifier and Type	Method and Description
String	getColumnName()
String	getColumnType()
String	getDefaultValue()
String	getExtra()
boolean	isKey()
boolean	isNullable()
boolean	isUnique()
boolean	isUnsigned()
void	setColumnName(String columnName)
void	setColumnType(String columnType)
void	setDefaultValue(String defaultValue)
void	setExtra(String extra)
void	setKey(boolean key)
void	setNullable(boolean nullable)
void	setUnique(boolean unique)
String	toDdl()

Methods inherited from class java.lang.Object

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

Constructor Detail

MySqlFieldDefinition

public MySqlFieldDefinition()

Method Detail

getColumnName

public String getColumnName()

setColumnName

public void setColumnName(String columnName)

getColumnType

public String getColumnType()

setColumnType

public void setColumnType(String columnType)

setNullable

public void setNullable(boolean nullable)

getDefaultValue

public String getDefaultValue()

setDefaultValue

public void setDefaultValue(String defaultValue)

isUnsigned

public boolean isUnsigned()

isNullable

public boolean isNullable()

isKey

public boolean isKey()

setKey

public void setKey(boolean key)

getExtra

public String getExtra()

setExtra

public void setExtra(String extra)

isUnique

public boolean isUnique()

setUnique

public void setUnique(boolean unique)

toDdl

public String toDdl()