|
|
|
@ -290,7 +290,6 @@ public class SqlTask extends AbstractTaskExecutor {
|
|
|
|
|
|
|
|
|
|
private String executeQuery(Connection connection, SqlBinds sqlBinds, String handlerType) throws Exception { |
|
|
|
|
try (PreparedStatement statement = prepareStatementAndBind(connection, sqlBinds)) { |
|
|
|
|
logger.info("{} statement execute query, for sql: {}", handlerType, sqlBinds.getSql()); |
|
|
|
|
ResultSet resultSet = statement.executeQuery(); |
|
|
|
|
return resultProcess(resultSet); |
|
|
|
|
} |
|
|
|
@ -362,7 +361,7 @@ public class SqlTask extends AbstractTaskExecutor {
|
|
|
|
|
ParameterUtils.setInParameter(entry.getKey(), stmt, prop.getType(), prop.getValue()); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
logger.info("prepare statement replace sql : {} ", stmt); |
|
|
|
|
logger.info("prepare statement replace sql : {}, sql parameters : {}", sqlBinds.getSql(), sqlBinds.getParamsMap()); |
|
|
|
|
return stmt; |
|
|
|
|
} catch (Exception exception) { |
|
|
|
|
throw new TaskException("SQL task prepareStatementAndBind error", exception); |
|
|
|
|