in asterixdb-jdbc/asterix-jdbc-core/src/main/java/org/apache/asterix/jdbc/core/ADBStatement.java [261:282]
protected boolean executeImpl(String sql, List<Object> args) throws SQLException {
try {
ADBProtocolBase.SubmitStatementOptions stmtOptions = createSubmitStatementOptions();
stmtOptions.executionId = executionId;
ADBProtocolBase.QueryServiceResponse response = connection.protocol.submitStatement(sql, args, stmtOptions);
warnings = connection.protocol.getWarningIfExists(response);
executeStmtOptions = stmtOptions;
boolean isQuery = connection.protocol.isStatementCategory(response,
ADBProtocolBase.QueryServiceResponse.StatementCategory.QUERY);
if (isQuery) {
updateCount = -1;
executeResponse = response;
return true;
} else {
updateCount = connection.protocol.getUpdateCount(response);
executeResponse = null;
return false;
}
} finally {
resetExecutionId();
}
}