Struct ckb_rocksdb::Transaction

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

Methods

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> Handle<rocksdb_transaction_t> for Transaction<'a, T>

fn handle(&self) -> *mut rocksdb_transaction_t

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

fn get_raw_iter(&self, readopts: &ReadOptions) -> DBRawIterator

Important traits for DBIterator<'a>

impl<'a> Iterator for DBIterator<'a> type Item = (Box<[u8]>, Box<[u8]>);

fn get_iter(&self, readopts: &ReadOptions, mode: IteratorMode) -> DBIterator

Important traits for DBIterator<'a>

impl<'a> Iterator for DBIterator<'a> type Item = (Box<[u8]>, Box<[u8]>);

fn iterator_opt(&self, mode: IteratorMode, readopts: &ReadOptions) -> DBIterator

Important traits for DBIterator<'a>

impl<'a> Iterator for DBIterator<'a> type Item = (Box<[u8]>, Box<[u8]>);

fn iterator(&self, mode: IteratorMode) -> DBIterator

Important traits for DBIterator<'a>

impl<'a> Iterator for DBIterator<'a> type Item = (Box<[u8]>, Box<[u8]>);

fn full_iterator(&self, mode: IteratorMode) -> DBIterator

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.

Important traits for DBIterator<'a>

impl<'a> Iterator for DBIterator<'a> type Item = (Box<[u8]>, Box<[u8]>);

fn prefix_iterator(&self, prefix: &[u8]) -> DBIterator

fn raw_iterator(&self) -> DBRawIterator

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

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

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

fn iterator_cf_opt(
    &self,
    cf_handle: &ColumnFamily,
    mode: IteratorMode,
    readopts: &ReadOptions
) -> Result<DBIterator, 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(
    &self,
    cf_handle: &ColumnFamily,
    mode: IteratorMode
) -> Result<DBIterator, Error>

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

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

fn raw_iterator_cf(
    &self,
    cf_handle: &ColumnFamily
) -> Result<DBRawIterator, 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> 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>