public CatalogDatabase getDatabase()

in src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalog.java [143:153]

• 11 lines of code
• 3 McCabe index (conditional complexity)

    public CatalogDatabase getDatabase(String databaseName)
            throws DatabaseNotExistException, CatalogException {
        if (StringUtils.isEmpty(databaseName)) {
            throw new CatalogException("Database name can not be null or empty.");
        }
        if (!databaseExists(databaseName)) {
            throw new DatabaseNotExistException(getName(), databaseName);
        } else {
            return new CatalogDatabaseImpl(new HashMap<>(), null);
        }
    }