Method delete_

src/processor/operator/persistent/delete_executor.cpp:113–140

}

void SingleLabelNodeDeleteExecutor::delete_(ExecutionContext* context) {
    DASSERT(tableInfo.pkVector->state == info.nodeIDVector->state);
    auto deleteState =
        std::make_unique<NodeTableDeleteState>(*info.nodeIDVector, *tableInfo.pkVector);
    auto transaction = Transaction::Get(*context->clientContext);
    if (!tableInfo.table->delete_(transaction, *deleteState)) {
        return;
    }
    switch (info.deleteType) {
    case DeleteNodeType::DELETE: {
        tableInfo.deleteFromRelTable(transaction, info.nodeIDVector);
    } break;
    case DeleteNodeType::DETACH_DELETE: {
        const auto& selVector = info.nodeIDVector->state->getSelVector();
        const auto pos = selVector[0];
        if (!info.nodeIDVector->isNull(pos)) {
            appendToBatch(info.nodeIDVector->getValue<internalID_t>(pos));
        }
        if (batchNodeIDs.size() >= BATCH_SIZE) {
            flushBatch(batchNodeIDs, *batchSrcNodeIDVector, tableInfo.fwdRelTables,
                tableInfo.bwdRelTables, transaction);
            batchNodeIDs.clear();
        }
    } break;
    default:
        UNREACHABLE_CODE;
    }
}

void MultiLabelNodeDeleteExecutor::init(ResultSet* resultSet, ExecutionContext* context) {
    NodeDeleteExecutor::init(resultSet, context);