Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
37 changes: 36 additions & 1 deletion README.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -13,6 +13,7 @@ A C++ wrapper for SQLite that provides compile-time checked CRUD operations for
- [Opening and closing the database](#opening-and-closing-the-database)
- [Saving records](#saving-records)
- [Fetching records](#fetching-records)
- [Working with query results](#working-with-query-results)
- [Updating records](#updating-records)
- [Deleting records](#deleting-records)
- [Date and time fields](#date-and-time-fields)
Expand DownExpand Up@@ -346,6 +347,38 @@ Available predicate helpers include:

Predicate values are bound with SQLite prepared statements. Text payloads are treated as values, not SQL syntax.

## Working with query results

`FetchAll` and `Fetch` return an [`fcpp::vector<T>`](https://github.com/jkalias/functional_cpp)
rather than a `std::vector<T>`, so functional operations can be chained directly on the result
without wrapping it yourself:

```c++
// Full names of every adult, straight off the query result.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

// Predicate-style checks are available too.
const bool everyone_is_adult = db->FetchAll<Person>()
.all_of([](const Person& p) { return p.age >= 18; });
```

`fcpp::vector` also supports `map`, `all_of`/`any_of`/`none_of`, `sort`, `distinct`, `zip`, and lazy
pipelines via `.lazy()`; see the [functional_cpp](https://github.com/jkalias/functional_cpp)
documentation. The batch `Save`, `SaveAutoIncrement`, and `Update` overloads accept an
`fcpp::vector<T>` as well.

**Migration note.** Because the result type changed from `std::vector<T>` to `fcpp::vector<T>`:

- `auto` call sites, range-`for` loops, indexing (`result[i]`), and `size()` are unaffected.
- Code that binds a result to a `std::vector<T>` explicitly no longer compiles, because there is no
implicit conversion back. Iterate the result directly, keep it as `fcpp::vector` (or `auto`), or
construct a `std::vector` from its iterators: `std::vector<Person>(result.begin(), result.end())`.
- Indexing is **always bounds-checked**, in release builds too: `result[i]` for an out-of-range `i`
calls `std::abort()` instead of being undefined behavior (unless the library is built with
`FCPP_NO_PRECONDITION_CHECKS`).

## Updating records

Fetch or construct a record, change its fields, and pass it to `Update`. The `id` identifies the row to update.
Expand All@@ -363,7 +396,7 @@ Multiple records can be updated in one call:

```c++
// Update each record in the vector by its id.
std::vector<Person> people = db->FetchAll<Person>();
auto people = db->FetchAll<Person>(); // fcpp::vector<Person>
people[0].last_name = L"Rambo";
people[1].age = 20;

Expand DownExpand Up@@ -494,6 +527,8 @@ You can also open the generated `build/sqlite-cpp-reflection.sln` in Visual Stud

- CMake 3.14 or newer
- A C++11-compatible compiler
- [functional_cpp](https://github.com/jkalias/functional_cpp) for `fcpp::vector` (query results) and
`fcpp::optional_t` (nullable fields), header-only, fetched by CMake
- GoogleTest for tests, fetched by CMake
- SQLite, vendored in `src/sqlite3.c` and `src/internal/sqlite3.h`

Expand Down
48 changes: 38 additions & 10 deletions include/database.h
Original file line numberDiff line numberDiff line change
Expand Up@@ -32,6 +32,7 @@
#include "queries.h"
#include "query_predicates.h"
#include "reflection.h"
#include "vector.h" // fcpp::vector, the functional container returned by the query API

struct sqlite3;

Expand DownExpand Up@@ -66,19 +67,23 @@ class REFLECTION_EXPORT Database {
Database& operator=(Database&&) = delete;

/// Retrieves all entries of a given record from the database.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> FetchAll() const {
fcpp::vector<T> FetchAll() const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
EmptyPredicate empty;
return FetchRecords<T>(record, &empty);
}

/// Retrieves all entries of a given record from the database, which match a given predicate.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> Fetch(const QueryPredicateBase* predicate) const {
fcpp::vector<T> Fetch(const QueryPredicateBase* predicate) const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
return FetchRecords<T>(record, predicate);
Expand DownExpand Up@@ -120,26 +125,43 @@ class REFLECTION_EXPORT Database {
/// Saves multiple records iteratively in the database.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void Save(const std::vector<T>& models) {
void Save(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Save((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Save(const std::vector<T>& models) {
Save(fcpp::vector<T>(models));
}

/// Saves multiple records iteratively in the database, letting the database assign their ids.
/// The newly generated ids are written back into the passed-in models.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
void SaveAutoIncrement(fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (auto& model : models) {
model.id = SaveAutoIncrement((void*)&model, record);
}
}

/// std::vector compatibility overload: saves each record through the single-record overload, so
/// every generated id is written back into the caller's std::vector as soon as its row is
/// inserted. This preserves the ids of already-committed rows if a later row in the batch fails
/// (each insert commits independently), matching the pre-fcpp::vector behavior.
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
for (auto& model : models) {
SaveAutoIncrement(model);
}
}

/// Updates a given record in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
Expand All@@ -152,14 +174,20 @@ class REFLECTION_EXPORT Database {
/// Updates multiple records iteratively in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
void Update(const std::vector<T>& models) {
void Update(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Update((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Update(const std::vector<T>& models) {
Update(fcpp::vector<T>(models));
}

/// Deletes a given record from the database.
/// This corresponds to an DELETE query in the SQL syntax
template <typename T>
Expand DownExpand Up@@ -203,14 +231,14 @@ class REFLECTION_EXPORT Database {
/// each matching row directly from the prepared statement into a newly constructed T -
/// no intermediate string materialization of the result set
template <typename T>
std::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
fcpp::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
std::lock_guard<std::mutex> lock(db_mutex_);
FetchRecordsQuery query(db_, record, predicate);
std::vector<T> models;
fcpp::vector<T> models;
while (query.StepRow()) {
T model;
query.HydrateCurrentRow((void*)&model, record);
models.emplace_back(std::move(model));
models.insert_back(std::move(model));
}
return models;
}
Expand Down
165 changes: 165 additions & 0 deletions tests/functional_vector_test.cc
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,165 @@
// MIT License
//
// Copyright (c) 2026 Ioannis Kaliakatsos
//
// 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.

#include <gtest/gtest.h>

#include <string>
#include <vector>

#include "database.h"
#include "person.h"
#include "vector.h"

using namespace sqlite_reflection;

namespace {
class FunctionalVectorTest : public ::testing::Test {
void SetUp() override {
Database::Initialize("");
}

void TearDown() override {
Database::Finalize();
}
};

// The whole point of the migration: a fetch result is an fcpp::vector, so functional operations
// can be chained directly on it, without the caller wrapping the std::vector themselves.
TEST_F(FunctionalVectorTest, FetchResultChainsFilterAndMap) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
{L"alan", L"turing", 41, true, 3},
});

// filter() (mutating, returns vector&) then map<U>() (non-mutating) chained on the temporary
// returned by FetchAll(), exactly as advertised in the README.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

ASSERT_EQ(2u, adult_names.size());
EXPECT_EQ(L"ada lovelace", adult_names[0]);
EXPECT_EQ(L"alan turing", adult_names[1]);
}

TEST_F(FunctionalVectorTest, FetchResultSupportsAllOfAnyOf) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
});

const auto people = db->FetchAll<Person>();
EXPECT_TRUE(people.all_of([](const Person& p) { return p.age > 0; }));
EXPECT_FALSE(people.all_of([](const Person& p) { return p.age >= 18; }));
EXPECT_TRUE(people.any_of([](const Person& p) { return p.age < 18; }));
EXPECT_FALSE(people.any_of([](const Person& p) { return p.age > 100; }));
}

// range-for and indexing over a fetch result keep working as with a std::vector
TEST_F(FunctionalVectorTest, FetchResultSupportsRangeForAndIndexing) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"alan", L"turing", 41, true, 2},
});

const auto people = db->FetchAll<Person>();

int64_t total_age = 0;
for (const auto& person : people) {
total_age += person.age;
}
EXPECT_EQ(77, total_age);
EXPECT_EQ(L"ada", people[0].first_name);
EXPECT_EQ(L"alan", people[1].first_name);
}

// Batch Save/Update accept an fcpp::vector directly.
TEST_F(FunctionalVectorTest, BatchSaveAndUpdateAcceptFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true, 1}).insert_back({L"alan", L"turing", 41, true, 2});

db->Save(people);

auto fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(36, fetched[0].age);

people[0].age = 37;
db->Update(people);

fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(37, fetched[0].age);
}

// SaveAutoIncrement writes the generated ids back into the passed-in fcpp::vector.
TEST_F(FunctionalVectorTest, SaveAutoIncrementWritesIdsBackIntoFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true}).insert_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}

// The std::vector compatibility overloads keep working for callers that still pass a std::vector.
TEST_F(FunctionalVectorTest, StdVectorCompatibilityOverloadsStillWork) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true, 1});
people.push_back({L"alan", L"turing", 41, true, 2});

db->Save(people);
EXPECT_EQ(2u, db->FetchAll<Person>().size());

people[0].age = 37;
db->Update(people);
EXPECT_EQ(37, db->Fetch<Person>(1).age);
}

// The SaveAutoIncrement std::vector wrapper writes the generated ids back into the caller's
// std::vector, just like the fcpp::vector overload.
TEST_F(FunctionalVectorTest, SaveAutoIncrementStdVectorWrapperWritesIdsBack) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true});
people.push_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}
} // namespace
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { // Add copy buttons to all
 blocks
(function() {
function addCopyButtons() {
document.querySelectorAll('pre code').forEach(function(codeBlock) {
if (codeBlock.parentElement.hasAttribute('data-copy-added')) return;
codeBlock.parentElement.setAttribute('data-copy-added', 'true');
var btn = document.createElement('button');
btn.textContent = 'Copy';
btn.style.cssText = 'position:absolute;top:4px;right:4px;padding:2px 8px;font-size:11px;background:#4ecdc4;border:none;border-radius:4px;color:#1a1a2e;cursor:pointer;opacity:0.7;transition:opacity 0.2s;';
btn.onmouseover = function() { this.style.opacity = '1'; };
btn.onmouseout = function() { this.style.opacity = '0.7'; };
btn.onclick = function() {
navigator.clipboard.writeText(codeBlock.textContent).then(function() {
btn.textContent = 'Copied!';
setTimeout(function() { btn.textContent = 'Copy'; }, 1500);
});
};
codeBlock.parentElement.style.position = 'relative';
codeBlock.parentElement.appendChild(btn);
});
}
addCopyButtons();
// Re-run on dynamic content
var observer = new MutationObserver(addCopyButtons);
observer.observe(document.body, { childList: true, subtree: true });
})();
}
} catch(__e) { console.warn('[Userscript:Add Copy Buttons to Code Blocks]', __e); }
})();
(function(){
try {
var __m = "github.com";
var __re = new RegExp('^' + "github\\.com" + '
Adopt fcpp::vector in the public Database API by jkalias · Pull Request #39 · jkalias/sqlite-reflection · GitHub
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
37 changes: 36 additions & 1 deletion README.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -13,6 +13,7 @@ A C++ wrapper for SQLite that provides compile-time checked CRUD operations for
- [Opening and closing the database](#opening-and-closing-the-database)
- [Saving records](#saving-records)
- [Fetching records](#fetching-records)
- [Working with query results](#working-with-query-results)
- [Updating records](#updating-records)
- [Deleting records](#deleting-records)
- [Date and time fields](#date-and-time-fields)
Expand DownExpand Up@@ -346,6 +347,38 @@ Available predicate helpers include:

Predicate values are bound with SQLite prepared statements. Text payloads are treated as values, not SQL syntax.

## Working with query results

`FetchAll` and `Fetch` return an [`fcpp::vector<T>`](https://github.com/jkalias/functional_cpp)
rather than a `std::vector<T>`, so functional operations can be chained directly on the result
without wrapping it yourself:

```c++
// Full names of every adult, straight off the query result.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

// Predicate-style checks are available too.
const bool everyone_is_adult = db->FetchAll<Person>()
.all_of([](const Person& p) { return p.age >= 18; });
```

`fcpp::vector` also supports `map`, `all_of`/`any_of`/`none_of`, `sort`, `distinct`, `zip`, and lazy
pipelines via `.lazy()`; see the [functional_cpp](https://github.com/jkalias/functional_cpp)
documentation. The batch `Save`, `SaveAutoIncrement`, and `Update` overloads accept an
`fcpp::vector<T>` as well.

**Migration note.** Because the result type changed from `std::vector<T>` to `fcpp::vector<T>`:

- `auto` call sites, range-`for` loops, indexing (`result[i]`), and `size()` are unaffected.
- Code that binds a result to a `std::vector<T>` explicitly no longer compiles, because there is no
implicit conversion back. Iterate the result directly, keep it as `fcpp::vector` (or `auto`), or
construct a `std::vector` from its iterators: `std::vector<Person>(result.begin(), result.end())`.
- Indexing is **always bounds-checked**, in release builds too: `result[i]` for an out-of-range `i`
calls `std::abort()` instead of being undefined behavior (unless the library is built with
`FCPP_NO_PRECONDITION_CHECKS`).

## Updating records

Fetch or construct a record, change its fields, and pass it to `Update`. The `id` identifies the row to update.
Expand All@@ -363,7 +396,7 @@ Multiple records can be updated in one call:

```c++
// Update each record in the vector by its id.
std::vector<Person> people = db->FetchAll<Person>();
auto people = db->FetchAll<Person>(); // fcpp::vector<Person>
people[0].last_name = L"Rambo";
people[1].age = 20;

Expand DownExpand Up@@ -494,6 +527,8 @@ You can also open the generated `build/sqlite-cpp-reflection.sln` in Visual Stud

- CMake 3.14 or newer
- A C++11-compatible compiler
- [functional_cpp](https://github.com/jkalias/functional_cpp) for `fcpp::vector` (query results) and
`fcpp::optional_t` (nullable fields), header-only, fetched by CMake
- GoogleTest for tests, fetched by CMake
- SQLite, vendored in `src/sqlite3.c` and `src/internal/sqlite3.h`

Expand Down
48 changes: 38 additions & 10 deletions include/database.h
Original file line numberDiff line numberDiff line change
Expand Up@@ -32,6 +32,7 @@
#include "queries.h"
#include "query_predicates.h"
#include "reflection.h"
#include "vector.h" // fcpp::vector, the functional container returned by the query API

struct sqlite3;

Expand DownExpand Up@@ -66,19 +67,23 @@ class REFLECTION_EXPORT Database {
Database& operator=(Database&&) = delete;

/// Retrieves all entries of a given record from the database.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> FetchAll() const {
fcpp::vector<T> FetchAll() const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
EmptyPredicate empty;
return FetchRecords<T>(record, &empty);
}

/// Retrieves all entries of a given record from the database, which match a given predicate.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> Fetch(const QueryPredicateBase* predicate) const {
fcpp::vector<T> Fetch(const QueryPredicateBase* predicate) const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
return FetchRecords<T>(record, predicate);
Expand DownExpand Up@@ -120,26 +125,43 @@ class REFLECTION_EXPORT Database {
/// Saves multiple records iteratively in the database.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void Save(const std::vector<T>& models) {
void Save(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Save((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Save(const std::vector<T>& models) {
Save(fcpp::vector<T>(models));
}

/// Saves multiple records iteratively in the database, letting the database assign their ids.
/// The newly generated ids are written back into the passed-in models.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
void SaveAutoIncrement(fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (auto& model : models) {
model.id = SaveAutoIncrement((void*)&model, record);
}
}

/// std::vector compatibility overload: saves each record through the single-record overload, so
/// every generated id is written back into the caller's std::vector as soon as its row is
/// inserted. This preserves the ids of already-committed rows if a later row in the batch fails
/// (each insert commits independently), matching the pre-fcpp::vector behavior.
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
for (auto& model : models) {
SaveAutoIncrement(model);
}
}

/// Updates a given record in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
Expand All@@ -152,14 +174,20 @@ class REFLECTION_EXPORT Database {
/// Updates multiple records iteratively in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
void Update(const std::vector<T>& models) {
void Update(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Update((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Update(const std::vector<T>& models) {
Update(fcpp::vector<T>(models));
}

/// Deletes a given record from the database.
/// This corresponds to an DELETE query in the SQL syntax
template <typename T>
Expand DownExpand Up@@ -203,14 +231,14 @@ class REFLECTION_EXPORT Database {
/// each matching row directly from the prepared statement into a newly constructed T -
/// no intermediate string materialization of the result set
template <typename T>
std::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
fcpp::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
std::lock_guard<std::mutex> lock(db_mutex_);
FetchRecordsQuery query(db_, record, predicate);
std::vector<T> models;
fcpp::vector<T> models;
while (query.StepRow()) {
T model;
query.HydrateCurrentRow((void*)&model, record);
models.emplace_back(std::move(model));
models.insert_back(std::move(model));
}
return models;
}
Expand Down
165 changes: 165 additions & 0 deletions tests/functional_vector_test.cc
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,165 @@
// MIT License
//
// Copyright (c) 2026 Ioannis Kaliakatsos
//
// 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.

#include <gtest/gtest.h>

#include <string>
#include <vector>

#include "database.h"
#include "person.h"
#include "vector.h"

using namespace sqlite_reflection;

namespace {
class FunctionalVectorTest : public ::testing::Test {
void SetUp() override {
Database::Initialize("");
}

void TearDown() override {
Database::Finalize();
}
};

// The whole point of the migration: a fetch result is an fcpp::vector, so functional operations
// can be chained directly on it, without the caller wrapping the std::vector themselves.
TEST_F(FunctionalVectorTest, FetchResultChainsFilterAndMap) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
{L"alan", L"turing", 41, true, 3},
});

// filter() (mutating, returns vector&) then map<U>() (non-mutating) chained on the temporary
// returned by FetchAll(), exactly as advertised in the README.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

ASSERT_EQ(2u, adult_names.size());
EXPECT_EQ(L"ada lovelace", adult_names[0]);
EXPECT_EQ(L"alan turing", adult_names[1]);
}

TEST_F(FunctionalVectorTest, FetchResultSupportsAllOfAnyOf) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
});

const auto people = db->FetchAll<Person>();
EXPECT_TRUE(people.all_of([](const Person& p) { return p.age > 0; }));
EXPECT_FALSE(people.all_of([](const Person& p) { return p.age >= 18; }));
EXPECT_TRUE(people.any_of([](const Person& p) { return p.age < 18; }));
EXPECT_FALSE(people.any_of([](const Person& p) { return p.age > 100; }));
}

// range-for and indexing over a fetch result keep working as with a std::vector
TEST_F(FunctionalVectorTest, FetchResultSupportsRangeForAndIndexing) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"alan", L"turing", 41, true, 2},
});

const auto people = db->FetchAll<Person>();

int64_t total_age = 0;
for (const auto& person : people) {
total_age += person.age;
}
EXPECT_EQ(77, total_age);
EXPECT_EQ(L"ada", people[0].first_name);
EXPECT_EQ(L"alan", people[1].first_name);
}

// Batch Save/Update accept an fcpp::vector directly.
TEST_F(FunctionalVectorTest, BatchSaveAndUpdateAcceptFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true, 1}).insert_back({L"alan", L"turing", 41, true, 2});

db->Save(people);

auto fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(36, fetched[0].age);

people[0].age = 37;
db->Update(people);

fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(37, fetched[0].age);
}

// SaveAutoIncrement writes the generated ids back into the passed-in fcpp::vector.
TEST_F(FunctionalVectorTest, SaveAutoIncrementWritesIdsBackIntoFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true}).insert_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}

// The std::vector compatibility overloads keep working for callers that still pass a std::vector.
TEST_F(FunctionalVectorTest, StdVectorCompatibilityOverloadsStillWork) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true, 1});
people.push_back({L"alan", L"turing", 41, true, 2});

db->Save(people);
EXPECT_EQ(2u, db->FetchAll<Person>().size());

people[0].age = 37;
db->Update(people);
EXPECT_EQ(37, db->Fetch<Person>(1).age);
}

// The SaveAutoIncrement std::vector wrapper writes the generated ids back into the caller's
// std::vector, just like the fcpp::vector overload.
TEST_F(FunctionalVectorTest, SaveAutoIncrementStdVectorWrapperWritesIdsBack) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true});
people.push_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}
} // namespace
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { // Force GitHub README to respect dark mode (function() { var style = document.createElement('style'); style.textContent = ' .markdown-body { color-scheme: dark light; } .markdown-body pre { background: #161b22 !important; } .markdown-body code { background: rgba(110, 118, 129, 0.4) !important; } .markdown-body table th, .markdown-body table td { border-color: #30363d !important; } .markdown-body img { background: #0d1117; } .markdown-body blockquote { border-left-color: #8b949e; } .markdown-body hr { border-color: #30363d; } '; document.head.appendChild(style); })(); } } catch(__e) { console.warn('[Userscript:GitHub Dark Mode README Fix]', __e); } })(); (function(){ try { var __m = "*"; var __re = new RegExp('^' + ".*" + ' Adopt fcpp::vector in the public Database API by jkalias · Pull Request #39 · jkalias/sqlite-reflection · GitHub
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
37 changes: 36 additions & 1 deletion README.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -13,6 +13,7 @@ A C++ wrapper for SQLite that provides compile-time checked CRUD operations for
- [Opening and closing the database](#opening-and-closing-the-database)
- [Saving records](#saving-records)
- [Fetching records](#fetching-records)
- [Working with query results](#working-with-query-results)
- [Updating records](#updating-records)
- [Deleting records](#deleting-records)
- [Date and time fields](#date-and-time-fields)
Expand DownExpand Up@@ -346,6 +347,38 @@ Available predicate helpers include:

Predicate values are bound with SQLite prepared statements. Text payloads are treated as values, not SQL syntax.

## Working with query results

`FetchAll` and `Fetch` return an [`fcpp::vector<T>`](https://github.com/jkalias/functional_cpp)
rather than a `std::vector<T>`, so functional operations can be chained directly on the result
without wrapping it yourself:

```c++
// Full names of every adult, straight off the query result.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

// Predicate-style checks are available too.
const bool everyone_is_adult = db->FetchAll<Person>()
.all_of([](const Person& p) { return p.age >= 18; });
```

`fcpp::vector` also supports `map`, `all_of`/`any_of`/`none_of`, `sort`, `distinct`, `zip`, and lazy
pipelines via `.lazy()`; see the [functional_cpp](https://github.com/jkalias/functional_cpp)
documentation. The batch `Save`, `SaveAutoIncrement`, and `Update` overloads accept an
`fcpp::vector<T>` as well.

**Migration note.** Because the result type changed from `std::vector<T>` to `fcpp::vector<T>`:

- `auto` call sites, range-`for` loops, indexing (`result[i]`), and `size()` are unaffected.
- Code that binds a result to a `std::vector<T>` explicitly no longer compiles, because there is no
implicit conversion back. Iterate the result directly, keep it as `fcpp::vector` (or `auto`), or
construct a `std::vector` from its iterators: `std::vector<Person>(result.begin(), result.end())`.
- Indexing is **always bounds-checked**, in release builds too: `result[i]` for an out-of-range `i`
calls `std::abort()` instead of being undefined behavior (unless the library is built with
`FCPP_NO_PRECONDITION_CHECKS`).

## Updating records

Fetch or construct a record, change its fields, and pass it to `Update`. The `id` identifies the row to update.
Expand All@@ -363,7 +396,7 @@ Multiple records can be updated in one call:

```c++
// Update each record in the vector by its id.
std::vector<Person> people = db->FetchAll<Person>();
auto people = db->FetchAll<Person>(); // fcpp::vector<Person>
people[0].last_name = L"Rambo";
people[1].age = 20;

Expand DownExpand Up@@ -494,6 +527,8 @@ You can also open the generated `build/sqlite-cpp-reflection.sln` in Visual Stud

- CMake 3.14 or newer
- A C++11-compatible compiler
- [functional_cpp](https://github.com/jkalias/functional_cpp) for `fcpp::vector` (query results) and
`fcpp::optional_t` (nullable fields), header-only, fetched by CMake
- GoogleTest for tests, fetched by CMake
- SQLite, vendored in `src/sqlite3.c` and `src/internal/sqlite3.h`

Expand Down
48 changes: 38 additions & 10 deletions include/database.h
Original file line numberDiff line numberDiff line change
Expand Up@@ -32,6 +32,7 @@
#include "queries.h"
#include "query_predicates.h"
#include "reflection.h"
#include "vector.h" // fcpp::vector, the functional container returned by the query API

struct sqlite3;

Expand DownExpand Up@@ -66,19 +67,23 @@ class REFLECTION_EXPORT Database {
Database& operator=(Database&&) = delete;

/// Retrieves all entries of a given record from the database.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> FetchAll() const {
fcpp::vector<T> FetchAll() const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
EmptyPredicate empty;
return FetchRecords<T>(record, &empty);
}

/// Retrieves all entries of a given record from the database, which match a given predicate.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> Fetch(const QueryPredicateBase* predicate) const {
fcpp::vector<T> Fetch(const QueryPredicateBase* predicate) const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
return FetchRecords<T>(record, predicate);
Expand DownExpand Up@@ -120,26 +125,43 @@ class REFLECTION_EXPORT Database {
/// Saves multiple records iteratively in the database.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void Save(const std::vector<T>& models) {
void Save(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Save((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Save(const std::vector<T>& models) {
Save(fcpp::vector<T>(models));
}

/// Saves multiple records iteratively in the database, letting the database assign their ids.
/// The newly generated ids are written back into the passed-in models.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
void SaveAutoIncrement(fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (auto& model : models) {
model.id = SaveAutoIncrement((void*)&model, record);
}
}

/// std::vector compatibility overload: saves each record through the single-record overload, so
/// every generated id is written back into the caller's std::vector as soon as its row is
/// inserted. This preserves the ids of already-committed rows if a later row in the batch fails
/// (each insert commits independently), matching the pre-fcpp::vector behavior.
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
for (auto& model : models) {
SaveAutoIncrement(model);
}
}

/// Updates a given record in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
Expand All@@ -152,14 +174,20 @@ class REFLECTION_EXPORT Database {
/// Updates multiple records iteratively in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
void Update(const std::vector<T>& models) {
void Update(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Update((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Update(const std::vector<T>& models) {
Update(fcpp::vector<T>(models));
}

/// Deletes a given record from the database.
/// This corresponds to an DELETE query in the SQL syntax
template <typename T>
Expand DownExpand Up@@ -203,14 +231,14 @@ class REFLECTION_EXPORT Database {
/// each matching row directly from the prepared statement into a newly constructed T -
/// no intermediate string materialization of the result set
template <typename T>
std::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
fcpp::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
std::lock_guard<std::mutex> lock(db_mutex_);
FetchRecordsQuery query(db_, record, predicate);
std::vector<T> models;
fcpp::vector<T> models;
while (query.StepRow()) {
T model;
query.HydrateCurrentRow((void*)&model, record);
models.emplace_back(std::move(model));
models.insert_back(std::move(model));
}
return models;
}
Expand Down
165 changes: 165 additions & 0 deletions tests/functional_vector_test.cc
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,165 @@
// MIT License
//
// Copyright (c) 2026 Ioannis Kaliakatsos
//
// 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.

#include <gtest/gtest.h>

#include <string>
#include <vector>

#include "database.h"
#include "person.h"
#include "vector.h"

using namespace sqlite_reflection;

namespace {
class FunctionalVectorTest : public ::testing::Test {
void SetUp() override {
Database::Initialize("");
}

void TearDown() override {
Database::Finalize();
}
};

// The whole point of the migration: a fetch result is an fcpp::vector, so functional operations
// can be chained directly on it, without the caller wrapping the std::vector themselves.
TEST_F(FunctionalVectorTest, FetchResultChainsFilterAndMap) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
{L"alan", L"turing", 41, true, 3},
});

// filter() (mutating, returns vector&) then map<U>() (non-mutating) chained on the temporary
// returned by FetchAll(), exactly as advertised in the README.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

ASSERT_EQ(2u, adult_names.size());
EXPECT_EQ(L"ada lovelace", adult_names[0]);
EXPECT_EQ(L"alan turing", adult_names[1]);
}

TEST_F(FunctionalVectorTest, FetchResultSupportsAllOfAnyOf) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
});

const auto people = db->FetchAll<Person>();
EXPECT_TRUE(people.all_of([](const Person& p) { return p.age > 0; }));
EXPECT_FALSE(people.all_of([](const Person& p) { return p.age >= 18; }));
EXPECT_TRUE(people.any_of([](const Person& p) { return p.age < 18; }));
EXPECT_FALSE(people.any_of([](const Person& p) { return p.age > 100; }));
}

// range-for and indexing over a fetch result keep working as with a std::vector
TEST_F(FunctionalVectorTest, FetchResultSupportsRangeForAndIndexing) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"alan", L"turing", 41, true, 2},
});

const auto people = db->FetchAll<Person>();

int64_t total_age = 0;
for (const auto& person : people) {
total_age += person.age;
}
EXPECT_EQ(77, total_age);
EXPECT_EQ(L"ada", people[0].first_name);
EXPECT_EQ(L"alan", people[1].first_name);
}

// Batch Save/Update accept an fcpp::vector directly.
TEST_F(FunctionalVectorTest, BatchSaveAndUpdateAcceptFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true, 1}).insert_back({L"alan", L"turing", 41, true, 2});

db->Save(people);

auto fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(36, fetched[0].age);

people[0].age = 37;
db->Update(people);

fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(37, fetched[0].age);
}

// SaveAutoIncrement writes the generated ids back into the passed-in fcpp::vector.
TEST_F(FunctionalVectorTest, SaveAutoIncrementWritesIdsBackIntoFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true}).insert_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}

// The std::vector compatibility overloads keep working for callers that still pass a std::vector.
TEST_F(FunctionalVectorTest, StdVectorCompatibilityOverloadsStillWork) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true, 1});
people.push_back({L"alan", L"turing", 41, true, 2});

db->Save(people);
EXPECT_EQ(2u, db->FetchAll<Person>().size());

people[0].age = 37;
db->Update(people);
EXPECT_EQ(37, db->Fetch<Person>(1).age);
}

// The SaveAutoIncrement std::vector wrapper writes the generated ids back into the caller's
// std::vector, just like the fcpp::vector overload.
TEST_F(FunctionalVectorTest, SaveAutoIncrementStdVectorWrapperWritesIdsBack) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true});
people.push_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}
} // namespace
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { // Highlight search terms from Google/DuckDuckGo/Bing referrer (function() { var ref = document.referrer; var terms = []; if (ref.includes('google.com') || ref.includes('duckduckgo.com') || ref.includes('bing.com')) { var url = new URL(ref); var q = url.searchParams.get('q') || url.searchParams.get('p'); if (q) { terms = q.split(/\s+/).filter(function(t) { return t.length > 2; }); } } if (terms.length === 0) return; var style = document.createElement('style'); style.textContent = '.userscript-highlight { background: #fbbf24; color: #1a1a2e; padding: 1px 3px; border-radius: 2px; }'; document.head.appendChild(style); function highlight(node) { if (node.nodeType === 3) { // text node var text = node.textContent; var found = false; terms.forEach(function(term) { var regex = new RegExp('(' + term.replace(/[.*+?^${}()|[\]\\]/g, '\\') + ')', 'gi'); if (regex.test(text)) { found = true; var frag = document.createDocumentFragment(); var parts = text.split(regex); parts.forEach(function(part, i) { if (i % 2 === 0) { frag.appendChild(document.createTextNode(part)); } else { var span = document.createElement('span'); span.className = 'userscript-highlight'; span.textContent = part; frag.appendChild(span); } }); node.parentNode.replaceChild(frag, node); } }); } else if (node.nodeType === 1 && node.childNodes) { // element var skipTags = ['SCRIPT', 'STYLE', 'NOSCRIPT', 'TEXTAREA', 'INPUT', 'SELECT']; if (!skipTags.includes(node.tagName)) { Array.from(node.childNodes).forEach(highlight); } } } highlight(document.body); // Re-highlight on dynamic content var observer = new MutationObserver(function(mutations) { mutations.forEach(function(m) { m.addedNodes.forEach(function(node) { if (node.nodeType === 1 || node.nodeType === 3) highlight(node); }); }); }); observer.observe(document.body, { childList: true, subtree: true }); })(); } } catch(__e) { console.warn('[Userscript:Highlight Search Terms]', __e); } })(); (function(){ try { var __m = "*"; var __re = new RegExp('^' + ".*" + ' Adopt fcpp::vector in the public Database API by jkalias · Pull Request #39 · jkalias/sqlite-reflection · GitHub
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
37 changes: 36 additions & 1 deletion README.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -13,6 +13,7 @@ A C++ wrapper for SQLite that provides compile-time checked CRUD operations for
- [Opening and closing the database](#opening-and-closing-the-database)
- [Saving records](#saving-records)
- [Fetching records](#fetching-records)
- [Working with query results](#working-with-query-results)
- [Updating records](#updating-records)
- [Deleting records](#deleting-records)
- [Date and time fields](#date-and-time-fields)
Expand DownExpand Up@@ -346,6 +347,38 @@ Available predicate helpers include:

Predicate values are bound with SQLite prepared statements. Text payloads are treated as values, not SQL syntax.

## Working with query results

`FetchAll` and `Fetch` return an [`fcpp::vector<T>`](https://github.com/jkalias/functional_cpp)
rather than a `std::vector<T>`, so functional operations can be chained directly on the result
without wrapping it yourself:

```c++
// Full names of every adult, straight off the query result.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

// Predicate-style checks are available too.
const bool everyone_is_adult = db->FetchAll<Person>()
.all_of([](const Person& p) { return p.age >= 18; });
```

`fcpp::vector` also supports `map`, `all_of`/`any_of`/`none_of`, `sort`, `distinct`, `zip`, and lazy
pipelines via `.lazy()`; see the [functional_cpp](https://github.com/jkalias/functional_cpp)
documentation. The batch `Save`, `SaveAutoIncrement`, and `Update` overloads accept an
`fcpp::vector<T>` as well.

**Migration note.** Because the result type changed from `std::vector<T>` to `fcpp::vector<T>`:

- `auto` call sites, range-`for` loops, indexing (`result[i]`), and `size()` are unaffected.
- Code that binds a result to a `std::vector<T>` explicitly no longer compiles, because there is no
implicit conversion back. Iterate the result directly, keep it as `fcpp::vector` (or `auto`), or
construct a `std::vector` from its iterators: `std::vector<Person>(result.begin(), result.end())`.
- Indexing is **always bounds-checked**, in release builds too: `result[i]` for an out-of-range `i`
calls `std::abort()` instead of being undefined behavior (unless the library is built with
`FCPP_NO_PRECONDITION_CHECKS`).

## Updating records

Fetch or construct a record, change its fields, and pass it to `Update`. The `id` identifies the row to update.
Expand All@@ -363,7 +396,7 @@ Multiple records can be updated in one call:

```c++
// Update each record in the vector by its id.
std::vector<Person> people = db->FetchAll<Person>();
auto people = db->FetchAll<Person>(); // fcpp::vector<Person>
people[0].last_name = L"Rambo";
people[1].age = 20;

Expand DownExpand Up@@ -494,6 +527,8 @@ You can also open the generated `build/sqlite-cpp-reflection.sln` in Visual Stud

- CMake 3.14 or newer
- A C++11-compatible compiler
- [functional_cpp](https://github.com/jkalias/functional_cpp) for `fcpp::vector` (query results) and
`fcpp::optional_t` (nullable fields), header-only, fetched by CMake
- GoogleTest for tests, fetched by CMake
- SQLite, vendored in `src/sqlite3.c` and `src/internal/sqlite3.h`

Expand Down
48 changes: 38 additions & 10 deletions include/database.h
Original file line numberDiff line numberDiff line change
Expand Up@@ -32,6 +32,7 @@
#include "queries.h"
#include "query_predicates.h"
#include "reflection.h"
#include "vector.h" // fcpp::vector, the functional container returned by the query API

struct sqlite3;

Expand DownExpand Up@@ -66,19 +67,23 @@ class REFLECTION_EXPORT Database {
Database& operator=(Database&&) = delete;

/// Retrieves all entries of a given record from the database.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> FetchAll() const {
fcpp::vector<T> FetchAll() const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
EmptyPredicate empty;
return FetchRecords<T>(record, &empty);
}

/// Retrieves all entries of a given record from the database, which match a given predicate.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> Fetch(const QueryPredicateBase* predicate) const {
fcpp::vector<T> Fetch(const QueryPredicateBase* predicate) const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
return FetchRecords<T>(record, predicate);
Expand DownExpand Up@@ -120,26 +125,43 @@ class REFLECTION_EXPORT Database {
/// Saves multiple records iteratively in the database.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void Save(const std::vector<T>& models) {
void Save(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Save((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Save(const std::vector<T>& models) {
Save(fcpp::vector<T>(models));
}

/// Saves multiple records iteratively in the database, letting the database assign their ids.
/// The newly generated ids are written back into the passed-in models.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
void SaveAutoIncrement(fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (auto& model : models) {
model.id = SaveAutoIncrement((void*)&model, record);
}
}

/// std::vector compatibility overload: saves each record through the single-record overload, so
/// every generated id is written back into the caller's std::vector as soon as its row is
/// inserted. This preserves the ids of already-committed rows if a later row in the batch fails
/// (each insert commits independently), matching the pre-fcpp::vector behavior.
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
for (auto& model : models) {
SaveAutoIncrement(model);
}
}

/// Updates a given record in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
Expand All@@ -152,14 +174,20 @@ class REFLECTION_EXPORT Database {
/// Updates multiple records iteratively in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
void Update(const std::vector<T>& models) {
void Update(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Update((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Update(const std::vector<T>& models) {
Update(fcpp::vector<T>(models));
}

/// Deletes a given record from the database.
/// This corresponds to an DELETE query in the SQL syntax
template <typename T>
Expand DownExpand Up@@ -203,14 +231,14 @@ class REFLECTION_EXPORT Database {
/// each matching row directly from the prepared statement into a newly constructed T -
/// no intermediate string materialization of the result set
template <typename T>
std::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
fcpp::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
std::lock_guard<std::mutex> lock(db_mutex_);
FetchRecordsQuery query(db_, record, predicate);
std::vector<T> models;
fcpp::vector<T> models;
while (query.StepRow()) {
T model;
query.HydrateCurrentRow((void*)&model, record);
models.emplace_back(std::move(model));
models.insert_back(std::move(model));
}
return models;
}
Expand Down
165 changes: 165 additions & 0 deletions tests/functional_vector_test.cc
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,165 @@
// MIT License
//
// Copyright (c) 2026 Ioannis Kaliakatsos
//
// 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.

#include <gtest/gtest.h>

#include <string>
#include <vector>

#include "database.h"
#include "person.h"
#include "vector.h"

using namespace sqlite_reflection;

namespace {
class FunctionalVectorTest : public ::testing::Test {
void SetUp() override {
Database::Initialize("");
}

void TearDown() override {
Database::Finalize();
}
};

// The whole point of the migration: a fetch result is an fcpp::vector, so functional operations
// can be chained directly on it, without the caller wrapping the std::vector themselves.
TEST_F(FunctionalVectorTest, FetchResultChainsFilterAndMap) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
{L"alan", L"turing", 41, true, 3},
});

// filter() (mutating, returns vector&) then map<U>() (non-mutating) chained on the temporary
// returned by FetchAll(), exactly as advertised in the README.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

ASSERT_EQ(2u, adult_names.size());
EXPECT_EQ(L"ada lovelace", adult_names[0]);
EXPECT_EQ(L"alan turing", adult_names[1]);
}

TEST_F(FunctionalVectorTest, FetchResultSupportsAllOfAnyOf) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
});

const auto people = db->FetchAll<Person>();
EXPECT_TRUE(people.all_of([](const Person& p) { return p.age > 0; }));
EXPECT_FALSE(people.all_of([](const Person& p) { return p.age >= 18; }));
EXPECT_TRUE(people.any_of([](const Person& p) { return p.age < 18; }));
EXPECT_FALSE(people.any_of([](const Person& p) { return p.age > 100; }));
}

// range-for and indexing over a fetch result keep working as with a std::vector
TEST_F(FunctionalVectorTest, FetchResultSupportsRangeForAndIndexing) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"alan", L"turing", 41, true, 2},
});

const auto people = db->FetchAll<Person>();

int64_t total_age = 0;
for (const auto& person : people) {
total_age += person.age;
}
EXPECT_EQ(77, total_age);
EXPECT_EQ(L"ada", people[0].first_name);
EXPECT_EQ(L"alan", people[1].first_name);
}

// Batch Save/Update accept an fcpp::vector directly.
TEST_F(FunctionalVectorTest, BatchSaveAndUpdateAcceptFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true, 1}).insert_back({L"alan", L"turing", 41, true, 2});

db->Save(people);

auto fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(36, fetched[0].age);

people[0].age = 37;
db->Update(people);

fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(37, fetched[0].age);
}

// SaveAutoIncrement writes the generated ids back into the passed-in fcpp::vector.
TEST_F(FunctionalVectorTest, SaveAutoIncrementWritesIdsBackIntoFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true}).insert_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}

// The std::vector compatibility overloads keep working for callers that still pass a std::vector.
TEST_F(FunctionalVectorTest, StdVectorCompatibilityOverloadsStillWork) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true, 1});
people.push_back({L"alan", L"turing", 41, true, 2});

db->Save(people);
EXPECT_EQ(2u, db->FetchAll<Person>().size());

people[0].age = 37;
db->Update(people);
EXPECT_EQ(37, db->Fetch<Person>(1).age);
}

// The SaveAutoIncrement std::vector wrapper writes the generated ids back into the caller's
// std::vector, just like the fcpp::vector overload.
TEST_F(FunctionalVectorTest, SaveAutoIncrementStdVectorWrapperWritesIdsBack) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true});
people.push_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}
} // namespace
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { // Strip utm_, fbclid, gclid, etc. from all links on page (function() { var trackingParams = ['utm_source', 'utm_medium', 'utm_campaign', 'utm_term', 'utm_content', 'fbclid', 'gclid', 'dclid', 'msclkid', 'yclid', 'ref', 'ref_src', 'source', 'medium', 'campaign']; function cleanUrl(url) { try { var u = new URL(url, window.location.origin); var changed = false; trackingParams.forEach(function(p) { if (u.searchParams.has(p)) { u.searchParams.delete(p); changed = true; } }); return changed ? u.toString() : url; } catch (e) { return url; } } function cleanLinks() { document.querySelectorAll('a[href]').forEach(function(a) { var clean = cleanUrl(a.href); if (clean !== a.href) a.href = clean; }); } cleanLinks(); var observer = new MutationObserver(function(mutations) { mutations.forEach(function(m) { m.addedNodes.forEach(function(node) { if (node.nodeType === 1) { if (node.tagName === 'A') cleanLinks(); node.querySelectorAll('a[href]').forEach(function(a) { var clean = cleanUrl(a.href); if (clean !== a.href) a.href = clean; }); } }); }); }); observer.observe(document.body, { childList: true, subtree: true }); })(); } } catch(__e) { console.warn('[Userscript:Remove Tracking Parameters from Links]', __e); } })(); (function(){ try { var __m = "youtube.com"; var __re = new RegExp('^' + "youtube\\.com" + ' Adopt fcpp::vector in the public Database API by jkalias · Pull Request #39 · jkalias/sqlite-reflection · GitHub
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
37 changes: 36 additions & 1 deletion README.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -13,6 +13,7 @@ A C++ wrapper for SQLite that provides compile-time checked CRUD operations for
- [Opening and closing the database](#opening-and-closing-the-database)
- [Saving records](#saving-records)
- [Fetching records](#fetching-records)
- [Working with query results](#working-with-query-results)
- [Updating records](#updating-records)
- [Deleting records](#deleting-records)
- [Date and time fields](#date-and-time-fields)
Expand DownExpand Up@@ -346,6 +347,38 @@ Available predicate helpers include:

Predicate values are bound with SQLite prepared statements. Text payloads are treated as values, not SQL syntax.

## Working with query results

`FetchAll` and `Fetch` return an [`fcpp::vector<T>`](https://github.com/jkalias/functional_cpp)
rather than a `std::vector<T>`, so functional operations can be chained directly on the result
without wrapping it yourself:

```c++
// Full names of every adult, straight off the query result.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

// Predicate-style checks are available too.
const bool everyone_is_adult = db->FetchAll<Person>()
.all_of([](const Person& p) { return p.age >= 18; });
```

`fcpp::vector` also supports `map`, `all_of`/`any_of`/`none_of`, `sort`, `distinct`, `zip`, and lazy
pipelines via `.lazy()`; see the [functional_cpp](https://github.com/jkalias/functional_cpp)
documentation. The batch `Save`, `SaveAutoIncrement`, and `Update` overloads accept an
`fcpp::vector<T>` as well.

**Migration note.** Because the result type changed from `std::vector<T>` to `fcpp::vector<T>`:

- `auto` call sites, range-`for` loops, indexing (`result[i]`), and `size()` are unaffected.
- Code that binds a result to a `std::vector<T>` explicitly no longer compiles, because there is no
implicit conversion back. Iterate the result directly, keep it as `fcpp::vector` (or `auto`), or
construct a `std::vector` from its iterators: `std::vector<Person>(result.begin(), result.end())`.
- Indexing is **always bounds-checked**, in release builds too: `result[i]` for an out-of-range `i`
calls `std::abort()` instead of being undefined behavior (unless the library is built with
`FCPP_NO_PRECONDITION_CHECKS`).

## Updating records

Fetch or construct a record, change its fields, and pass it to `Update`. The `id` identifies the row to update.
Expand All@@ -363,7 +396,7 @@ Multiple records can be updated in one call:

```c++
// Update each record in the vector by its id.
std::vector<Person> people = db->FetchAll<Person>();
auto people = db->FetchAll<Person>(); // fcpp::vector<Person>
people[0].last_name = L"Rambo";
people[1].age = 20;

Expand DownExpand Up@@ -494,6 +527,8 @@ You can also open the generated `build/sqlite-cpp-reflection.sln` in Visual Stud

- CMake 3.14 or newer
- A C++11-compatible compiler
- [functional_cpp](https://github.com/jkalias/functional_cpp) for `fcpp::vector` (query results) and
`fcpp::optional_t` (nullable fields), header-only, fetched by CMake
- GoogleTest for tests, fetched by CMake
- SQLite, vendored in `src/sqlite3.c` and `src/internal/sqlite3.h`

Expand Down
48 changes: 38 additions & 10 deletions include/database.h
Original file line numberDiff line numberDiff line change
Expand Up@@ -32,6 +32,7 @@
#include "queries.h"
#include "query_predicates.h"
#include "reflection.h"
#include "vector.h" // fcpp::vector, the functional container returned by the query API

struct sqlite3;

Expand DownExpand Up@@ -66,19 +67,23 @@ class REFLECTION_EXPORT Database {
Database& operator=(Database&&) = delete;

/// Retrieves all entries of a given record from the database.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> FetchAll() const {
fcpp::vector<T> FetchAll() const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
EmptyPredicate empty;
return FetchRecords<T>(record, &empty);
}

/// Retrieves all entries of a given record from the database, which match a given predicate.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> Fetch(const QueryPredicateBase* predicate) const {
fcpp::vector<T> Fetch(const QueryPredicateBase* predicate) const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
return FetchRecords<T>(record, predicate);
Expand DownExpand Up@@ -120,26 +125,43 @@ class REFLECTION_EXPORT Database {
/// Saves multiple records iteratively in the database.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void Save(const std::vector<T>& models) {
void Save(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Save((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Save(const std::vector<T>& models) {
Save(fcpp::vector<T>(models));
}

/// Saves multiple records iteratively in the database, letting the database assign their ids.
/// The newly generated ids are written back into the passed-in models.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
void SaveAutoIncrement(fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (auto& model : models) {
model.id = SaveAutoIncrement((void*)&model, record);
}
}

/// std::vector compatibility overload: saves each record through the single-record overload, so
/// every generated id is written back into the caller's std::vector as soon as its row is
/// inserted. This preserves the ids of already-committed rows if a later row in the batch fails
/// (each insert commits independently), matching the pre-fcpp::vector behavior.
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
for (auto& model : models) {
SaveAutoIncrement(model);
}
}

/// Updates a given record in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
Expand All@@ -152,14 +174,20 @@ class REFLECTION_EXPORT Database {
/// Updates multiple records iteratively in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
void Update(const std::vector<T>& models) {
void Update(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Update((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Update(const std::vector<T>& models) {
Update(fcpp::vector<T>(models));
}

/// Deletes a given record from the database.
/// This corresponds to an DELETE query in the SQL syntax
template <typename T>
Expand DownExpand Up@@ -203,14 +231,14 @@ class REFLECTION_EXPORT Database {
/// each matching row directly from the prepared statement into a newly constructed T -
/// no intermediate string materialization of the result set
template <typename T>
std::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
fcpp::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
std::lock_guard<std::mutex> lock(db_mutex_);
FetchRecordsQuery query(db_, record, predicate);
std::vector<T> models;
fcpp::vector<T> models;
while (query.StepRow()) {
T model;
query.HydrateCurrentRow((void*)&model, record);
models.emplace_back(std::move(model));
models.insert_back(std::move(model));
}
return models;
}
Expand Down
165 changes: 165 additions & 0 deletions tests/functional_vector_test.cc
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,165 @@
// MIT License
//
// Copyright (c) 2026 Ioannis Kaliakatsos
//
// 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.

#include <gtest/gtest.h>

#include <string>
#include <vector>

#include "database.h"
#include "person.h"
#include "vector.h"

using namespace sqlite_reflection;

namespace {
class FunctionalVectorTest : public ::testing::Test {
void SetUp() override {
Database::Initialize("");
}

void TearDown() override {
Database::Finalize();
}
};

// The whole point of the migration: a fetch result is an fcpp::vector, so functional operations
// can be chained directly on it, without the caller wrapping the std::vector themselves.
TEST_F(FunctionalVectorTest, FetchResultChainsFilterAndMap) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
{L"alan", L"turing", 41, true, 3},
});

// filter() (mutating, returns vector&) then map<U>() (non-mutating) chained on the temporary
// returned by FetchAll(), exactly as advertised in the README.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

ASSERT_EQ(2u, adult_names.size());
EXPECT_EQ(L"ada lovelace", adult_names[0]);
EXPECT_EQ(L"alan turing", adult_names[1]);
}

TEST_F(FunctionalVectorTest, FetchResultSupportsAllOfAnyOf) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
});

const auto people = db->FetchAll<Person>();
EXPECT_TRUE(people.all_of([](const Person& p) { return p.age > 0; }));
EXPECT_FALSE(people.all_of([](const Person& p) { return p.age >= 18; }));
EXPECT_TRUE(people.any_of([](const Person& p) { return p.age < 18; }));
EXPECT_FALSE(people.any_of([](const Person& p) { return p.age > 100; }));
}

// range-for and indexing over a fetch result keep working as with a std::vector
TEST_F(FunctionalVectorTest, FetchResultSupportsRangeForAndIndexing) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"alan", L"turing", 41, true, 2},
});

const auto people = db->FetchAll<Person>();

int64_t total_age = 0;
for (const auto& person : people) {
total_age += person.age;
}
EXPECT_EQ(77, total_age);
EXPECT_EQ(L"ada", people[0].first_name);
EXPECT_EQ(L"alan", people[1].first_name);
}

// Batch Save/Update accept an fcpp::vector directly.
TEST_F(FunctionalVectorTest, BatchSaveAndUpdateAcceptFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true, 1}).insert_back({L"alan", L"turing", 41, true, 2});

db->Save(people);

auto fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(36, fetched[0].age);

people[0].age = 37;
db->Update(people);

fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(37, fetched[0].age);
}

// SaveAutoIncrement writes the generated ids back into the passed-in fcpp::vector.
TEST_F(FunctionalVectorTest, SaveAutoIncrementWritesIdsBackIntoFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true}).insert_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}

// The std::vector compatibility overloads keep working for callers that still pass a std::vector.
TEST_F(FunctionalVectorTest, StdVectorCompatibilityOverloadsStillWork) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true, 1});
people.push_back({L"alan", L"turing", 41, true, 2});

db->Save(people);
EXPECT_EQ(2u, db->FetchAll<Person>().size());

people[0].age = 37;
db->Update(people);
EXPECT_EQ(37, db->Fetch<Person>(1).age);
}

// The SaveAutoIncrement std::vector wrapper writes the generated ids back into the caller's
// std::vector, just like the fcpp::vector overload.
TEST_F(FunctionalVectorTest, SaveAutoIncrementStdVectorWrapperWritesIdsBack) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true});
people.push_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}
} // namespace
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { // Auto-enable theater mode on YouTube (function() { function tryTheater() { var btn = document.querySelector('button[aria-label="Theater mode"], ytd-player #player button[title="Theater mode"]'); if (btn && !btn.classList.contains('activated')) { btn.click(); } } // Try immediately tryTheater(); // Try after navigation (SPA) var lastUrl = location.href; setInterval(function() { if (location.href !== lastUrl) { lastUrl = location.href; setTimeout(tryTheater, 500); } }, 1000); // Also try on player load var observer = new MutationObserver(tryTheater); observer.observe(document.body, { childList: true, subtree: true }); })(); } } catch(__e) { console.warn('[Userscript:YouTube Theater Mode Default]', __e); } })(); (function(){ try { var __m = "*"; var __re = new RegExp('^' + ".*" + ' Adopt fcpp::vector in the public Database API by jkalias · Pull Request #39 · jkalias/sqlite-reflection · GitHub
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
37 changes: 36 additions & 1 deletion README.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -13,6 +13,7 @@ A C++ wrapper for SQLite that provides compile-time checked CRUD operations for
- [Opening and closing the database](#opening-and-closing-the-database)
- [Saving records](#saving-records)
- [Fetching records](#fetching-records)
- [Working with query results](#working-with-query-results)
- [Updating records](#updating-records)
- [Deleting records](#deleting-records)
- [Date and time fields](#date-and-time-fields)
Expand DownExpand Up@@ -346,6 +347,38 @@ Available predicate helpers include:

Predicate values are bound with SQLite prepared statements. Text payloads are treated as values, not SQL syntax.

## Working with query results

`FetchAll` and `Fetch` return an [`fcpp::vector<T>`](https://github.com/jkalias/functional_cpp)
rather than a `std::vector<T>`, so functional operations can be chained directly on the result
without wrapping it yourself:

```c++
// Full names of every adult, straight off the query result.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

// Predicate-style checks are available too.
const bool everyone_is_adult = db->FetchAll<Person>()
.all_of([](const Person& p) { return p.age >= 18; });
```

`fcpp::vector` also supports `map`, `all_of`/`any_of`/`none_of`, `sort`, `distinct`, `zip`, and lazy
pipelines via `.lazy()`; see the [functional_cpp](https://github.com/jkalias/functional_cpp)
documentation. The batch `Save`, `SaveAutoIncrement`, and `Update` overloads accept an
`fcpp::vector<T>` as well.

**Migration note.** Because the result type changed from `std::vector<T>` to `fcpp::vector<T>`:

- `auto` call sites, range-`for` loops, indexing (`result[i]`), and `size()` are unaffected.
- Code that binds a result to a `std::vector<T>` explicitly no longer compiles, because there is no
implicit conversion back. Iterate the result directly, keep it as `fcpp::vector` (or `auto`), or
construct a `std::vector` from its iterators: `std::vector<Person>(result.begin(), result.end())`.
- Indexing is **always bounds-checked**, in release builds too: `result[i]` for an out-of-range `i`
calls `std::abort()` instead of being undefined behavior (unless the library is built with
`FCPP_NO_PRECONDITION_CHECKS`).

## Updating records

Fetch or construct a record, change its fields, and pass it to `Update`. The `id` identifies the row to update.
Expand All@@ -363,7 +396,7 @@ Multiple records can be updated in one call:

```c++
// Update each record in the vector by its id.
std::vector<Person> people = db->FetchAll<Person>();
auto people = db->FetchAll<Person>(); // fcpp::vector<Person>
people[0].last_name = L"Rambo";
people[1].age = 20;

Expand DownExpand Up@@ -494,6 +527,8 @@ You can also open the generated `build/sqlite-cpp-reflection.sln` in Visual Stud

- CMake 3.14 or newer
- A C++11-compatible compiler
- [functional_cpp](https://github.com/jkalias/functional_cpp) for `fcpp::vector` (query results) and
`fcpp::optional_t` (nullable fields), header-only, fetched by CMake
- GoogleTest for tests, fetched by CMake
- SQLite, vendored in `src/sqlite3.c` and `src/internal/sqlite3.h`

Expand Down
48 changes: 38 additions & 10 deletions include/database.h
Original file line numberDiff line numberDiff line change
Expand Up@@ -32,6 +32,7 @@
#include "queries.h"
#include "query_predicates.h"
#include "reflection.h"
#include "vector.h" // fcpp::vector, the functional container returned by the query API

struct sqlite3;

Expand DownExpand Up@@ -66,19 +67,23 @@ class REFLECTION_EXPORT Database {
Database& operator=(Database&&) = delete;

/// Retrieves all entries of a given record from the database.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> FetchAll() const {
fcpp::vector<T> FetchAll() const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
EmptyPredicate empty;
return FetchRecords<T>(record, &empty);
}

/// Retrieves all entries of a given record from the database, which match a given predicate.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> Fetch(const QueryPredicateBase* predicate) const {
fcpp::vector<T> Fetch(const QueryPredicateBase* predicate) const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
return FetchRecords<T>(record, predicate);
Expand DownExpand Up@@ -120,26 +125,43 @@ class REFLECTION_EXPORT Database {
/// Saves multiple records iteratively in the database.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void Save(const std::vector<T>& models) {
void Save(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Save((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Save(const std::vector<T>& models) {
Save(fcpp::vector<T>(models));
}

/// Saves multiple records iteratively in the database, letting the database assign their ids.
/// The newly generated ids are written back into the passed-in models.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
void SaveAutoIncrement(fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (auto& model : models) {
model.id = SaveAutoIncrement((void*)&model, record);
}
}

/// std::vector compatibility overload: saves each record through the single-record overload, so
/// every generated id is written back into the caller's std::vector as soon as its row is
/// inserted. This preserves the ids of already-committed rows if a later row in the batch fails
/// (each insert commits independently), matching the pre-fcpp::vector behavior.
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
for (auto& model : models) {
SaveAutoIncrement(model);
}
}

/// Updates a given record in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
Expand All@@ -152,14 +174,20 @@ class REFLECTION_EXPORT Database {
/// Updates multiple records iteratively in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
void Update(const std::vector<T>& models) {
void Update(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Update((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Update(const std::vector<T>& models) {
Update(fcpp::vector<T>(models));
}

/// Deletes a given record from the database.
/// This corresponds to an DELETE query in the SQL syntax
template <typename T>
Expand DownExpand Up@@ -203,14 +231,14 @@ class REFLECTION_EXPORT Database {
/// each matching row directly from the prepared statement into a newly constructed T -
/// no intermediate string materialization of the result set
template <typename T>
std::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
fcpp::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
std::lock_guard<std::mutex> lock(db_mutex_);
FetchRecordsQuery query(db_, record, predicate);
std::vector<T> models;
fcpp::vector<T> models;
while (query.StepRow()) {
T model;
query.HydrateCurrentRow((void*)&model, record);
models.emplace_back(std::move(model));
models.insert_back(std::move(model));
}
return models;
}
Expand Down
165 changes: 165 additions & 0 deletions tests/functional_vector_test.cc
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,165 @@
// MIT License
//
// Copyright (c) 2026 Ioannis Kaliakatsos
//
// 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.

#include <gtest/gtest.h>

#include <string>
#include <vector>

#include "database.h"
#include "person.h"
#include "vector.h"

using namespace sqlite_reflection;

namespace {
class FunctionalVectorTest : public ::testing::Test {
void SetUp() override {
Database::Initialize("");
}

void TearDown() override {
Database::Finalize();
}
};

// The whole point of the migration: a fetch result is an fcpp::vector, so functional operations
// can be chained directly on it, without the caller wrapping the std::vector themselves.
TEST_F(FunctionalVectorTest, FetchResultChainsFilterAndMap) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
{L"alan", L"turing", 41, true, 3},
});

// filter() (mutating, returns vector&) then map<U>() (non-mutating) chained on the temporary
// returned by FetchAll(), exactly as advertised in the README.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

ASSERT_EQ(2u, adult_names.size());
EXPECT_EQ(L"ada lovelace", adult_names[0]);
EXPECT_EQ(L"alan turing", adult_names[1]);
}

TEST_F(FunctionalVectorTest, FetchResultSupportsAllOfAnyOf) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
});

const auto people = db->FetchAll<Person>();
EXPECT_TRUE(people.all_of([](const Person& p) { return p.age > 0; }));
EXPECT_FALSE(people.all_of([](const Person& p) { return p.age >= 18; }));
EXPECT_TRUE(people.any_of([](const Person& p) { return p.age < 18; }));
EXPECT_FALSE(people.any_of([](const Person& p) { return p.age > 100; }));
}

// range-for and indexing over a fetch result keep working as with a std::vector
TEST_F(FunctionalVectorTest, FetchResultSupportsRangeForAndIndexing) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"alan", L"turing", 41, true, 2},
});

const auto people = db->FetchAll<Person>();

int64_t total_age = 0;
for (const auto& person : people) {
total_age += person.age;
}
EXPECT_EQ(77, total_age);
EXPECT_EQ(L"ada", people[0].first_name);
EXPECT_EQ(L"alan", people[1].first_name);
}

// Batch Save/Update accept an fcpp::vector directly.
TEST_F(FunctionalVectorTest, BatchSaveAndUpdateAcceptFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true, 1}).insert_back({L"alan", L"turing", 41, true, 2});

db->Save(people);

auto fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(36, fetched[0].age);

people[0].age = 37;
db->Update(people);

fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(37, fetched[0].age);
}

// SaveAutoIncrement writes the generated ids back into the passed-in fcpp::vector.
TEST_F(FunctionalVectorTest, SaveAutoIncrementWritesIdsBackIntoFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true}).insert_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}

// The std::vector compatibility overloads keep working for callers that still pass a std::vector.
TEST_F(FunctionalVectorTest, StdVectorCompatibilityOverloadsStillWork) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true, 1});
people.push_back({L"alan", L"turing", 41, true, 2});

db->Save(people);
EXPECT_EQ(2u, db->FetchAll<Person>().size());

people[0].age = 37;
db->Update(people);
EXPECT_EQ(37, db->Fetch<Person>(1).age);
}

// The SaveAutoIncrement std::vector wrapper writes the generated ids back into the caller's
// std::vector, just like the fcpp::vector overload.
TEST_F(FunctionalVectorTest, SaveAutoIncrementStdVectorWrapperWritesIdsBack) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true});
people.push_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}
} // namespace
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { // Remove or un-stick sticky/fixed headers that block content (function() { function unstick() { document.querySelectorAll('header, nav, [role="banner"], .header, .navbar, .sticky, .fixed-top, [style*="position: fixed"], [style*="position:sticky"]').forEach(function(el) { if (el.style.position === 'fixed' || el.style.position === 'sticky' || getComputedStyle(el).position === 'fixed' || getComputedStyle(el).position === 'sticky') { el.style.position = 'static'; el.style.top = 'auto'; el.style.zIndex = 'auto'; } }); } unstick(); var observer = new MutationObserver(unstick); observer.observe(document.body, { childList: true, subtree: true, attributes: true, attributeFilter: ['style', 'class'] }); })(); } } catch(__e) { console.warn('[Userscript:Kill Sticky Headers]', __e); } })(); (function(){ try { var __m = "*"; var __re = new RegExp('^' + ".*" + ' Adopt fcpp::vector in the public Database API by jkalias · Pull Request #39 · jkalias/sqlite-reflection · GitHub
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
37 changes: 36 additions & 1 deletion README.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -13,6 +13,7 @@ A C++ wrapper for SQLite that provides compile-time checked CRUD operations for
- [Opening and closing the database](#opening-and-closing-the-database)
- [Saving records](#saving-records)
- [Fetching records](#fetching-records)
- [Working with query results](#working-with-query-results)
- [Updating records](#updating-records)
- [Deleting records](#deleting-records)
- [Date and time fields](#date-and-time-fields)
Expand DownExpand Up@@ -346,6 +347,38 @@ Available predicate helpers include:

Predicate values are bound with SQLite prepared statements. Text payloads are treated as values, not SQL syntax.

## Working with query results

`FetchAll` and `Fetch` return an [`fcpp::vector<T>`](https://github.com/jkalias/functional_cpp)
rather than a `std::vector<T>`, so functional operations can be chained directly on the result
without wrapping it yourself:

```c++
// Full names of every adult, straight off the query result.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

// Predicate-style checks are available too.
const bool everyone_is_adult = db->FetchAll<Person>()
.all_of([](const Person& p) { return p.age >= 18; });
```

`fcpp::vector` also supports `map`, `all_of`/`any_of`/`none_of`, `sort`, `distinct`, `zip`, and lazy
pipelines via `.lazy()`; see the [functional_cpp](https://github.com/jkalias/functional_cpp)
documentation. The batch `Save`, `SaveAutoIncrement`, and `Update` overloads accept an
`fcpp::vector<T>` as well.

**Migration note.** Because the result type changed from `std::vector<T>` to `fcpp::vector<T>`:

- `auto` call sites, range-`for` loops, indexing (`result[i]`), and `size()` are unaffected.
- Code that binds a result to a `std::vector<T>` explicitly no longer compiles, because there is no
implicit conversion back. Iterate the result directly, keep it as `fcpp::vector` (or `auto`), or
construct a `std::vector` from its iterators: `std::vector<Person>(result.begin(), result.end())`.
- Indexing is **always bounds-checked**, in release builds too: `result[i]` for an out-of-range `i`
calls `std::abort()` instead of being undefined behavior (unless the library is built with
`FCPP_NO_PRECONDITION_CHECKS`).

## Updating records

Fetch or construct a record, change its fields, and pass it to `Update`. The `id` identifies the row to update.
Expand All@@ -363,7 +396,7 @@ Multiple records can be updated in one call:

```c++
// Update each record in the vector by its id.
std::vector<Person> people = db->FetchAll<Person>();
auto people = db->FetchAll<Person>(); // fcpp::vector<Person>
people[0].last_name = L"Rambo";
people[1].age = 20;

Expand DownExpand Up@@ -494,6 +527,8 @@ You can also open the generated `build/sqlite-cpp-reflection.sln` in Visual Stud

- CMake 3.14 or newer
- A C++11-compatible compiler
- [functional_cpp](https://github.com/jkalias/functional_cpp) for `fcpp::vector` (query results) and
`fcpp::optional_t` (nullable fields), header-only, fetched by CMake
- GoogleTest for tests, fetched by CMake
- SQLite, vendored in `src/sqlite3.c` and `src/internal/sqlite3.h`

Expand Down
48 changes: 38 additions & 10 deletions include/database.h
Original file line numberDiff line numberDiff line change
Expand Up@@ -32,6 +32,7 @@
#include "queries.h"
#include "query_predicates.h"
#include "reflection.h"
#include "vector.h" // fcpp::vector, the functional container returned by the query API

struct sqlite3;

Expand DownExpand Up@@ -66,19 +67,23 @@ class REFLECTION_EXPORT Database {
Database& operator=(Database&&) = delete;

/// Retrieves all entries of a given record from the database.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> FetchAll() const {
fcpp::vector<T> FetchAll() const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
EmptyPredicate empty;
return FetchRecords<T>(record, &empty);
}

/// Retrieves all entries of a given record from the database, which match a given predicate.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> Fetch(const QueryPredicateBase* predicate) const {
fcpp::vector<T> Fetch(const QueryPredicateBase* predicate) const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
return FetchRecords<T>(record, predicate);
Expand DownExpand Up@@ -120,26 +125,43 @@ class REFLECTION_EXPORT Database {
/// Saves multiple records iteratively in the database.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void Save(const std::vector<T>& models) {
void Save(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Save((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Save(const std::vector<T>& models) {
Save(fcpp::vector<T>(models));
}

/// Saves multiple records iteratively in the database, letting the database assign their ids.
/// The newly generated ids are written back into the passed-in models.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
void SaveAutoIncrement(fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (auto& model : models) {
model.id = SaveAutoIncrement((void*)&model, record);
}
}

/// std::vector compatibility overload: saves each record through the single-record overload, so
/// every generated id is written back into the caller's std::vector as soon as its row is
/// inserted. This preserves the ids of already-committed rows if a later row in the batch fails
/// (each insert commits independently), matching the pre-fcpp::vector behavior.
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
for (auto& model : models) {
SaveAutoIncrement(model);
}
}

/// Updates a given record in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
Expand All@@ -152,14 +174,20 @@ class REFLECTION_EXPORT Database {
/// Updates multiple records iteratively in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
void Update(const std::vector<T>& models) {
void Update(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Update((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Update(const std::vector<T>& models) {
Update(fcpp::vector<T>(models));
}

/// Deletes a given record from the database.
/// This corresponds to an DELETE query in the SQL syntax
template <typename T>
Expand DownExpand Up@@ -203,14 +231,14 @@ class REFLECTION_EXPORT Database {
/// each matching row directly from the prepared statement into a newly constructed T -
/// no intermediate string materialization of the result set
template <typename T>
std::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
fcpp::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
std::lock_guard<std::mutex> lock(db_mutex_);
FetchRecordsQuery query(db_, record, predicate);
std::vector<T> models;
fcpp::vector<T> models;
while (query.StepRow()) {
T model;
query.HydrateCurrentRow((void*)&model, record);
models.emplace_back(std::move(model));
models.insert_back(std::move(model));
}
return models;
}
Expand Down
165 changes: 165 additions & 0 deletions tests/functional_vector_test.cc
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,165 @@
// MIT License
//
// Copyright (c) 2026 Ioannis Kaliakatsos
//
// 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.

#include <gtest/gtest.h>

#include <string>
#include <vector>

#include "database.h"
#include "person.h"
#include "vector.h"

using namespace sqlite_reflection;

namespace {
class FunctionalVectorTest : public ::testing::Test {
void SetUp() override {
Database::Initialize("");
}

void TearDown() override {
Database::Finalize();
}
};

// The whole point of the migration: a fetch result is an fcpp::vector, so functional operations
// can be chained directly on it, without the caller wrapping the std::vector themselves.
TEST_F(FunctionalVectorTest, FetchResultChainsFilterAndMap) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
{L"alan", L"turing", 41, true, 3},
});

// filter() (mutating, returns vector&) then map<U>() (non-mutating) chained on the temporary
// returned by FetchAll(), exactly as advertised in the README.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

ASSERT_EQ(2u, adult_names.size());
EXPECT_EQ(L"ada lovelace", adult_names[0]);
EXPECT_EQ(L"alan turing", adult_names[1]);
}

TEST_F(FunctionalVectorTest, FetchResultSupportsAllOfAnyOf) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
});

const auto people = db->FetchAll<Person>();
EXPECT_TRUE(people.all_of([](const Person& p) { return p.age > 0; }));
EXPECT_FALSE(people.all_of([](const Person& p) { return p.age >= 18; }));
EXPECT_TRUE(people.any_of([](const Person& p) { return p.age < 18; }));
EXPECT_FALSE(people.any_of([](const Person& p) { return p.age > 100; }));
}

// range-for and indexing over a fetch result keep working as with a std::vector
TEST_F(FunctionalVectorTest, FetchResultSupportsRangeForAndIndexing) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"alan", L"turing", 41, true, 2},
});

const auto people = db->FetchAll<Person>();

int64_t total_age = 0;
for (const auto& person : people) {
total_age += person.age;
}
EXPECT_EQ(77, total_age);
EXPECT_EQ(L"ada", people[0].first_name);
EXPECT_EQ(L"alan", people[1].first_name);
}

// Batch Save/Update accept an fcpp::vector directly.
TEST_F(FunctionalVectorTest, BatchSaveAndUpdateAcceptFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true, 1}).insert_back({L"alan", L"turing", 41, true, 2});

db->Save(people);

auto fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(36, fetched[0].age);

people[0].age = 37;
db->Update(people);

fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(37, fetched[0].age);
}

// SaveAutoIncrement writes the generated ids back into the passed-in fcpp::vector.
TEST_F(FunctionalVectorTest, SaveAutoIncrementWritesIdsBackIntoFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true}).insert_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}

// The std::vector compatibility overloads keep working for callers that still pass a std::vector.
TEST_F(FunctionalVectorTest, StdVectorCompatibilityOverloadsStillWork) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true, 1});
people.push_back({L"alan", L"turing", 41, true, 2});

db->Save(people);
EXPECT_EQ(2u, db->FetchAll<Person>().size());

people[0].age = 37;
db->Update(people);
EXPECT_EQ(37, db->Fetch<Person>(1).age);
}

// The SaveAutoIncrement std::vector wrapper writes the generated ids back into the caller's
// std::vector, just like the fcpp::vector overload.
TEST_F(FunctionalVectorTest, SaveAutoIncrementStdVectorWrapperWritesIdsBack) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true});
people.push_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}
} // namespace
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { // Universal Dark Mode - works on any site (function() { var enabled = true; function applyDarkMode() { if (!enabled) return; // Create style element if it doesn't exist var style = document.getElementById('universal-dark-mode-style'); if (!style) { style = document.createElement('style'); style.id = 'universal-dark-mode-style'; document.head.appendChild(style); } // Dark mode CSS - inverts colors but preserves images/video style.textContent = ' /* Invert everything except media */ html { filter: invert(1) hue-rotate(180deg) !important; background: #1a1a2e !important; } /* Restore images, videos, iframes, canvas */ img, video, iframe, canvas, svg, picture, [style*="background-image"] { filter: invert(1) hue-rotate(180deg) !important; } /* Preserve specific elements that should not be inverted */ .no-dark-mode, .no-dark-mode *, [data-theme="light"], [data-theme="light"], .ace_editor, .ace_editor *, .CodeMirror, .CodeMirror *, .monaco-editor, .monaco-editor *, .markdown-body pre, .markdown-body pre *, .highlight, .highlight *, pre code, pre code * { filter: none !important; } /* Fix common UI elements */ .modal, .popup, .dropdown-menu, .tooltip, .popover { filter: invert(1) hue-rotate(180deg) !important; background: #2d2d44 !important; border-color: #444 !important; } /* Scrollbars */ ::-webkit-scrollbar { background: #1a1a2e !important; } ::-webkit-scrollbar-thumb { background: #444 !important; } ::-webkit-scrollbar-thumb:hover { background: #555 !important; } /* Selection */ ::selection { background: #4ecdc4 !important; color: #1a1a2e !important; } ::-moz-selection { background: #4ecdc4 !important; color: #1a1a2e !important; } '; } function removeDarkMode() { var style = document.getElementById('universal-dark-mode-style'); if (style) style.remove(); } // Toggle with Alt+Shift+D document.addEventListener('keydown', function(e) { if (e.altKey && e.shiftKey && e.key === 'D') { e.preventDefault(); enabled = !enabled; if (enabled) { applyDarkMode(); console.log('[Universal Dark Mode] Enabled'); } else { removeDarkMode(); console.log('[Universal Dark Mode] Disabled'); } } }); // Apply on load applyDarkMode(); // Re-apply on dynamic content var observer = new MutationObserver(function(mutations) { if (enabled && !document.getElementById('universal-dark-mode-style')) { applyDarkMode(); } }); observer.observe(document.head, { childList: true }); console.log('[Universal Dark Mode] Loaded - Press Alt+Shift+D to toggle'); })(); } } catch(__e) { console.warn('[Userscript:Universal Dark Mode]', __e); } })(); })(); Adopt fcpp::vector in the public Database API by jkalias · Pull Request #39 · jkalias/sqlite-reflection · GitHub
Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
37 changes: 36 additions & 1 deletion README.md
Original file line numberDiff line numberDiff line change
Expand Up@@ -13,6 +13,7 @@ A C++ wrapper for SQLite that provides compile-time checked CRUD operations for
- [Opening and closing the database](#opening-and-closing-the-database)
- [Saving records](#saving-records)
- [Fetching records](#fetching-records)
- [Working with query results](#working-with-query-results)
- [Updating records](#updating-records)
- [Deleting records](#deleting-records)
- [Date and time fields](#date-and-time-fields)
Expand DownExpand Up@@ -346,6 +347,38 @@ Available predicate helpers include:

Predicate values are bound with SQLite prepared statements. Text payloads are treated as values, not SQL syntax.

## Working with query results

`FetchAll` and `Fetch` return an [`fcpp::vector<T>`](https://github.com/jkalias/functional_cpp)
rather than a `std::vector<T>`, so functional operations can be chained directly on the result
without wrapping it yourself:

```c++
// Full names of every adult, straight off the query result.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

// Predicate-style checks are available too.
const bool everyone_is_adult = db->FetchAll<Person>()
.all_of([](const Person& p) { return p.age >= 18; });
```

`fcpp::vector` also supports `map`, `all_of`/`any_of`/`none_of`, `sort`, `distinct`, `zip`, and lazy
pipelines via `.lazy()`; see the [functional_cpp](https://github.com/jkalias/functional_cpp)
documentation. The batch `Save`, `SaveAutoIncrement`, and `Update` overloads accept an
`fcpp::vector<T>` as well.

**Migration note.** Because the result type changed from `std::vector<T>` to `fcpp::vector<T>`:

- `auto` call sites, range-`for` loops, indexing (`result[i]`), and `size()` are unaffected.
- Code that binds a result to a `std::vector<T>` explicitly no longer compiles, because there is no
implicit conversion back. Iterate the result directly, keep it as `fcpp::vector` (or `auto`), or
construct a `std::vector` from its iterators: `std::vector<Person>(result.begin(), result.end())`.
- Indexing is **always bounds-checked**, in release builds too: `result[i]` for an out-of-range `i`
calls `std::abort()` instead of being undefined behavior (unless the library is built with
`FCPP_NO_PRECONDITION_CHECKS`).

## Updating records

Fetch or construct a record, change its fields, and pass it to `Update`. The `id` identifies the row to update.
Expand All@@ -363,7 +396,7 @@ Multiple records can be updated in one call:

```c++
// Update each record in the vector by its id.
std::vector<Person> people = db->FetchAll<Person>();
auto people = db->FetchAll<Person>(); // fcpp::vector<Person>
people[0].last_name = L"Rambo";
people[1].age = 20;

Expand DownExpand Up@@ -494,6 +527,8 @@ You can also open the generated `build/sqlite-cpp-reflection.sln` in Visual Stud

- CMake 3.14 or newer
- A C++11-compatible compiler
- [functional_cpp](https://github.com/jkalias/functional_cpp) for `fcpp::vector` (query results) and
`fcpp::optional_t` (nullable fields), header-only, fetched by CMake
- GoogleTest for tests, fetched by CMake
- SQLite, vendored in `src/sqlite3.c` and `src/internal/sqlite3.h`

Expand Down
48 changes: 38 additions & 10 deletions include/database.h
Original file line numberDiff line numberDiff line change
Expand Up@@ -32,6 +32,7 @@
#include "queries.h"
#include "query_predicates.h"
#include "reflection.h"
#include "vector.h" // fcpp::vector, the functional container returned by the query API

struct sqlite3;

Expand DownExpand Up@@ -66,19 +67,23 @@ class REFLECTION_EXPORT Database {
Database& operator=(Database&&) = delete;

/// Retrieves all entries of a given record from the database.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> FetchAll() const {
fcpp::vector<T> FetchAll() const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
EmptyPredicate empty;
return FetchRecords<T>(record, &empty);
}

/// Retrieves all entries of a given record from the database, which match a given predicate.
/// This corresponds to a SELECT query in the SQL syntax
/// This corresponds to a SELECT query in the SQL syntax.
/// The result is an fcpp::vector, so functional operations (filter/map/...) can be chained
/// directly on it; range-for, indexing and size() work as with a std::vector.
template <typename T>
std::vector<T> Fetch(const QueryPredicateBase* predicate) const {
fcpp::vector<T> Fetch(const QueryPredicateBase* predicate) const {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
return FetchRecords<T>(record, predicate);
Expand DownExpand Up@@ -120,26 +125,43 @@ class REFLECTION_EXPORT Database {
/// Saves multiple records iteratively in the database.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void Save(const std::vector<T>& models) {
void Save(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Save((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Save(const std::vector<T>& models) {
Save(fcpp::vector<T>(models));
}

/// Saves multiple records iteratively in the database, letting the database assign their ids.
/// The newly generated ids are written back into the passed-in models.
/// This corresponds to an INSERT query in the SQL syntax
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
void SaveAutoIncrement(fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (auto& model : models) {
model.id = SaveAutoIncrement((void*)&model, record);
}
}

/// std::vector compatibility overload: saves each record through the single-record overload, so
/// every generated id is written back into the caller's std::vector as soon as its row is
/// inserted. This preserves the ids of already-committed rows if a later row in the batch fails
/// (each insert commits independently), matching the pre-fcpp::vector behavior.
template <typename T>
void SaveAutoIncrement(std::vector<T>& models) {
for (auto& model : models) {
SaveAutoIncrement(model);
}
}

/// Updates a given record in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
Expand All@@ -152,14 +174,20 @@ class REFLECTION_EXPORT Database {
/// Updates multiple records iteratively in the database.
/// This corresponds to an UPDATE query in the SQL syntax
template <typename T>
void Update(const std::vector<T>& models) {
void Update(const fcpp::vector<T>& models) {
const auto type_id = typeid(T).name();
const auto& record = GetRecord(type_id);
for (const auto& model : models) {
Update((void*)&model, record);
}
}

/// std::vector compatibility overload: copies into an fcpp::vector and forwards.
template <typename T>
void Update(const std::vector<T>& models) {
Update(fcpp::vector<T>(models));
}

/// Deletes a given record from the database.
/// This corresponds to an DELETE query in the SQL syntax
template <typename T>
Expand DownExpand Up@@ -203,14 +231,14 @@ class REFLECTION_EXPORT Database {
/// each matching row directly from the prepared statement into a newly constructed T -
/// no intermediate string materialization of the result set
template <typename T>
std::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
fcpp::vector<T> FetchRecords(const Reflection& record, const QueryPredicateBase* predicate) const {
std::lock_guard<std::mutex> lock(db_mutex_);
FetchRecordsQuery query(db_, record, predicate);
std::vector<T> models;
fcpp::vector<T> models;
while (query.StepRow()) {
T model;
query.HydrateCurrentRow((void*)&model, record);
models.emplace_back(std::move(model));
models.insert_back(std::move(model));
}
return models;
}
Expand Down
165 changes: 165 additions & 0 deletions tests/functional_vector_test.cc
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,165 @@
// MIT License
//
// Copyright (c) 2026 Ioannis Kaliakatsos
//
// 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.

#include <gtest/gtest.h>

#include <string>
#include <vector>

#include "database.h"
#include "person.h"
#include "vector.h"

using namespace sqlite_reflection;

namespace {
class FunctionalVectorTest : public ::testing::Test {
void SetUp() override {
Database::Initialize("");
}

void TearDown() override {
Database::Finalize();
}
};

// The whole point of the migration: a fetch result is an fcpp::vector, so functional operations
// can be chained directly on it, without the caller wrapping the std::vector themselves.
TEST_F(FunctionalVectorTest, FetchResultChainsFilterAndMap) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
{L"alan", L"turing", 41, true, 3},
});

// filter() (mutating, returns vector&) then map<U>() (non-mutating) chained on the temporary
// returned by FetchAll(), exactly as advertised in the README.
const auto adult_names = db->FetchAll<Person>()
.filter([](const Person& p) { return p.age >= 18; })
.map<std::wstring>([](const Person& p) { return p.GetFullName(); });

ASSERT_EQ(2u, adult_names.size());
EXPECT_EQ(L"ada lovelace", adult_names[0]);
EXPECT_EQ(L"alan turing", adult_names[1]);
}

TEST_F(FunctionalVectorTest, FetchResultSupportsAllOfAnyOf) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"grace", L"hopper", 17, true, 2},
});

const auto people = db->FetchAll<Person>();
EXPECT_TRUE(people.all_of([](const Person& p) { return p.age > 0; }));
EXPECT_FALSE(people.all_of([](const Person& p) { return p.age >= 18; }));
EXPECT_TRUE(people.any_of([](const Person& p) { return p.age < 18; }));
EXPECT_FALSE(people.any_of([](const Person& p) { return p.age > 100; }));
}

// range-for and indexing over a fetch result keep working as with a std::vector
TEST_F(FunctionalVectorTest, FetchResultSupportsRangeForAndIndexing) {
const auto db = Database::Instance();
db->Save(std::vector<Person>{
{L"ada", L"lovelace", 36, true, 1},
{L"alan", L"turing", 41, true, 2},
});

const auto people = db->FetchAll<Person>();

int64_t total_age = 0;
for (const auto& person : people) {
total_age += person.age;
}
EXPECT_EQ(77, total_age);
EXPECT_EQ(L"ada", people[0].first_name);
EXPECT_EQ(L"alan", people[1].first_name);
}

// Batch Save/Update accept an fcpp::vector directly.
TEST_F(FunctionalVectorTest, BatchSaveAndUpdateAcceptFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true, 1}).insert_back({L"alan", L"turing", 41, true, 2});

db->Save(people);

auto fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(36, fetched[0].age);

people[0].age = 37;
db->Update(people);

fetched = db->FetchAll<Person>();
ASSERT_EQ(2u, fetched.size());
EXPECT_EQ(37, fetched[0].age);
}

// SaveAutoIncrement writes the generated ids back into the passed-in fcpp::vector.
TEST_F(FunctionalVectorTest, SaveAutoIncrementWritesIdsBackIntoFcppVector) {
const auto db = Database::Instance();

fcpp::vector<Person> people;
people.insert_back({L"ada", L"lovelace", 36, true}).insert_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}

// The std::vector compatibility overloads keep working for callers that still pass a std::vector.
TEST_F(FunctionalVectorTest, StdVectorCompatibilityOverloadsStillWork) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true, 1});
people.push_back({L"alan", L"turing", 41, true, 2});

db->Save(people);
EXPECT_EQ(2u, db->FetchAll<Person>().size());

people[0].age = 37;
db->Update(people);
EXPECT_EQ(37, db->Fetch<Person>(1).age);
}

// The SaveAutoIncrement std::vector wrapper writes the generated ids back into the caller's
// std::vector, just like the fcpp::vector overload.
TEST_F(FunctionalVectorTest, SaveAutoIncrementStdVectorWrapperWritesIdsBack) {
const auto db = Database::Instance();

std::vector<Person> people;
people.push_back({L"ada", L"lovelace", 36, true});
people.push_back({L"alan", L"turing", 41, true});

db->SaveAutoIncrement(people);

EXPECT_EQ(1, people[0].id);
EXPECT_EQ(2, people[1].id);
EXPECT_EQ(2u, db->FetchAll<Person>().size());
}
} // namespace
Loading