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

类 OceanBaseOracleCatalog

java.lang.Object

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

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

所有已实现的接口:

Serializable

public class OceanBaseOracleCatalog
extends OceanBaseCatalog

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

另请参阅:

序列化表格

字段概要

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

connectionProvider

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
void	alterAddColumns(String databaseName, String tableName, List<OceanBaseColumn> addColumns)
void	alterColumnType(String schemaName, String tableName, String columnName, org.apache.flink.cdc.common.types.DataType dataType)
void	alterDropColumns(String schemaName, String tableName, List<String> dropColumns)
void	createDatabase(String databaseName, boolean ignoreIfExists)
void	createTable(OceanBaseTable table, boolean ignoreIfExists)
boolean	databaseExists(String databaseName)
void	dropTable(String schemaName, String tableName)
void	renameColumn(String schemaName, String tableName, String oldColumnName, String newColumnName)
boolean	tableExists(String databaseName, String tableName)
void	truncateTable(String schemaName, 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

构造器详细资料

OceanBaseOracleCatalog

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

方法详细资料

databaseExists

public boolean databaseExists(String databaseName)
                       throws OceanBaseCatalogException

指定者:

databaseExists 在类中 OceanBaseCatalog

抛出:

OceanBaseCatalogException

createDatabase

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

指定者:

createDatabase 在类中 OceanBaseCatalog

抛出:

OceanBaseCatalogException

tableExists

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

指定者:

tableExists 在类中 OceanBaseCatalog

抛出:

OceanBaseCatalogException

createTable

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

指定者:

createTable 在类中 OceanBaseCatalog

抛出:

OceanBaseCatalogException

alterAddColumns

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

指定者:

alterAddColumns 在类中 OceanBaseCatalog

alterDropColumns

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

指定者:

alterDropColumns 在类中 OceanBaseCatalog

alterColumnType

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

指定者:

alterColumnType 在类中 OceanBaseCatalog

renameColumn

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

指定者:

renameColumn 在类中 OceanBaseCatalog

dropTable

public void dropTable(String schemaName,
                      String tableName)

指定者:

dropTable 在类中 OceanBaseCatalog

truncateTable

public void truncateTable(String schemaName,
                          String tableName)

指定者:

truncateTable 在类中 OceanBaseCatalog