connection

Connection Objects

class Connection(ABC)

execute

@abstractmethod
def execute(query: str, parameters: Dict[str, Any] = {}) -> None

Executes Cypher query without returning any results.

execute_and_fetch

@abstractmethod
def execute_and_fetch(
        query: str,
        parameters: Dict[str, Any] = {}) -> Iterator[Dict[str, Any]]

Executes Cypher query and returns iterator of results.

is_active

@abstractmethod
def is_active() -> bool

Returns True if connection is active and can be used.

MemgraphConnection Objects

class MemgraphConnection(Connection)

execute

@database_error_handler
def execute(query: str, parameters: Dict[str, Any] = {}) -> None

Executes Cypher query without returning any results.

execute_and_fetch

@database_error_handler
def execute_and_fetch(
        query: str,
        parameters: Dict[str, Any] = {}) -> Iterator[Dict[str, Any]]

Executes Cypher query and returns iterator of results.

is_active

def is_active() -> bool

Returns True if connection is active and can be used.

Neo4jConnection Objects

class Neo4jConnection(Connection)

execute

def execute(query: str, parameters: Dict[str, Any] = {}) -> None

Executes Cypher query without returning any results.

execute_and_fetch

def execute_and_fetch(
        query: str,
        parameters: Dict[str, Any] = {}) -> Iterator[Dict[str, Any]]

Executes Cypher query and returns iterator of results.

is_active

def is_active() -> bool

Returns True if connection is active and can be used.