Function validateQueryResult

src/processor/operator/simple/import_db.cpp:16–24

namespace processor {

static void validateQueryResult(main::QueryResult* queryResult) {
    auto currentResult = queryResult;
    while (currentResult) {
        if (!currentResult->isSuccess()) {
            throw RuntimeException("Import database failed: " + currentResult->getErrorMessage());
        }
        currentResult = currentResult->getNextQueryResult();
    }
}

void ImportDB::executeInternal(ExecutionContext* context) {
    auto clientContext = context->clientContext;