Struct Transaction

pub struct Transaction<'a, T> { /* private fields */ }

Implementations

impl<'a, T> Transaction<'a, T>

pub fn commit(&self) -> Result<(), Error>

commits a transaction

pub fn rollback(&self) -> Result<(), Error>

Transaction rollback

pub fn rollback_to_savepoint(&self) -> Result<(), Error>

Transaction rollback to savepoint

pub fn set_savepoint(&self)

Set savepoint for transaction

pub fn snapshot(&'a self) -> TransactionSnapshot<'a, T>

Get Snapshot

pub fn get_for_update<K: AsRef<[u8]>>( &self, key: K, ) -> Result<Option<DBVector>, Error>

Get For Update ReadOptions: Default exclusive: true

pub fn get_for_update_opt<K: AsRef<[u8]>>( &self, key: K, readopts: &ReadOptions, exclusive: bool, ) -> Result<Option<DBVector>, Error>

Get For Update with custom ReadOptions and exclusive

pub fn get_for_update_cf<K: AsRef<[u8]>>( &self, cf: &ColumnFamily, key: K, ) -> Result<Option<DBVector>, Error>

pub fn get_for_update_cf_opt<K: AsRef<[u8]>>( &self, cf: &ColumnFamily, key: K, readopts: &ReadOptions, exclusive: bool, ) -> Result<Option<DBVector>, Error>

Trait Implementations

impl<'a, T> DeleteCF<()> for Transaction<'a, T>

fn delete_cf_full<K>( &self, cf: Option<&ColumnFamily>, key: K, _: Option<&()>, ) -> Result<(), Error>

where K: AsRef<[u8]>,

fn delete_cf<K>(&self, cf: &ColumnFamily, key: K) -> Result<(), Error>

where K: AsRef<[u8]>,

fn put_cf_opt<K>( &self, cf: &ColumnFamily, key: K, writeopts: &W, ) -> Result<(), Error>

where K: AsRef<[u8]>,

impl<'a, T> Drop for Transaction<'a, T>

fn drop(&mut self)

Executes the destructor for this type.

impl<'a, T> GetCF<ReadOptions> for Transaction<'a, T>

where Transaction<'a, T>: Handle<rocksdb_transaction_t> + Read,

fn get_cf_full<K: AsRef<[u8]>>( &self, cf: Option<&ColumnFamily>, key: K, readopts: Option<&ReadOptions>, ) -> Result<Option<DBVector>, Error>

fn get_cf<K: AsRef<[u8]>>( &self, cf: &ColumnFamily, key: K, ) -> Result<Option<DBVector>, Error>

fn get_cf_opt<K: AsRef<[u8]>>( &self, cf: &ColumnFamily, key: K, readopts: &R, ) -> Result<Option<DBVector>, Error>

impl<'a, T> GetPinnedCF<'a> for Transaction<'a, T>

type ColumnFamily = &'a ColumnFamily

type ReadOptions = &'a ReadOptions

fn get_pinned_cf_full<K: AsRef<[u8]>>( &'a self, cf: Option<Self::ColumnFamily>, key: K, readopts: Option<Self::ReadOptions>, ) -> Result<Option<DBPinnableSlice<'a>>, Error>

Return the value associated with a key using RocksDB’s PinnableSlice so as to avoid unnecessary memory copy.

fn get_pinned_cf<K: AsRef<[u8]>>( &'a self, cf: Self::ColumnFamily, key: K, ) -> Result<Option<DBPinnableSlice<'a>>, Error>

Return the value associated with a key using RocksDB’s PinnableSlice so as to avoid unnecessary memory copy.

fn get_pinned_cf_opt<K: AsRef<[u8]>>( &'a self, cf: Self::ColumnFamily, key: K, readopts: Self::ReadOptions, ) -> Result<Option<DBPinnableSlice<'a>>, Error>

Return the value associated with a key using RocksDB’s PinnableSlice so as to avoid unnecessary memory copy.

impl<'a, T> Handle<rocksdb_transaction_t> for Transaction<'a, T>

fn handle(&self) -> *mut rocksdb_transaction_t

impl<T> Iterate for Transaction<'_, T>

fn get_raw_iter<'a: 'b, 'b>( &'a self, readopts: &ReadOptions, ) -> DBRawIterator<'b>

fn get_iter<'a: 'b, 'b>( &'a self, readopts: &ReadOptions, mode: IteratorMode<'_>, ) -> DBIterator<'b>

fn iterator_opt<'a: 'b, 'b>( &'a self, mode: IteratorMode<'_>, readopts: &ReadOptions, ) -> DBIterator<'b>

fn iterator<'a: 'b, 'b>(&'a self, mode: IteratorMode<'_>) -> DBIterator<'b>

fn full_iterator<'a: 'b, 'b>(&'a self, mode: IteratorMode<'_>) -> DBIterator<'b>

Opens an interator with set_total_order_seek enabled. This must be used to iterate across prefixes when set_memtable_factory has been called with a Hash-based implementation.

fn prefix_iterator<'a: 'b, 'b>(&'a self, prefix: &[u8]) -> DBIterator<'b>

fn raw_iterator<'a: 'b, 'b>(&'a self) -> DBRawIterator<'b>

impl<T> IterateCF for Transaction<'_, T>

fn get_raw_iter_cf<'a: 'b, 'b>( &'a self, cf_handle: &ColumnFamily, readopts: &ReadOptions, ) -> Result<DBRawIterator<'b>, Error>

fn get_iter_cf<'a: 'b, 'b>( &'a self, cf_handle: &ColumnFamily, readopts: &ReadOptions, mode: IteratorMode<'_>, ) -> Result<DBIterator<'b>, Error>

fn iterator_cf_opt<'a: 'b, 'b>( &'a self, cf_handle: &ColumnFamily, mode: IteratorMode<'_>, readopts: &ReadOptions, ) -> Result<DBIterator<'b>, Error>

Opens an interator using the provided ReadOptions. This is used when you want to iterate over a specific ColumnFamily with a modified ReadOptions

fn iterator_cf<'a: 'b, 'b>( &'a self, cf_handle: &ColumnFamily, mode: IteratorMode<'_>, ) -> Result<DBIterator<'b>, Error>

fn full_iterator_cf<'a: 'b, 'b>( &'a self, cf_handle: &ColumnFamily, mode: IteratorMode<'_>, ) -> Result<DBIterator<'b>, Error>

fn prefix_iterator_cf<'a: 'b, 'b>( &'a self, cf_handle: &ColumnFamily, prefix: &[u8], ) -> Result<DBIterator<'b>, Error>

fn raw_iterator_cf<'a: 'b, 'b>( &'a self, cf_handle: &ColumnFamily, ) -> Result<DBRawIterator<'b>, Error>

impl<'a, T> MergeCF<()> for Transaction<'a, T>

fn merge_cf_full<K, V>( &self, cf: Option<&ColumnFamily>, key: K, value: V, _: Option<&()>, ) -> Result<(), Error>

where K: AsRef<[u8]>, V: AsRef<[u8]>,

fn merge_cf<K, V>( &self, cf: &ColumnFamily, key: K, value: V, ) -> Result<(), Error>

where K: AsRef<[u8]>, V: AsRef<[u8]>,

fn merge_cf_opt<K, V>( &self, cf: &ColumnFamily, key: K, value: V, writeopts: &W, ) -> Result<(), Error>

where K: AsRef<[u8]>, V: AsRef<[u8]>,

impl<'a, T> MultiGet<ReadOptions> for Transaction<'a, T>

where Transaction<'a, T>: Handle<rocksdb_transaction_t> + Read,

fn multi_get_full<K, I>( &self, keys: I, readopts: Option<&ReadOptions>, ) -> Vec<Result<Option<DBVector>, Error>>

where K: AsRef<[u8]>, I: IntoIterator<Item = K>,

fn multi_get<K, I>(&self, keys: I) -> Vec<Result<Option<DBVector>, Error>>

where K: AsRef<[u8]>, I: IntoIterator<Item = K>,

fn multi_get_opt<K, I>( &self, keys: I, readopts: &R, ) -> Vec<Result<Option<DBVector>, Error>>

where K: AsRef<[u8]>, I: IntoIterator<Item = K>,

impl<'a, T> MultiGetCF<ReadOptions> for Transaction<'a, T>

where Transaction<'a, T>: Handle<rocksdb_transaction_t> + Read,

fn multi_get_cf_full<'m, K, I>( &self, keys: I, readopts: Option<&ReadOptions>, ) -> Vec<Result<Option<DBVector>, Error>>

where K: AsRef<[u8]>, I: IntoIterator<Item = (&'m ColumnFamily, K)>,

fn multi_get_cf<'a, K, I>( &self, keys_cf: I, ) -> Vec<Result<Option<DBVector>, Error>>

where K: AsRef<[u8]>, I: IntoIterator<Item = (&'a ColumnFamily, K)>,

fn multi_get_cf_opt<'a, K, I>( &self, keys_cf: I, readopts: &R, ) -> Vec<Result<Option<DBVector>, Error>>

where K: AsRef<[u8]>, I: IntoIterator<Item = (&'a ColumnFamily, K)>,

impl<'a, T> PutCF<()> for Transaction<'a, T>

fn put_cf_full<K, V>( &self, cf: Option<&ColumnFamily>, key: K, value: V, _: Option<&()>, ) -> Result<(), Error>

where K: AsRef<[u8]>, V: AsRef<[u8]>,

fn put_cf<K, V>(&self, cf: &ColumnFamily, key: K, value: V) -> Result<(), Error>

where K: AsRef<[u8]>, V: AsRef<[u8]>,

fn put_cf_opt<K, V>( &self, cf: &ColumnFamily, key: K, value: V, writeopts: &W, ) -> Result<(), Error>

where K: AsRef<[u8]>, V: AsRef<[u8]>,

impl<'a, T> Read for Transaction<'a, T>