MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-11-29 18:22:50 +01:00
Code Issues Releases Wiki Activity

ircd::db: Support different db::op types in txn::append(tuple).

Browse source
This commit is contained in:
Jason Volk 2018-03-24 21:36:19 -07:00
parent f60aad8753
commit d3c5845ee4
1 changed files with 23 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
include/ircd/db/txn.h
View file

@ -76,8 +76,8 @@ struct ircd::db::txn::append
append(txn &, const row::delta &); append(txn &, const row::delta &);
append(txn &, const delta &); append(txn &, const delta &);
append(txn &, const string_view &key, const json::iov &); append(txn &, const string_view &key, const json::iov &);
template<class... T> append(txn &, const string_view &key, const json::tuple<T...> &); template<class... T> append(txn &, const string_view &key, const json::tuple<T...> &, const op & = op::SET);
template<class... T> append(txn &, const string_view &key, const json::tuple<T...> &, std::array<column, sizeof...(T)> &); template<class... T> append(txn &, const string_view &key, const json::tuple<T...> &, std::array<column, sizeof...(T)> &, const op & = op::SET);
}; };
struct ircd::db::txn::checkpoint struct ircd::db::txn::checkpoint
@ -97,15 +97,22 @@ struct ircd::db::txn::opts
template<class... T> template<class... T>
ircd::db::txn::append::append(txn &txn, ircd::db::txn::append::append(txn &txn,
const string_view &key, const string_view &key,
const json::tuple<T...> &tuple) const json::tuple<T...> &tuple,
const op &op)
{ {
for_each(tuple, [&txn, &key](const auto &col, auto&& val) for_each(tuple, [&txn, &key, &op]
(const auto &col, auto&& val)
{ {
if(defined(val)) append if(!value_required(op) || defined(val)) append
{ {
txn, delta txn, delta
{ {
col, key, byte_view<string_view>{val} op,
col,
key,
value_required(op)?
byte_view<string_view>{val}:
byte_view<string_view>{}
} }
}; };
}); });
@ -115,16 +122,22 @@ template<class... T>
ircd::db::txn::append::append(txn &txn, ircd::db::txn::append::append(txn &txn,
const string_view &key, const string_view &key,
const json::tuple<T...> &tuple, const json::tuple<T...> &tuple,
std::array<column, sizeof...(T)> &col) std::array<column, sizeof...(T)> &col,
const op &op)
{ {
size_t i{0}; size_t i{0};
for_each(tuple, [&txn, &key, &col, &i](const auto &, auto&& val) for_each(tuple, [&txn, &key, &col, &op, &i]
(const auto &, auto&& val)
{ {
if(defined(val)) append if(!value_required(op) || defined(val)) append
{ {
txn, col.at(i), column::delta txn, col.at(i), column::delta
{ {
key, byte_view<string_view>{val} op,
key,
value_required(op)?
byte_view<string_view>{val}:
byte_view<string_view>{}
} }
}; };