类的使用
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中的方法

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