pub struct Graph { /* private fields */ }
Expand description
A neo4j database abstraction. This type can be cloned and shared across threads, internal resources are reference-counted.
Implementations§
source§impl Graph
impl Graph
sourcepub async fn connect(config: Config) -> Result<Self>
pub async fn connect(config: Config) -> Result<Self>
Connects to the database with configurations provided.
You can build a config using ConfigBuilder::default()
.
sourcepub async fn new(
uri: impl Into<String>,
user: impl Into<String>,
password: impl Into<String>
) -> Result<Self>
pub async fn new( uri: impl Into<String>, user: impl Into<String>, password: impl Into<String> ) -> Result<Self>
Connects to the database with default configurations
sourcepub async fn start_txn(&self) -> Result<Txn>
pub async fn start_txn(&self) -> Result<Txn>
Starts a new transaction on the configured database.
All queries that needs to be run/executed within the transaction
should be executed using either Txn::run
or Txn::execute
sourcepub async fn start_txn_on(&self, db: impl Into<Database>) -> Result<Txn>
pub async fn start_txn_on(&self, db: impl Into<Database>) -> Result<Txn>
Starts a new transaction on the provided database.
All queries that needs to be run/executed within the transaction
should be executed using either Txn::run
or Txn::execute
sourcepub async fn run(&self, q: Query) -> Result<()>
pub async fn run(&self, q: Query) -> Result<()>
Runs a query on the configured database using a connection from the connection pool,
It doesn’t return any [RowStream
] as the run
abstraction discards any stream.
Use Graph::run
for cases where you just want a write operation
use Graph::execute
when you are interested in the result stream
sourcepub async fn run_on(&self, db: &str, q: Query) -> Result<()>
pub async fn run_on(&self, db: &str, q: Query) -> Result<()>
Runs a query on the provided database using a connection from the connection pool.
It doesn’t return any [RowStream
] as the run
abstraction discards any stream.
Use Graph::run
for cases where you just want a write operation
use Graph::execute
when you are interested in the result stream
sourcepub async fn execute(&self, q: Query) -> Result<DetachedRowStream>
pub async fn execute(&self, q: Query) -> Result<DetachedRowStream>
Executes a query on the configured database and returns a [DetachedRowStream
]
sourcepub async fn execute_on(&self, db: &str, q: Query) -> Result<DetachedRowStream>
pub async fn execute_on(&self, db: &str, q: Query) -> Result<DetachedRowStream>
Executes a query on the provided database and returns a [DetaRowStream
]