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

类 OceanBaseCatalog

java.lang.Object

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

所有已实现的接口:

Serializable

直接已知子类:

OceanBaseMySQLCatalog, OceanBaseOracleCatalog

public abstract class OceanBaseCatalog
extends Object
implements Serializable

A OceanBaseCatalog for OceanBase connector that supports schema evolution.

另请参阅:

序列化表格

字段概要

字段

修饰符和类型	字段	说明
protected com.oceanbase.connector.flink.connection.OceanBaseConnectionProvider	connectionProvider

构造器概要

构造器

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

方法概要

修饰符和类型	方法	说明
abstract void	alterAddColumns(String databaseName, String tableName, List<OceanBaseColumn> addColumns)
abstract void	alterColumnType(String schemaName, String tableName, String columnName, org.apache.flink.cdc.common.types.DataType dataType, String comment)
abstract void	alterDropColumns(String schemaName, String tableName, List<String> dropColumns)
abstract void	alterTable(String schemaName, String tableName, String comment)
void	close()
abstract void	createDatabase(String databaseName, boolean ignoreIfExists)
abstract void	createTable(OceanBaseTable table, boolean ignoreIfExists)
abstract boolean	databaseExists(String databaseName)
abstract void	dropTable(String schemaName, String tableName)
protected List<String>	executeSingleColumnStatement(String sql, Object... params)
protected void	executeUpdateStatement(String sql)
void	open()
abstract void	renameColumn(String schemaName, String tableName, String oldColumnName, String newColumnName)
abstract boolean	tableExists(String databaseName, String tableName)
abstract void	truncateTable(String schemaName, String tableName)

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

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

字段详细资料

connectionProvider

protected com.oceanbase.connector.flink.connection.OceanBaseConnectionProvider connectionProvider

构造器详细资料

OceanBaseCatalog

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

方法详细资料

open

public void open()

executeSingleColumnStatement

protected List<String> executeSingleColumnStatement(String sql,
                                                    Object... params)
                                             throws SQLException

抛出:

SQLException

executeUpdateStatement

protected void executeUpdateStatement(String sql)
                               throws SQLException

抛出:

SQLException

databaseExists

public abstract boolean databaseExists(String databaseName)
                                throws OceanBaseCatalogException

抛出:

OceanBaseCatalogException

createDatabase

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

抛出:

OceanBaseCatalogException

tableExists

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

抛出:

OceanBaseCatalogException

createTable

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

抛出:

OceanBaseCatalogException

alterAddColumns

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

alterDropColumns

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

alterColumnType

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

renameColumn

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

dropTable

public abstract void dropTable(String schemaName,
                               String tableName)

truncateTable

public abstract void truncateTable(String schemaName,
                                   String tableName)

alterTable

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

close

public void close()