[Hotfix][Connector-V2][Jdbc] Flink engine, source is LocalFile, sink is jdbc, get "No suitable driver" Exception fix (#6902)

luoyongsir · luoyongsir · commit a7042e9a2743 · 2024-06-19T20:45:49.000+08:00
diff --git a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkWriter.java b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkWriter.java
@@ -92,6 +92,7 @@ public MultiTableResourceManager<ConnectionPoolManager> initMultiTableResourceMa
             ds.setPassword(jdbcSinkConfig.getJdbcConnectionConfig().getPassword().get());
         }
         ds.setAutoCommit(jdbcSinkConfig.getJdbcConnectionConfig().isAutoCommit());
+        ds.setDriverClassName(jdbcSinkConfig.getJdbcConnectionConfig().getDriverName());
         return new JdbcMultiTableResourceManager(new ConnectionPoolManager(ds));
     }
 

Original file line number	Diff line number	Diff line change
`@@ -92,6 +92,7 @@ public MultiTableResourceManager<ConnectionPoolManager> initMultiTableResourceMa`
`92`	`92`	`ds.setPassword(jdbcSinkConfig.getJdbcConnectionConfig().getPassword().get());`
`93`	`93`	`}`
`94`	`94`	`ds.setAutoCommit(jdbcSinkConfig.getJdbcConnectionConfig().isAutoCommit());`
	`95`	`+ ds.setDriverClassName(jdbcSinkConfig.getJdbcConnectionConfig().getDriverName());`
`95`	`96`	`return new JdbcMultiTableResourceManager(new ConnectionPoolManager(ds));`
`96`	`97`	`}`
`97`	`98`