protected void initCatalogSchema()

in asterixdb-jdbc/asterix-jdbc-core/src/main/java/org/apache/asterix/jdbc/core/ADBConnection.java [82:111]

28 lines of code
9 McCabe index (conditional complexity)


    protected void initCatalogSchema(ADBProtocolBase protocol, String dataverseCanonicalName) throws SQLException {
        switch (catalogDataverseMode) {
            case CATALOG:
                catalog = dataverseCanonicalName == null || dataverseCanonicalName.isEmpty()
                        ? protocol.getDefaultDataverse() : dataverseCanonicalName;
                // schema = null
                break;
            case CATALOG_SCHEMA:
                if (dataverseCanonicalName == null || dataverseCanonicalName.isEmpty()) {
                    catalog = protocol.getDefaultDataverse();
                    // schema = null
                } else {
                    String[] parts = dataverseCanonicalName.split("/");
                    switch (parts.length) {
                        case 1:
                            catalog = parts[0];
                            break;
                        case 2:
                            catalog = parts[0];
                            schema = parts[1];
                            break;
                        default:
                            throw protocol.getErrorReporter().errorInConnection(dataverseCanonicalName); //TODO:FIXME
                    }
                }
                break;
            default:
                throw new IllegalStateException();
        }
    }