public static OceanBaseCompatibleMode parse()

in flink-connector-jdbc-oceanbase/src/main/java/org/apache/flink/connector/jdbc/oceanbase/database/dialect/OceanBaseCompatibleMode.java [26:38]


    public static OceanBaseCompatibleMode parse(String text) {
        if (text == null || text.trim().isEmpty()) {
            return OceanBaseCompatibleMode.MySQL;
        }
        switch (text.trim().toLowerCase()) {
            case "mysql":
                return OceanBaseCompatibleMode.MySQL;
            case "oracle":
                return OceanBaseCompatibleMode.Oracle;
            default:
                throw new IllegalArgumentException("Unsupported compatible mode: " + text);
        }
    }