public static String extractDatabaseName()

in flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/sink/AdbpgOutputFormat.java [1131:1151]

• 16 lines of code
• 5 McCabe index (conditional complexity)

    public static String extractDatabaseName(String jdbcUrl) {
        // check if jdbcUrl is empty
        if (jdbcUrl == null || jdbcUrl.isEmpty()) {
            return null;
        }

        // try to split with given url
        String[] parts = jdbcUrl.split("/");
        // database name should be the last part
        if (parts.length > 0) {
            String lastPart = parts[parts.length - 1];
            // if there are parameters in url like '?', then these should be removed
            int paramsIndex = lastPart.indexOf('?');
            if (paramsIndex != -1) {
                return lastPart.substring(0, paramsIndex);
            } else {
                return lastPart;
            }
        }
        return null;
    }