save

Author: tobixdev

Cargo.lock

@@ -4,7 +4,7 @@ use anyhow::{bail, Context};
 use clap::Parser;
 use graphfusion::io::{RdfFormat, RdfParser, RdfSerializer};
 use graphfusion::model::{GraphName, NamedNode};
-use graphfusion::store::Store;
+use graphfusion_engine::store::Store;
 use graphfusion_web::ServerConfig;
 use std::ffi::OsStr;
 use std::fs::File;

cli/src/main.rs

@@ -0,0 +1,3 @@
+pub struct GraphFusionEngine {
+
+}

lib/graphfusion-engine/engine.rs

@@ -3,8 +3,10 @@ extern crate core;
 pub mod error;
 pub mod results;
 pub mod sparql;
-mod triple_store;
+mod quad_storage;
+mod planner;
 
-pub use triple_store::QuadStorage;
+pub use quad_storage::QuadStorage;
+pub use planner::GraphFusionPlanner;
 
 type DFResult<T> = datafusion::error::Result<T>;

lib/graphfusion-engine/src/lib.rs

@@ -5,6 +5,7 @@ use datafusion::execution::SessionState;
 use datafusion::logical_expr::LogicalPlan;
 use datafusion::physical_plan::ExecutionPlan;
 use datafusion::physical_planner::{DefaultPhysicalPlanner, PhysicalPlanner};
+use graphfusion_physical::paths::KleenePlusPathPlanner;
 use std::sync::Arc;
 
 #[derive(Debug, Default)]

lib/graphfusion-physical/src/planner.rs renamed to lib/graphfusion-engine/src/planner.rs

@@ -0,0 +1,23 @@
+use std::sync::Arc;
+use async_trait::async_trait;
+use datafusion::common::DataFusionError;
+use datafusion::datasource::TableProvider;
+use model::{Quad, QuadRef};
+
+#[async_trait]
+#[allow(clippy::len_without_is_empty)]
+pub trait QuadStorage {
+    /// Returns the table name of this [QuadStorage]. This name is used to register a table in the
+    /// DataFusion engine.
+    async fn table_name(&self) -> &str;
+
+    /// Returns the [TableProvider] for this [QuadStorage]. This provider is registered in the
+    /// DataFusion session and used for planning the execution of queries.
+    async fn table_provider(&self) -> Arc<dyn TableProvider>;
+
+    /// Loads the given quads into the storage.
+    async fn load_quads(&self, quads: Vec<Quad>) -> Result<usize, DataFusionError>;
+
+    /// Removes the given quad from the storage.
+    async fn remove<'a>(&self, quad: QuadRef<'_>) -> Result<bool, DataFusionError>;
+}

lib/graphfusion-engine/src/quad_storage.rs

@@ -1,6 +1,6 @@
 //! [SPARQL](https://www.w3.org/TR/sparql11-overview/) implementation.
 //!
-//! Stores execute SPARQL. See [`Store`](crate::store::Store::query()) for an example.
+//! Stores execute SPARQL. See [`Store`](graphfusion::store::Store::query()) for an example.
 
 mod algebra;
 pub mod error;

lib/graphfusion-engine/src/sparql/mod.rs

@@ -1,8 +1,5 @@
 extern crate core;
 
 pub mod paths;
-mod planner;
-
-pub use planner::*;
 
 type DFResult<T> = datafusion::error::Result<T>;

lib/graphfusion-engine/src/triple_store.rs

@@ -2,4 +2,4 @@ mod physical;
 mod planner;
 
 pub use physical::KleenePlusClosureExec;
-pub(crate) use planner::KleenePlusPathPlanner;
+pub use planner::KleenePlusPathPlanner;