in src/main/java/com/uber/uberscriptquery/util/SqlUtils.java [78:91]
public static int executeJdbcUpdate(String jdbcUrl, String sql) {
logger.info(String.format("Updating jdbc data by sql: %s", sql));
loadJdbcDriverClass(jdbcUrl);
try (Connection con = DriverManager.getConnection(jdbcUrl)) {
PreparedStatement stmt = con.prepareStatement(sql);
int rowCount = stmt.executeUpdate();
logger.info(String.format("Finished db update sql: %s, row count: %s", sql, rowCount));
return rowCount;
} catch (SQLException e) {
throw new RuntimeException("Failed to execute jdbc sql: " + sql, e);
}
}