Delete.cpp 1.0 KB

123456789101112131415161718192021222324252627282930313233343536373839
  1. /*
  2. * Copyright (c) 2022, Tim Flynn <trflynn89@serenityos.org>
  3. *
  4. * SPDX-License-Identifier: BSD-2-Clause
  5. */
  6. #include <LibSQL/AST/AST.h>
  7. #include <LibSQL/Database.h>
  8. #include <LibSQL/Meta.h>
  9. #include <LibSQL/Row.h>
  10. namespace SQL::AST {
  11. ResultOr<ResultSet> Delete::execute(ExecutionContext& context) const
  12. {
  13. auto const& schema_name = m_qualified_table_name->schema_name();
  14. auto const& table_name = m_qualified_table_name->table_name();
  15. auto table_def = TRY(context.database->get_table(schema_name, table_name));
  16. ResultSet result { SQLCommand::Delete };
  17. for (auto& table_row : TRY(context.database->select_all(*table_def))) {
  18. context.current_row = &table_row;
  19. if (auto const& where_clause = this->where_clause()) {
  20. auto where_result = TRY(where_clause->evaluate(context)).to_bool();
  21. if (!where_result.has_value() || !where_result.value())
  22. continue;
  23. }
  24. TRY(context.database->remove(table_row));
  25. // FIXME: Implement the RETURNING clause.
  26. }
  27. return result;
  28. }
  29. }