A Rust Client for OrientDB. Supports sync and async (tokio and async-std)
Install from crates.io
[dependencies]
orientdb-client = "*"async-std-runtime: use the async APIs withasync-std.tokio-runtime: use the async APIs withtokio.uuid: Add support for UUID.sugar: Add ergonimic APIs for querying and binding results to structs
use orientdb_client::{OrientDB};
fn main() -> Result<(), Box<std::error::Error>> {
let client = OrientDB::connect(("localhost",2424))?;
let session = client.session("demodb","admin","admin")?;
let results : Vec<_> = session.query("select from V where id = :param").named(&[("param", &1)]).run()?.collect();
println!("{:?}", results);
Ok(())
}For async-std
activate the feature async-std-runtime
orientdb-client = { version = "*", features = ["async-std-runtime"] }
use async_std::task::block_on;
use futures::StreamExt;
use orientdb_client::aio::OrientDB;
use orientdb_client::OrientResult;
fn main() -> OrientResult<()> {
block_on(async {
let client = OrientDB::connect(("localhost", 2424)).await?;
let session = client.session("demodb", "admin", "admin").await?;
let mut stream = session.query("select from V limit 10").run().await?;
while let Some(item) = stream.next().await {
println!("Record {:?}", item?);
}
Ok(())
})
}For tokio
activate the feature tokio-runtime
orientdb-client = { version = "*", features = ["tokio-runtime"] }
use futures::StreamExt;
use orientdb_client::aio::OrientDB;
use orientdb_client::OrientResult;
#[tokio::main]
async fn main() -> OrientResult<()> {
let client = OrientDB::connect(("localhost", 2424)).await?;
let session = client.session("demodb", "admin", "admin").await?;
let mut stream = session.query("select from V limit 10").run().await?;
while let Some(item) = stream.next().await {
println!("Record {:?}", item?);
}
Ok(())
}The sugar feature add 3 methods to the query builder for spawning the query.
fetch_onefetchstreamfor async oriterfor sync
They should be used instead of run APIs when you want to execute the query and map the OResult into a struct.
The sugar is supported in sync and async mode.
fetch_one
Consume the stream and fetch the first result if any.
use orientdb_client::derive::FromResult;
#[derive(FromResult, Debug)]
struct User {
name: String,
}
// fetch one
let user: Option<User> = session
.query("select from OUser limit 1")
.fetch_one()
.await?;
println!("User {:?}", user);`fetch
Collect the stream to a Vec and map to struct.
use orientdb_client::derive::FromResult;
#[derive(FromResult, Debug)]
struct User {
name: String,
}
// fetch
let user: Vec<User> = session
.query("select from OUser limit 1")
.fetch()
.await?;
println!("Users {:?}", user);`stream
Map each item of the stream to a struct.
use orientdb_client::derive::FromResult;
#[derive(FromResult, Debug)]
struct User {
name: String,
}
// fetch stream and collect
let stream = session
.query("select from OUser")
.stream::<User>()
.await?
.collect::<Vec<_>>()
.await;
println!("Users {:?}", user);git clone https://github.com/wolf4ood/orientdb-rs.git
cd orientdb-rs
cargo build
You can use docker-compose to start an instance for testing. Use the env variable ORIENTDB_SERVER
in order to specify the version of OrientDB
cd docker-compose
export ORIENTDB_SERVER=3.0.23
docker-compose up -d
cd ..
cargo test
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent