Skip to main content

​
BaseGraphStorage

class BaseGraphStorage(ABC):
An abstract base class for graph storage systems.

​
get_client

def get_client(self):
Get the underlying graph storage client.

​
get_schema

def get_schema(self):
Get the schema of the graph storage

​
get_structured_schema

def get_structured_schema(self):
Get the structured schema of the graph storage

​
refresh_schema

def refresh_schema(self):
Refreshes the graph schema information.

​
add_triplet

def add_triplet(
    self,
    subj: str,
    obj: str,
    rel: str
):
Adds a relationship (triplet) between two entities in the database. Parameters:
  • subj (str): The identifier for the subject entity.
  • obj (str): The identifier for the object entity.
  • rel (str): The relationship between the subject and object.

​
delete_triplet

def delete_triplet(
    self,
    subj: str,
    obj: str,
    rel: str
):
Deletes a specific triplet from the graph, comprising a subject, object and relationship. Parameters:
  • subj (str): The identifier for the subject entity.
  • obj (str): The identifier for the object entity.
  • rel (str): The relationship between the subject and object.

​
query

def query(self, query: str, params: Optional[Dict[str, Any]] = None):
Query the graph store with statement and parameters. Parameters:
  • query (str): The query to be executed.
  • params (Optional[Dict[str, Any]]): A dictionary of parameters to be used in the query. Defaults to None.
Returns: List[Dict[str, Any]]: A list of dictionaries, each dictionary represents a row of results from the query.