Preapred delete query

Author: sea5kg

src/tests/test_delete.cpp

@@ -0,0 +1,65 @@
+/**********************************************************************************
+ * MIT License
+ *
+ * Copyright (c) 2025-2026 Evgenii Sopov <mrseakg@gmail.com>
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to deal
+ * in the Software without restriction, including without limitation the rights
+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ * copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in
+ *all copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ * SOFTWARE.
+ *
+ * Official Source Code: https://github.com/wsjcpp/wsjcpp-sql-builder
+ *
+ ***********************************************************************************/
+
+#include <iostream>
+#include <wsjcpp_sql_builder.h>
+
+int main() {
+    WsjcppSqlBuilder builder;
+    builder.deleteFrom("table4")
+      .where()
+        .equal("col1", "1")
+        .or_()
+        .notEqual("col2", "2")
+        .or_()
+        .subCondition()
+          .equal("c3", "4")
+          // .and_() // be default must be added and
+          .equal("col2", "5")
+        .finishSubCondition()
+        .or_()
+        .lessThen("col4", 111)
+    ;
+
+    if (builder.hasErrors()) {
+        std::cerr << "Select builder has some errors" << std::endl;
+        return -1;
+    }
+    std::string sqlQuery = builder.sql();
+    std::string sqlQueryExpected = "DELETE FROM table4 WHERE col1 = '1' OR col2 <> '2' OR (c3 = '4' AND col2 = '5') OR col4 < 111";
+    if (sqlQuery != sqlQueryExpected) {
+        std::cerr
+            << "Expected:" << std::endl
+            << "   {" << sqlQueryExpected << "}" << std::endl
+            << ", but got:" << std::endl
+            << "   {" << sqlQuery << "}" << std::endl
+        ;
+        return -1;
+    }
+
+    return 0;
+}

src/wsjcpp_sql_builder.cpp

@@ -317,7 +317,7 @@ std::string WsjcppSqlInsert::sql() {
 // WsjcppSqlUpdate
 
 WsjcppSqlUpdate::WsjcppSqlUpdate(const std::string &tableName, WsjcppSqlBuilder *builder)
-  : WsjcppSqlQuery(WsjcppSqlQueryType::INSERT, builder, tableName) {
+  : WsjcppSqlQuery(WsjcppSqlQueryType::UPDATE, builder, tableName) {
 
 }
 
@@ -377,6 +377,31 @@ std::string WsjcppSqlUpdate::sql() {
 };
 
 
+// ---------------------------------------------------------------------
+// WsjcppSqlDelete
+
+WsjcppSqlDelete::WsjcppSqlDelete(const std::string &tableName, WsjcppSqlBuilder *builder)
+  : WsjcppSqlQuery(WsjcppSqlQueryType::DELETE, builder, tableName) {
+
+}
+
+WsjcppSqlWhere<WsjcppSqlDelete> &WsjcppSqlDelete::where() {
+  if (!m_where) {
+    m_where = std::make_shared<WsjcppSqlWhere<WsjcppSqlDelete>>(nullptr, builderRawPtr(), this);
+  }
+  return *(m_where.get());
+}
+
+std::string WsjcppSqlDelete::sql() {
+  std::string ret = "DELETE FROM " + tableName();
+
+  if (m_where) {
+    ret += " WHERE " + m_where->sql();
+  }
+
+  return ret;
+};
+
 // ---------------------------------------------------------------------
 // WsjcppSqlBuilder
 
@@ -414,11 +439,19 @@ WsjcppSqlUpdate &WsjcppSqlBuilder::findUpdateOrCreate(const std::string &tableNa
   return update(tableName);
 }
 
-// WsjcppSqlBuilder &WsjcppSqlBuilder::makeDelete(const std::string &tableName) {
-//   m_tableName = tableName;
-//   m_nSqlType = WsjcppSqlQueryType::DELETE;
-//   return *this;
-// }
+WsjcppSqlDelete &WsjcppSqlBuilder::deleteFrom(const std::string &tableName) {
+  m_queries.push_back(std::make_shared<WsjcppSqlDelete>(tableName, this));
+  return *(WsjcppSqlDelete *)(m_queries[m_queries.size() -1].get());
+}
+
+WsjcppSqlDelete &WsjcppSqlBuilder::findDeleteOrCreate(const std::string &tableName) {
+  for (auto query : m_queries) {
+    if (query->sqlType() == WsjcppSqlQueryType::DELETE && query->tableName() == tableName) {
+      return *(WsjcppSqlDelete *)(query.get());
+    }
+  }
+  return deleteFrom(tableName);
+}
 
 bool WsjcppSqlBuilder::hasErrors() {
   return m_errors.size() > 0;

src/wsjcpp_sql_builder.h

@@ -276,6 +276,18 @@ class WsjcppSqlUpdate : public WsjcppSqlQuery {
   std::map<std::string, std::string> m_values;
 };
 
+class WsjcppSqlDelete : public WsjcppSqlQuery {
+public:
+  WsjcppSqlDelete(const std::string &tableName, WsjcppSqlBuilder *builder);
+
+  WsjcppSqlWhere<WsjcppSqlDelete> &where();
+
+  virtual std::string sql() override;
+
+private:
+  std::shared_ptr<WsjcppSqlWhere<WsjcppSqlDelete>> m_where;
+};
+
 class WsjcppSqlBuilder {
 public:
   // TODO begin / end transaction can be added here
@@ -285,7 +297,8 @@ class WsjcppSqlBuilder {
   WsjcppSqlInsert &findInsertOrCreate(const std::string &tableName);
   WsjcppSqlUpdate &update(const std::string &tableName);
   WsjcppSqlUpdate &findUpdateOrCreate(const std::string &tableName);
-  // WsjcppSqlBuilder &deleteFrom(const std::string &sSqlTable);
+  WsjcppSqlDelete &deleteFrom(const std::string &sSqlTable);
+  WsjcppSqlDelete &findDeleteOrCreate(const std::string &tableName);
 
   bool hasErrors();
   std::string sql();