public static WriteMode getWriteMode()

in flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/AdbpgOptions.java [280:301]

• 22 lines of code
• 9 McCabe index (conditional complexity)

    public static WriteMode getWriteMode(ReadableConfig readableConfig) {
        switch (readableConfig.get(WRITE_MODE).toString().toLowerCase()) {
            case "insert":
            case "0":
                return WriteMode.insert;
            case "copy":
            case "1":
                return WriteMode.copy;
            case "upsert":
            case "2":
                return WriteMode.upsert;
            case "merge":
            case "3":
                return WriteMode.merge;
            default:
                throw new IllegalArgumentException(
                        String.format(
                                "Invalid value for config %s : %s",
                                WRITE_MODE.key(),
                                readableConfig.get(WRITE_MODE)));
        }
    }