Struct rdfox_rs::data_store_connection::DataStoreConnection

pub struct DataStoreConnection {
    pub data_store: Arc<DataStore>,
    pub server_connection: Arc<ServerConnection>,
    pub(crate) inner: *mut CDataStoreConnection,
    started_at: Instant,
    pub number: usize,
}

A connection to a given DataStore.

Fields

data_store: Arc<DataStore>

server_connection: Arc<ServerConnection>

inner: *mut CDataStoreConnection

started_at: Instant

number: usize

Implementations

impl DataStoreConnection

pub(crate) fn new( server_connection: &Arc<ServerConnection>, data_store: &Arc<DataStore>, inner: *mut CDataStoreConnection ) -> Self

pub fn same(self: &Arc<Self>, other: &Arc<Self>) -> bool

fn get_number() -> usize

pub fn get_id(&self) -> Result<String, RDFStoreError>

pub fn get_unique_id(&self) -> Result<String, RDFStoreError>

pub fn import_data_from_file<P>( &self, file: P, graph: &Graph ) -> Result<(), RDFStoreError>where P: AsRef<Path>,

Import RDF data from the given file into the given graph.

NOTE: Only supports turtle files at the moment.

pub fn import_axioms_from_triples( &self, source_graph: &Graph, target_graph: &Graph ) -> Result<(), RDFStoreError>

pub fn import_rdf_from_directory( &self, root: &Path, graph: &Graph ) -> Result<u16, RDFStoreError>

Read all RDF files (currently it supports .ttl and .nt files) from the given directory, applying ignore files like .gitignore.

Returns the number of loaded files.

TODO: Support all the types that RDFox supports (and more) TODO: Support ‘*.gz’ files TODO: Parallelize appropriately in sync with number of threads that RDFox uses

pub fn evaluate_update( &self, statement: &Statement, parameters: &Parameters ) -> Result<CStatementResult, RDFStoreError>

pub fn evaluate_to_stream<'a, W>( self: &Arc<Self>, writer: W, statement: &'a Statement, mime_type: &'static Mime, base_iri: Option<Iri<'_>> ) -> Result<Streamer<'a, W>, RDFStoreError>where W: 'a + Write,

pub fn get_triples_count( self: &Arc<Self>, tx: &Arc<Transaction>, fact_domain: FactDomain ) -> Result<usize, RDFStoreError>

pub fn get_subjects_count( self: &Arc<Self>, tx: &Arc<Transaction>, fact_domain: FactDomain ) -> Result<usize, RDFStoreError>

pub fn get_predicates_count( self: &Arc<Self>, tx: &Arc<Transaction>, fact_domain: FactDomain ) -> Result<usize, RDFStoreError>

pub fn get_ontologies_count( self: &Arc<Self>, tx: &Arc<Transaction>, fact_domain: FactDomain ) -> Result<usize, RDFStoreError>

Trait Implementations

impl Debug for DataStoreConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for DataStoreConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for DataStoreConnection

fn drop(&mut self)

Executes the destructor for this type.

impl Send for DataStoreConnection

impl Sync for DataStoreConnection