pyflink.table.catalog.Catalog.create_database

Catalog.create_database(name: str, database: CatalogDatabase, ignore_if_exists: bool)

Create a database.

Parameters:

• name – Name of the database to be created.

• database – The CatalogDatabase database definition.

• ignore_if_exists – Flag to specify behavior when a database with the given name already exists: if set to false, throw a DatabaseAlreadyExistException, if set to true, do nothing.

Raise:

CatalogException in case of any runtime exception. DatabaseAlreadyExistException if the given database already exists and ignoreIfExists is false.