Merge pull request #392 from LASTRADA-Software/feature/Delete_in_datamapper_query_builder

[DataMapper] Implement Delete query builder

Author: christianparpart

src/Lightweight/DataMapper/DataMapper.hpp

@@ -648,6 +648,21 @@ bool SqlCoreDataMapperQueryBuilder<Record, Derived, QueryOptions>::Exist()
     return false;
 }
 
+template <typename Record, typename Derived, DataMapperOptions QueryOptions>
+void SqlCoreDataMapperQueryBuilder<Record, Derived, QueryOptions>::Delete()
+{
+    auto stmt = SqlStatement { _dm.Connection() };
+
+    auto const query = _formatter.Delete(RecordTableName<Record>,
+                                         this->_query.searchCondition.tableAlias,
+                                         this->_query.searchCondition.tableJoins,
+                                         this->_query.searchCondition.condition);
+
+    stmt.Prepare(query);
+    stmt.Execute();
+    stmt.CloseCursor();
+}
+
 template <typename Record, typename Derived, DataMapperOptions QueryOptions>
 std::vector<Record> SqlCoreDataMapperQueryBuilder<Record, Derived, QueryOptions>::All()
 {

src/Lightweight/DataMapper/QueryBuilders.hpp

@@ -62,6 +62,9 @@ class [[nodiscard]] SqlCoreDataMapperQueryBuilder: public SqlBasicSelectQueryBui
     /// Executes a SELECT query and returns all records found.
     [[nodiscard]] std::vector<Record> All();
 
+    /// Executes a DELETE query.
+    void Delete();
+
     /// @brief Executes a SELECT query and returns all records found for the specified field.
     ///
     /// @tparam Field The field to select from the record, in the form of &Record::FieldName.

src/tests/DataMapper/MiscTests.cpp

@@ -520,4 +520,26 @@ TEST_CASE_METHOD(SqlTestFixture, "SqlGuid", "[DataMapper]")
     }
 }
 
+TEST_CASE_METHOD(SqlTestFixture, "Delete", "[DataMapper]")
+{
+    auto dm = DataMapper::Create();
+
+    dm->CreateTable<Person>();
+    for (auto const i: std::views::iota(0, 10))
+    {
+        dm->CreateExplicit(Person {
+            .id = SqlGuid::Create(),
+            .name = std::format("Person {}", i),
+            .is_active = (i % 2) == 0,
+            .age = i,
+        });
+    }
+    CHECK(dm->Query<Person>().Count() == 10);
+    dm->Query<Person>().Where(FieldNameOf<Member(Person::age)>, "<", 6).Delete();
+    CHECK(dm->Query<Person>().Count() == 4);
+    dm->Query<Person>().Delete();
+    REQUIRE(dm->Query<Person>().Count() == 0);
+    dm->Query<Person>().Delete();
+}
+
 // NOLINTEND(bugprone-unchecked-optional-access)