67 lines
2.2 KiB
C
67 lines
2.2 KiB
C
|
#pragma once
|
||
|
|
|
||
|
|
#include <sqlite3.h>
|
||
|
|
#include <string> // std::string
|
||
|
|
#include <utility> // std::forward, std::move
|
||
|
|
#include <tuple> // std::tuple, std::make_tuple
|
||
|
|
|
||
|
|
#include "row_extractor.h"
|
||
|
|
#include "error_code.h"
|
||
|
|
#include "iterator.h"
|
||
|
|
#include "ast_iterator.h"
|
||
|
|
#include "prepared_statement.h"
|
||
|
|
#include "connection_holder.h"
|
||
|
|
#include "util.h"
|
||
|
|
|
||
|
|
namespace sqlite_orm {
|
||
|
|
|
||
|
|
namespace internal {
|
||
|
|
|
||
|
|
/**
|
||
|
|
* This class does not related to SQL view. This is a container like class which is returned by
|
||
|
|
* by storage_t::iterate function. This class contains STL functions:
|
||
|
|
* - size_t size()
|
||
|
|
* - bool empty()
|
||
|
|
* - iterator end()
|
||
|
|
* - iterator begin()
|
||
|
|
* All these functions are not right const cause all of them may open SQLite connections.
|
||
|
|
*/
|
||
|
|
template<class T, class S, class... Args>
|
||
|
|
struct view_t {
|
||
|
|
using mapped_type = T;
|
||
|
|
using storage_type = S;
|
||
|
|
using self = view_t<T, S, Args...>;
|
||
|
|
|
||
|
|
storage_type& storage;
|
||
|
|
connection_ref connection;
|
||
|
|
get_all_t<T, std::vector<T>, Args...> args;
|
||
|
|
|
||
|
|
view_t(storage_type& stor, decltype(connection) conn, Args&&... args_) :
|
||
|
|
storage(stor), connection(std::move(conn)), args{std::make_tuple(std::forward<Args>(args_)...)} {}
|
||
|
|
|
||
|
|
size_t size() const {
|
||
|
|
return this->storage.template count<T>();
|
||
|
|
}
|
||
|
|
|
||
|
|
bool empty() const {
|
||
|
|
return !this->size();
|
||
|
|
}
|
||
|
|
|
||
|
|
iterator_t<self> begin() {
|
||
|
|
using context_t = serializer_context<typename storage_type::db_objects_type>;
|
||
|
|
context_t context{obtain_db_objects(this->storage)};
|
||
|
|
context.skip_table_name = false;
|
||
|
|
context.replace_bindable_with_question = true;
|
||
|
|
|
||
|
|
statement_finalizer stmt{prepare_stmt(this->connection.get(), serialize(this->args, context))};
|
||
|
|
iterate_ast(this->args.conditions, conditional_binder{stmt.get()});
|
||
|
|
return {std::move(stmt), *this};
|
||
|
|
}
|
||
|
|
|
||
|
|
iterator_t<self> end() {
|
||
|
|
return {};
|
||
|
|
}
|
||
|
|
};
|
||
|
|
}
|
||
|
|
}
|