类的使用
org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalogException

使用OceanBaseCatalogException的程序包

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

org.apache.flink.cdc.connectors.oceanbase.catalog中OceanBaseCatalogException的使用

抛出OceanBaseCatalogException的org.apache.flink.cdc.connectors.oceanbase.catalog中的方法

限定符和类型	方法和说明
void	OceanBaseOracleCatalog.createDatabase(String databaseName, boolean ignoreIfExists)
void	OceanBaseMySQLCatalog.createDatabase(String databaseName, boolean ignoreIfExists) Create a database.
abstract void	OceanBaseCatalog.createDatabase(String databaseName, boolean ignoreIfExists)
void	OceanBaseOracleCatalog.createTable(OceanBaseTable table, boolean ignoreIfExists)
void	OceanBaseMySQLCatalog.createTable(OceanBaseTable table, boolean ignoreIfExists) Creates a table.
abstract void	OceanBaseCatalog.createTable(OceanBaseTable table, boolean ignoreIfExists)
boolean	OceanBaseOracleCatalog.databaseExists(String databaseName)
boolean	OceanBaseMySQLCatalog.databaseExists(String databaseName) Check if a database exists in this catalog.
abstract boolean	OceanBaseCatalog.databaseExists(String databaseName)
boolean	OceanBaseOracleCatalog.tableExists(String databaseName, String tableName)
boolean	OceanBaseMySQLCatalog.tableExists(String databaseName, String tableName)
abstract boolean	OceanBaseCatalog.tableExists(String databaseName, String tableName)