ISAR/libmdbx
3
0
Fork 0
mirror of https://github.com/isar/libmdbx.git synced 2025-01-30 22:47:16 +08:00
Code Issues Packages Projects Releases Wiki Activity

mdbx++: add cursor::bind() and cursor_managed' constructor.

Browse Source 
Change-Id: I78eb5dbe494a0ca6c480c5854096c0849e9c4b07
This commit is contained in:
Leonid Yuriev 2020-09-15 02:32:04 +03:00
parent 10b170c6cd
commit fd57088906
1 changed files with 26 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
mdbx.h++
View File

@ -2273,7 +2273,8 @@ public:
/// \brief Start nested write transaction.
txn_managed start_nested();
inline cursor_managed create_cursor(map_handle map);
/// \brief Opens cursor for specified key-value map handle.
inline cursor_managed open_cursor(map_handle map);
/// \brief Open existing key-value map.
inline map_handle open_map(
@ -2604,8 +2605,15 @@ public:
//----------------------------------------------------------------------------
/// \brief Renew/bind a cursor with a new transaction and previously used
/// key-value map handle.
inline void renew(::mdbx::txn &txn);
/// Return the cursor's transaction.
/// \brief Bind/renew a cursor with a new transaction and specified key-value
/// map handle.
inline void bind(::mdbx::txn &txn, ::mdbx::map_handle map_handle);
/// \brief Return the cursor's transaction.
inline ::mdbx::txn txn() const;
inline map_handle map() const;
@ -2645,9 +2653,10 @@ class LIBMDBX_API_TYPE cursor_managed : public cursor {
: inherited(ptr) {}
public:
MDBX_CXX11_CONSTEXPR cursor_managed() noexcept = default;
/// \brief Creates a new managed cursor with underlying object.
inline cursor_managed();
/// Explicitly closes the cursor.
/// \brief Explicitly closes the cursor.
void close();
cursor_managed(cursor_managed &&) = default;
@ -3620,7 +3629,7 @@ inline txn::info txn::get_info(bool scan_reader_lock_table) const {
return r;
}
inline cursor_managed txn::create_cursor(map_handle map) {
inline cursor_managed txn::open_cursor(map_handle map) {
MDBX_cursor *ptr;
error::success_or_throw(::mdbx_cursor_open(handle_, map.dbi, &ptr));
return cursor_managed(ptr);
@ -4267,6 +4276,10 @@ inline void cursor::renew(::mdbx::txn &txn) {
error::success_or_throw(::mdbx_cursor_renew(txn, handle_));
}
inline void cursor::bind(::mdbx::txn &txn, ::mdbx::map_handle map_handle) {
error::success_or_throw(::mdbx_cursor_bind(txn, handle_, map_handle.dbi));
}
inline txn cursor::txn() const {
MDBX_txn *txn = ::mdbx_cursor_txn(handle_);
error::throw_on_nullptr(txn, MDBX_EINVAL);
@ -4396,6 +4409,14 @@ inline bool cursor::erase(bool whole_multivalue) {
//------------------------------------------------------------------------------
inline cursor_managed::cursor_managed()
: cursor_managed(::mdbx_cursor_create()) {
if (MDBX_UNLIKELY(!handle_))
MDBX_CXX20_UNLIKELY error::throw_exception(MDBX_ENOMEM);
}
//------------------------------------------------------------------------------
template <class ALLOCATOR>
inline buffer<ALLOCATOR>::buffer(const txn &txn, const ::mdbx::slice &src,
const ALLOCATOR &allocator)