0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-11-17 23:40:57 +01:00

ircd::db: Rename where to query.

This commit is contained in:
Jason Volk 2017-09-27 18:24:36 -07:00
parent 8ceafd4281
commit dacff8eb9f
5 changed files with 264 additions and 225 deletions

View file

@ -142,7 +142,7 @@ enum ircd::db::op
#include "db/index.h" #include "db/index.h"
#include "db/json.h" #include "db/json.h"
#include "db/iov.h" #include "db/iov.h"
#include "db/where.h" #include "db/query.h"
#include "db/cursor.h" #include "db/cursor.h"
namespace ircd namespace ircd

View file

@ -36,11 +36,11 @@ struct ircd::db::cursor
struct const_reverse_iterator; struct const_reverse_iterator;
struct const_iterator; struct const_iterator;
using where_type = db::where<tuple>; template<enum where where = where::noop> using query_type = db::query<tuple, where>;
using iterator_type = const_iterator; using iterator_type = const_iterator;
struct index index; struct index index;
const where_type *where{nullptr}; const query_type<> *query{nullptr};
const_iterator end(const string_view &key = {}); const_iterator end(const string_view &key = {});
const_iterator begin(const string_view &key = {}); const_iterator begin(const string_view &key = {});
@ -48,9 +48,9 @@ struct ircd::db::cursor
const_reverse_iterator rend(const string_view &key = {}); const_reverse_iterator rend(const string_view &key = {});
const_reverse_iterator rbegin(const string_view &key = {}); const_reverse_iterator rbegin(const string_view &key = {});
cursor(const string_view &index, const where_type *const &where = nullptr) cursor(const string_view &index, const query_type<> *const &query = nullptr)
:index{*d, index} :index{*d, index}
,where{where} ,query{query}
{} {}
}; };
@ -64,9 +64,9 @@ struct ircd::db::cursor<d, tuple>::const_iterator_base
using reference = value_type &; using reference = value_type &;
using difference_type = size_t; using difference_type = size_t;
using iterator_category = std::bidirectional_iterator_tag; using iterator_category = std::bidirectional_iterator_tag;
using where_type = cursor::where_type; template<enum where where = where::noop> using query_type = cursor::query_type<where>;
const where_type *where{nullptr}; const query_type<> *query{nullptr};
index_iterator idx; index_iterator idx;
db::row row; db::row row;
mutable tuple v; mutable tuple v;
@ -170,7 +170,7 @@ template<class index_iterator>
ircd::db::cursor<d, tuple>::const_iterator_base<index_iterator>::const_iterator_base(const cursor &c, ircd::db::cursor<d, tuple>::const_iterator_base<index_iterator>::const_iterator_base(const cursor &c,
index_iterator idx, index_iterator idx,
const gopts &opts) const gopts &opts)
:where{c.where} :query{c.query}
,idx{std::move(idx)} ,idx{std::move(idx)}
,row ,row
{ {
@ -193,10 +193,10 @@ ircd::db::cursor<d, tuple>::const_iterator_base<index_iterator>::const_iterator_
if(invalid) if(invalid)
return; return;
if(!this->where) if(!this->query)
return; return;
if(!(*this->where)(this->operator*())) if(!(*this->query)(this->operator*()))
this->operator++(); this->operator++();
} }
@ -236,7 +236,7 @@ ircd::db::cursor<d, tuple>::const_iterator_base<index_iterator>::seek_row()
return false; return false;
stale = true; stale = true;
if(this->where && !(*this->where)(this->operator*())) if(this->query && !(*this->query)(this->operator*()))
return false; return false;
return true; return true;

236
include/ircd/db/query.h Normal file
View file

@ -0,0 +1,236 @@
/*
* Copyright (C) 2016 Charybdis Development Team
* Copyright (C) 2016 Jason Volk <jason@zemos.net>
*
* Permission to use, copy, modify, and/or distribute this software for any
* purpose with or without fee is hereby granted, provided that the above
* copyright notice and this permission notice is present in all copies.
*
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT,
* INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
* STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
* IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGE.
*
*/
#pragma once
#define HAVE_IRCD_DB_QUERY_H
namespace ircd::db
{
/// Types of query clauses.
enum class where
{
noop,
test,
equal,
not_equal,
logical_or,
logical_and,
logical_not,
};
string_view reflect(const where &);
/// The query provides a decision tree oriented around the structure of
/// a tuple. All queries inherit from query<> which can execute the
/// derived's test via the virtual operator(). The abstract query instance
/// stores the type of its derived portion for downcasting. Downcasting is
/// used to get more information from the query to get a result faster, ex.
/// where::equal, the keys being tested might impact the db fetch pattern.
/// or searching a logic tree of where::logical_* for the most efficient
/// db fetches to make next.
template<class tuple, enum where = where::noop> struct query;
template<class tuple> struct query<tuple, where::noop>;
template<class tuple> struct query<tuple, where::test>;
template<class tuple> struct query<tuple, where::equal>;
template<class tuple> struct query<tuple, where::not_equal>;
template<class tuple> struct query<tuple, where::logical_or>;
template<class tuple> struct query<tuple, where::logical_and>;
template<class tuple> struct query<tuple, where::logical_not>;
}
template<class tuple>
struct ircd::db::query<tuple, ircd::db::where::noop>
{
virtual bool operator()(const tuple &) const
{
return true;
}
// Stores the type of the derived class for downcasting. This is important
// in order to evaluate details of the query.
where type;
query(const enum where &type = where::noop)
:type{type}
{}
virtual ~query() noexcept {}
};
template<class tuple>
struct ircd::db::query<tuple, ircd::db::where::test>
:query<tuple>
{
using function = std::function<bool (const tuple &)>;
function closure;
bool operator()(const tuple &t) const override
{
return closure(t);
}
query(function closure)
:query<tuple>{where::test}
,closure{std::move(closure)}
{}
};
template<class tuple>
struct ircd::db::query<tuple, ircd::db::where::equal>
:query<tuple>
{
tuple value;
bool operator()(const tuple &) const override;
query(const tuple &value)
:query<tuple>{where::equal}
,value{value}
{}
query(const json::members &members)
:query<tuple>{where::equal}
,value{members}
{}
};
template<class tuple>
bool
ircd::db::query<tuple, ircd::db::where::equal>::operator()(const tuple &value)
const
{
return json::until(this->value, value, []
(const auto &key, const auto &a, const auto &b)
{
if(!a)
return true;
return a == b;
});
}
template<class tuple>
struct ircd::db::query<tuple, ircd::db::where::not_equal>
:query<tuple>
{
tuple value;
bool operator()(const tuple &) const override;
query(const tuple &value)
:query<tuple>{where::not_equal}
,value{value}
{}
query(const json::members &members)
:query<tuple>{where::not_equal}
,value{members}
{}
};
template<class tuple>
bool
ircd::db::query<tuple, ircd::db::where::not_equal>::operator()(const tuple &value)
const
{
return !json::until(this->value, value, []
(const auto &key, const auto &a, const auto &b)
{
if(!a)
return true;
return a == b;
});
}
template<class tuple>
struct ircd::db::query<tuple, ircd::db::where::logical_or>
:query<tuple>
{
const query<tuple> *a, *b;
bool operator()(const tuple &t) const override
{
return (*a)(t) || (*b)(t);
}
query(const query<tuple> &a, const query<tuple> &b)
:query<tuple>{where::logical_or}
,a{&a}
,b{&b}
{}
};
template<class tuple>
struct ircd::db::query<tuple, ircd::db::where::logical_and>
:query<tuple>
{
const query<tuple> *a, *b;
bool operator()(const tuple &t) const override
{
return (*a)(t) && (*b)(t);
}
query(const query<tuple> &a, const query<tuple> &b)
:query<tuple>{where::logical_and}
,a{&a}
,b{&b}
{}
};
template<class tuple>
struct ircd::db::query<tuple, ircd::db::where::logical_not>
:query<tuple>
{
const where *a;
bool operator()(const tuple &t) const override
{
return !(*a)(t);
}
query(const where &a)
:query<tuple>{where::logical_not}
,a{&a}
{}
};
namespace ircd::db
{
template<class T> typename db::query<T, where::logical_or> operator||(const query<T> &a, const query<T> &b)
{
return { a, b };
}
template<class T> typename db::query<T, where::logical_and> operator&&(const query<T> &a, const query<T> &b)
{
return { a, b };
}
template<class T> typename db::query<T, where::logical_not> operator!(const query<T> &a)
{
return { a };
}
}

View file

@ -1,214 +0,0 @@
/*
* Copyright (C) 2016 Charybdis Development Team
* Copyright (C) 2016 Jason Volk <jason@zemos.net>
*
* Permission to use, copy, modify, and/or distribute this software for any
* purpose with or without fee is hereby granted, provided that the above
* copyright notice and this permission notice is present in all copies.
*
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT,
* INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
* STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
* IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGE.
*
*/
#pragma once
#define HAVE_IRCD_DB_WHERE_H
namespace ircd::db
{
template<class tuple> struct where;
}
template<class tuple>
struct ircd::db::where
{
struct equal;
struct not_equal;
struct logical_not;
struct logical_and;
struct logical_or;
struct test;
struct noop;
virtual bool operator()(const tuple &) const = 0;
virtual ~where() noexcept = default;
};
namespace ircd::db
{
template<class T> typename where<T>::logical_or operator||(const where<T> &, const where<T> &);
template<class T> typename where<T>::logical_and operator&&(const where<T> &, const where<T> &);
template<class T> typename where<T>::logical_not operator!(const where<T> &);
}
template<class tuple>
struct ircd::db::where<tuple>::equal
:ircd::db::where<tuple>
{
tuple value;
bool operator()(const tuple &) const override;
equal(const tuple &value)
:value{value}
{}
equal(const json::members &members)
:value{members}
{}
};
template<class tuple>
bool
ircd::db::where<tuple>::equal::operator()(const tuple &value)
const
{
return json::until(this->value, value, []
(const auto &key, const auto &a, const auto &b)
{
if(!a)
return true;
return a == b;
});
}
template<class tuple>
struct ircd::db::where<tuple>::not_equal
:ircd::db::where<tuple>
{
tuple value;
bool operator()(const tuple &) const override;
not_equal(const tuple &value)
:value{value}
{}
not_equal(const json::members &members)
:value{members}
{}
};
template<class tuple>
bool
ircd::db::where<tuple>::not_equal::operator()(const tuple &value)
const
{
return !json::until(this->value, value, []
(const auto &key, const auto &a, const auto &b)
{
if(!a)
return true;
return a == b;
});
}
template<class tuple>
struct ircd::db::where<tuple>::logical_and
:ircd::db::where<tuple>
{
const where *a, *b;
bool operator()(const tuple &t) const override
{
return (*a)(t) && (*b)(t);
}
logical_and(const where &a, const where &b)
:a{&a}
,b{&b}
{}
};
template<class tuple>
typename ircd::db::where<tuple>::logical_and
ircd::db::operator&&(const where<tuple> &a, const where<tuple> &b)
{
return { a, b };
}
template<class tuple>
struct ircd::db::where<tuple>::logical_or
:ircd::db::where<tuple>
{
const where *a, *b;
bool operator()(const tuple &t) const override
{
return (*a)(t) || (*b)(t);
}
logical_or(const where &a, const where &b)
:a{&a}
,b{&b}
{}
};
template<class tuple>
typename ircd::db::where<tuple>::logical_or
ircd::db::operator||(const where<tuple> &a, const where<tuple> &b)
{
return { a, b };
}
template<class tuple>
struct ircd::db::where<tuple>::logical_not
:ircd::db::where<tuple>
{
const where *a;
bool operator()(const tuple &t) const override
{
return !(*a)(t);
}
logical_not(const where &a)
:a{&a}
{}
};
template<class tuple>
typename ircd::db::where<tuple>::logical_not
ircd::db::operator!(const where<tuple> &a)
{
return { a };
}
template<class tuple>
struct ircd::db::where<tuple>::test
:ircd::db::where<tuple>
{
using function = std::function<bool (const tuple &)>;
function closure;
bool operator()(const tuple &t) const override
{
return closure(t);
}
test(function closure)
:closure{std::move(closure)}
{}
};
template<class tuple>
struct ircd::db::where<tuple>::noop
:ircd::db::where<tuple>
{
bool operator()(const tuple &) const override
{
return true;
}
};

View file

@ -4018,3 +4018,20 @@ ircd::db::value_required(const op &op)
assert(0); assert(0);
return false; return false;
} }
ircd::string_view
ircd::db::reflect(const where &w)
{
switch(w)
{
case where::noop: return "noop";
case where::test: return "test";
case where::equal: return "equal";
case where::not_equal: return "not_equal";
case where::logical_or: return "logical_or";
case where::logical_and: return "logical_and";
case where::logical_not: return "logical_not";
}
return "?????";
}