程序包 org.apache.flink.cdc.connectors.oceanbase.catalog

类 OceanBaseMySQLCatalog

java.lang.Object

org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

所有已实现的接口:

Serializable

public class OceanBaseMySQLCatalog
extends OceanBaseCatalog

A OceanBaseCatalog for OceanBase connector that supports schema evolution under MySQL mode.

另请参阅:

序列化表格

字段概要

从类继承的字段 org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

connectionProvider

构造器概要

构造器

构造器	说明
OceanBaseMySQLCatalog(com.oceanbase.connector.flink.OceanBaseConnectorOptions connectorOptions)

方法概要

修饰符和类型	方法	说明
void	alterAddColumns(String databaseName, String tableName, List<OceanBaseColumn> addColumns)
void	alterColumnType(String databaseName, String tableName, String columnName, org.apache.flink.cdc.common.types.DataType dataType, String comment)
void	alterDropColumns(String databaseName, String tableName, List<String> dropColumns)
void	alterTable(String schemaName, String tableName, String comment)
protected String	buildAlterAddColumnsSql(String databaseName, String tableName, List<OceanBaseColumn> addColumns)
protected String	buildColumnStmt(OceanBaseColumn column)
protected String	buildCreateDatabaseSql(String databaseName, boolean ignoreIfExists)
protected String	buildCreateTableSql(OceanBaseTable table, boolean ignoreIfExists)
void	createDatabase(String databaseName, boolean ignoreIfExists)	Create a database.
void	createTable(OceanBaseTable table, boolean ignoreIfExists)	Creates a table.
boolean	databaseExists(String databaseName)	Check if a database exists in this catalog.
void	dropTable(String databaseName, String tableName)
static String	escapeSingleQuote(String dbOrTableName)
protected String	getFullColumnType(String type, Optional<Integer> columnSize, Optional<Integer> decimalDigits)
static String	quote(String dbOrTableName)
void	renameColumn(String schemaName, String tableName, String oldColumnName, String newColumnName)
boolean	tableExists(String databaseName, String tableName)
void	truncateTable(String databaseName, String tableName)

从类继承的方法 org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

close, executeSingleColumnStatement, executeUpdateStatement, open

从类继承的方法 java.lang.Object

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

构造器详细资料

OceanBaseMySQLCatalog

public OceanBaseMySQLCatalog(com.oceanbase.connector.flink.OceanBaseConnectorOptions connectorOptions)

方法详细资料

databaseExists

public boolean databaseExists(String databaseName)
                       throws OceanBaseCatalogException

Check if a database exists in this catalog.

指定者:

databaseExists 在类中 OceanBaseCatalog

参数:

databaseName - Name of the database

返回:

true if the given database exists in the catalog false otherwise

抛出:

OceanBaseCatalogException - in case of any runtime exception

escapeSingleQuote

public static String escapeSingleQuote(String dbOrTableName)

quote

public static String quote(String dbOrTableName)

createDatabase

public void createDatabase(String databaseName,
                           boolean ignoreIfExists)
                    throws OceanBaseCatalogException

Create a database.

指定者:

createDatabase 在类中 OceanBaseCatalog

参数:

databaseName - Name of the database

ignoreIfExists - Flag to specify behavior when a database with the given name already exists.

抛出:

OceanBaseCatalogException - in case of any runtime exception

tableExists

public boolean tableExists(String databaseName,
                           String tableName)
                    throws OceanBaseCatalogException

指定者:

tableExists 在类中 OceanBaseCatalog

抛出:

OceanBaseCatalogException

createTable

public void createTable(OceanBaseTable table,
                        boolean ignoreIfExists)
                 throws OceanBaseCatalogException

Creates a table.

指定者:

createTable 在类中 OceanBaseCatalog

参数:

table - the table definition

ignoreIfExists - flag to specify behavior when a table already exists.

抛出:

OceanBaseCatalogException - in case of any runtime exception

alterAddColumns

public void alterAddColumns(String databaseName,
                            String tableName,
                            List<OceanBaseColumn> addColumns)

指定者:

alterAddColumns 在类中 OceanBaseCatalog

alterDropColumns

public void alterDropColumns(String databaseName,
                             String tableName,
                             List<String> dropColumns)

指定者:

alterDropColumns 在类中 OceanBaseCatalog

alterColumnType

public void alterColumnType(String databaseName,
                            String tableName,
                            String columnName,
                            org.apache.flink.cdc.common.types.DataType dataType,
                            String comment)

指定者:

alterColumnType 在类中 OceanBaseCatalog

renameColumn

public void renameColumn(String schemaName,
                         String tableName,
                         String oldColumnName,
                         String newColumnName)

指定者:

renameColumn 在类中 OceanBaseCatalog

dropTable

public void dropTable(String databaseName,
                      String tableName)

指定者:

dropTable 在类中 OceanBaseCatalog

truncateTable

public void truncateTable(String databaseName,
                          String tableName)

指定者:

truncateTable 在类中 OceanBaseCatalog

alterTable

public void alterTable(String schemaName,
                       String tableName,
                       String comment)

指定者:

alterTable 在类中 OceanBaseCatalog

buildCreateDatabaseSql

protected String buildCreateDatabaseSql(String databaseName,
                                        boolean ignoreIfExists)

buildCreateTableSql

protected String buildCreateTableSql(OceanBaseTable table,
                                     boolean ignoreIfExists)

buildColumnStmt

protected String buildColumnStmt(OceanBaseColumn column)

getFullColumnType

protected String getFullColumnType(String type,
                                   Optional<Integer> columnSize,
                                   Optional<Integer> decimalDigits)

buildAlterAddColumnsSql

protected String buildAlterAddColumnsSql(String databaseName,
                                         String tableName,
                                         List<OceanBaseColumn> addColumns)