/
NikolayIvkin
/
sqlancer2
Обзор
Документация
Войти
/
NikolayIvkin
/
sqlancer2
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
src/sqlancer/common/query/SQLQueryResultCheckAdapter.java
33 строки
937 B
Patrick
Continuation of Reworking Connection to DB to support non-SQL connections
26 ноя 2020, 15:40
26 ноя 2020, 15:40
62e302e
Код
Авторство
О чём код?
package sqlancer.common.query; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.function.Consumer; import sqlancer.GlobalState; import sqlancer.SQLConnection; public class SQLQueryResultCheckAdapter extends SQLQueryAdapter { private final Consumer<ResultSet> rsChecker; public SQLQueryResultCheckAdapter(String query, Consumer<ResultSet> rsChecker) { super(query); this.rsChecker = rsChecker; } @Override public <G extends GlobalState<?, ?, SQLConnection>> boolean execute(G globalState, String... fills) throws SQLException { try (Statement s = globalState.getConnection().createStatement()) { ResultSet rs = s.executeQuery(getQueryString()); rsChecker.accept(rs); return true; } catch (Exception e) { checkException(e); return false; } } }