hotfix: load driver by name before instantiation

oceanbase · Feb 5, 2024 · e12f47f · e12f47f
1 parent d1433b5
commit e12f47f
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...e/src/main/java/com/oceanbase/connector/flink/connection/OceanBaseConnectionProvider.java b/...e/src/main/java/com/oceanbase/connector/flink/connection/OceanBaseConnectionProvider.java
@@ -62,6 +62,12 @@ public OceanBaseConnectionProvider(OceanBaseConnectorOptions options) {
  }
 
  private String getCompatibleMode() {
+ try {
+ Class.forName(options.getDriverClassName());
+ } catch (ClassNotFoundException e) {
+ throw new RuntimeException(
+ "Failed to load driver class: " + options.getDriverClassName(), e);
+ }
  String mode =
  OceanBaseJdbcUtils.getCompatibleMode(
  () ->