jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

cursor put (#54)

Browse Source
This commit is contained in:
Roman Krasiuk
2022-10-12 18:16:59 +03:00
committed by GitHub
parent 111c13f12f
commit 08d8a7f030
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
crates/db/src/kv/cursor.rs
View File

@ -5,7 +5,7 @@ use crate::{
kv::{Decode, DupSort, Encode, Table}, kv::{Decode, DupSort, Encode, Table},
utils::*, utils::*,
}; };
use libmdbx::{self, TransactionKind}; use libmdbx::{self, TransactionKind, WriteFlags, RW};
/// Alias type for a `(key, value)` result coming from a cursor. /// Alias type for a `(key, value)` result coming from a cursor.
pub type PairResult<T> = Result<Option<(<T as Table>::Key, <T as Table>::Value)>, KVError>; pub type PairResult<T> = Result<Option<(<T as Table>::Key, <T as Table>::Value)>, KVError>;
@ -108,6 +108,15 @@ impl<'tx, K: TransactionKind, T: Table> Cursor<'tx, K, T> {
} }
} }
impl<'tx, T: Table> Cursor<'tx, RW, T> {
/// Inserts a `(key, value)` to the database. Repositions the cursor to the new item
pub fn put(&mut self, k: T::Key, v: T::Value, f: Option<WriteFlags>) -> Result<(), KVError> {
self.inner
.put(k.encode().as_ref(), v.encode().as_ref(), f.unwrap_or_default())
.map_err(KVError::Put)
}
}
impl<'txn, K, T> Cursor<'txn, K, T> impl<'txn, K, T> Cursor<'txn, K, T>
where where
K: TransactionKind, K: TransactionKind,