Struct mentat::conn::InProgress

pub struct InProgress<'a, 'c> { /* fields omitted */ }

Represents an in-progress, not yet committed, set of changes to the store. Call commit to commit your changes, or rollback to discard them. A transaction is held open until you do so. Your changes will be implicitly dropped along with this struct.

Methods

impl<'a, 'c> InProgress<'a, 'c>

pub fn builder(self) -> InProgressBuilder<'a, 'c>

pub fn use_caching(&mut self, yesno: bool)

Choose whether to use in-memory caches for running queries.

pub fn transact_builder(&mut self, builder: TermBuilder) -> Result<TxReport>

If you only have a reference to an InProgress, you can't use the easy builder. This exists so you can make your own.

pub fn transact_terms<I>(     &mut self,     terms: I,     tempid_set: InternSet<TempId> ) -> Result<TxReport> where     I: IntoIterator<Item = TermWithTempIds>,

pub fn transact_entities<I, V: TransactableValue>(     &mut self,     entities: I ) -> Result<TxReport> where     I: IntoIterator<Item = Entity<V>>,

pub fn transact<B>(&mut self, transaction: B) -> Result<TxReport> where     B: Borrow<str>,

pub fn import<P>(&mut self, path: P) -> Result<TxReport> where     P: AsRef<Path>,

pub fn rollback(self) -> Result<()>

pub fn commit(self) -> Result<()>

pub fn cache(     &mut self,     attribute: &Keyword,     cache_direction: CacheDirection,     cache_action: CacheAction ) -> Result<()>

Trait Implementations

impl<'a, 'c> Queryable for InProgress<'a, 'c>

fn q_once<T>(&self, query: &str, inputs: T) -> Result<QueryOutput> where     T: Into<Option<QueryInputs>>,

fn q_prepare<T>(&self, query: &str, inputs: T) -> PreparedResult where     T: Into<Option<QueryInputs>>,

fn q_explain<T>(&self, query: &str, inputs: T) -> Result<QueryExplanation> where     T: Into<Option<QueryInputs>>,

fn lookup_values_for_attribute<E>(     &self,     entity: E,     attribute: &Keyword ) -> Result<Vec<TypedValue>> where     E: Into<Entid>,

fn lookup_value_for_attribute<E>(     &self,     entity: E,     attribute: &Keyword ) -> Result<Option<TypedValue>> where     E: Into<Entid>,

impl<'a, 'c> Pullable for InProgress<'a, 'c>

fn pull_attributes_for_entities<E, A>(     &self,     entities: E,     attributes: A ) -> Result<BTreeMap<Entid, ValueRc<StructuredMap>>> where     E: IntoIterator<Item = Entid>,     A: IntoIterator<Item = Entid>,

fn pull_attributes_for_entity<A>(     &self,     entity: Entid,     attributes: A ) -> Result<StructuredMap> where     A: IntoIterator<Item = Entid>,

impl<'a, 'c> HasSchema for InProgress<'a, 'c>

fn entid_for_type(&self, t: ValueType) -> Option<KnownEntid>

fn get_ident<T>(&self, x: T) -> Option<&Keyword> where     T: Into<Entid>,

fn get_entid(&self, x: &Keyword) -> Option<KnownEntid>

fn attribute_for_entid<T>(&self, x: T) -> Option<&Attribute> where     T: Into<Entid>,

fn attribute_for_ident(     &self,     ident: &Keyword ) -> Option<(&Attribute, KnownEntid)>

fn is_attribute<T>(&self, x: T) -> bool where     T: Into<Entid>,

Return true if the provided entid identifies an attribute in this schema.

fn identifies_attribute(&self, x: &Keyword) -> bool

Return true if the provided ident identifies an attribute in this schema.

Important traits for &'a [u8]

impl<'a> Read for &'a [u8]impl<'a> Write for &'a mut [u8]

fn component_attributes(&self) -> &[Entid]

impl<'a, 'c> VersionedStore for InProgress<'a, 'c>

fn ensure_vocabulary(     &mut self,     definition: &Definition ) -> Result<VocabularyOutcome>

Check whether the provided vocabulary is present in the store. If it isn't, make it so.

fn ensure_vocabularies(     &mut self,     vocabularies: &mut VocabularySource ) -> Result<BTreeMap<Keyword, VocabularyOutcome>>

Check whether the provided vocabularies are present in the store at the correct version and with all defined attributes. If any are not, invoke the pre function on the provided VocabularySource, install or upgrade the necessary vocabularies, then invoke post. Returns Ok if all of these steps succeed.

fn check_vocabulary<'definition>(     &self,     definition: &'definition Definition ) -> Result<VocabularyCheck<'definition>>

Check whether the vocabulary described by the provided metadata is present in the store.

fn verify_core_schema(&self) -> Result<()>

Make sure that our expectations of the core vocabulary — basic types and attributes — are met.