raw sql queries

Author: jkalias

include/database.h

@@ -169,6 +169,9 @@ namespace sqlite_reflection {
             const auto& record = GetRecord(type_id);
             Delete(record, predicate);
         }
+        
+        /// Executes a raw SQL query. A trailing semicolon is added if needed
+        void Sql(const std::string& raw_sql_query) const;
 
 	private:
 		explicit Database(const char* path);

include/queries.h

@@ -75,6 +75,18 @@ namespace sqlite_reflection {
 		std::vector<std::string> GetValues(void* p) const;
 	};
 
+    /// A query for which direct SQL prompts are used
+    class REFLECTION_EXPORT SqlQuery : public ExecutionQuery
+    {
+    public:
+        ~SqlQuery() override = default;
+        explicit SqlQuery(sqlite3* db, const std::string& sql);
+        
+    protected:
+        std::string PrepareSql() const override;
+        const std::string& sql_;
+    };
+
 	/// A query for creating a table for a given reflectable struct. When the database
 	/// is initialized, a table for every registered reflectable struct is created
 	/// This maps to CREATE TABLE IF NOT EXISTS  in SQL

include/reflection.h

@@ -36,9 +36,7 @@
 #endif
 
 // todo: BETWEEN / IN / NOT IN predicate
-// todo: raw sql queries
 // todo: save with automatic id
-
 // todo: nullable types
 // todo: relations
 

src/database.cc

@@ -95,4 +95,9 @@ namespace sqlite_reflection {
 		DeleteQuery query(db_, record, predicate);
 		query.Execute();
 	}
+
+    void Database::Sql(const std::string& raw_sql_query) const {
+        SqlQuery sql(db_, raw_sql_query);
+        sql.Execute();
+    }
 }

src/queries.cc

@@ -127,6 +127,15 @@ std::vector<std::string> ExecutionQuery::GetValues(void* p) const {
 	return values;
 }
 
+SqlQuery::SqlQuery(sqlite3* db, const std::string& sql)
+: ExecutionQuery(db, Reflection()), sql_(sql) {}
+
+std::string SqlQuery::PrepareSql() const {
+    return sql_.length() > 0 && sql_[sql_.length() - 1] != ';'
+    ? sql_ + ";"
+    : sql_;
+}
+
 CreateTableQuery::CreateTableQuery(sqlite3* db, const Reflection& record)
 	: ExecutionQuery(db, record) { }
 

tests/database_test.cc

@@ -414,3 +414,20 @@ TEST_F(DatabaseTest, ReadMaxId) {
 	const auto max_id_pet = db.GetMaxId<Pet>();
 	EXPECT_EQ(0, max_id_pet);
 }
+
+TEST_F(DatabaseTest, RawSqlQueryForPersistedRecord) {
+    const auto& db = Database::Instance();
+
+    std::vector<Person> persons;
+
+    persons.push_back({52, L"johnie", L"appleseed", 28});
+    persons.push_back({156, L"mary", L"poppins", 20});
+
+    db.Save(persons);
+    db.Sql("DELETE FROM Person WHERE length(first_name) <= 4");
+    
+    const auto fetched_persons = db.FetchAll<Person>();
+    EXPECT_EQ(1, fetched_persons.size());
+    EXPECT_EQ(52, fetched_persons[0].id);
+    EXPECT_EQ(L"johnie", fetched_persons[0].first_name);
+}