This repository was archived by the owner on Jan 31, 2025. It is now read-only.

Description
As a user, I need to make the Jdbc Sink be able to call stored procedures.
This is not a difficult task, just need to modify WriteJdbcP replace with this block.
if (updateQuery.trim().startsWith("{") && updateQuery.trim().endsWith("}")
&& updateQuery.toUpperCase().contains("CALL")) {
statement = connection.prepareCall(updateQuery);
} else {
statement = connection.prepareStatement(updateQuery);
}