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);
}
}