Rust客户端用于dgraph

Dgraph Rust客户端，使用gRPC与服务器通信。

在使用此客户端之前，强烈建议您通过tour.dgraph.io和docs.dgraph.io了解如何运行和与Dgraph一起工作。

目录

• 安装
• 使用客户端
  • 创建客户端
  • 更改数据库
  • 创建事务
  • 运行突变
  • 运行查询
  • 提交事务
• Интеграция тестирования
• Присоединение к проекту

Предварительные условия

dgraph поддерживает только версии Dgraph 1.1 или выше.

Поскольку этот crate использует grpcio, который является оберткой вокруг библиотеки C++ и требует некоторых предварительных условий перед установкой. Вы можете найти их в grpcio documentation.

安装

dgraph доступен на crates.io. Добавьте следующую зависимость в ваш Cargo.toml.

[dependencies]
dgraph = "0.4.0"

Доступны также несколько функций passthrough grpcio

• openssl
• openssl-vendored

Эти функции описаны в grpcio documentation.

使用客户端

创建客户端

Объект Dgraph можно инициализировать, передав в него список клиентов dgraph::DgraphClient в вектор. Подключение к нескольким серверам Dgraph в одной и той же кластере позволяет лучше распределять нагрузку. Библиотека предоставляет макрос для этого.

Следующий фрагмент кода показывает только одно подключение.

let dgraph = make_dgraph!(dgraph::new_dgraph_client("localhost:9080"));

Альтернативно, можно использовать безопасного клиента

fn open_cert_file(path: &str) -> Vec<u8> {
  ...
}

let root_ca = open_cert_file("./tls/ca.crt");
let cert = open_cert_file("./tls/client.user.crt");
let private_key = open_cert_file("./tls/client.user.key");

let dgraph = make_dgraph!(dgraph::new_secure_dgraph_client(
    "localhost:9080",
    root_ca,
    cert,
    private_key
));

更改数据库

Чтобы установить схему, создайте экземпляр dgraph::Operation и используйте точку końca Alter.

let op = dgraph::Operation{
  schema: "name: string @index(exact) .".to_string(), ..Default::default()
};
let result = dgraph.alter(&op);
// Check error

操作 包含其他字段，包括 DropAttr 和 DropAll。当您希望丢弃所有数据，从头开始而不需要关闭实例时，DropAll 非常有用。DropAttr 用于删除与谓词相关联的所有数据。

创建事务

要创建一个事务，调用 dgraph.new_txn()，它返回一个 dgraph::Txn 对象。此操作不产生网络开销。

一旦 dgraph::Txn 超出作用域，将通过 Drop 特性自动调用 txn.discard()。在 txn.commit() 之后调用 txn.discard() 是无操作的，多次调用此方法也没有额外的副作用。

let txn = dgraph.new_txn();

#[derive(Serialize, Deserialize, Default, Debug)]
struct Person {
  uid: String,
  name: String,
}

let p = Person {
  uid:  "_:alice".to_string(),
  Name: "Alice".to_string(),
}

let pb = serde_json::to_vec(&p).expect("Invalid json");

let mut mu = dgraph::Mutation {
  json: pb, ..Default::default()
};

let assigned = txn.mutate(mu).expect("failed to create data");

let q = r#"query all($a: string) {
    all(func: eq(name, $a)) {
      name
    }
  }"#;

let mut vars = HashMap::new();
vars.insert("$a".to_string(), "Alice".to_string());

let resp = dgraph.new_readonly_txn().query_with_vars(&q, vars).expect("query");
let root: Root = serde_json::from_slice(&resp.json).expect("parsing");
println!("Root: {:#?}", root);

let q = r#"schema(pred: [name]) {
  type
  index
  reverse
  tokenizer
  list
  count
  upsert
  lang
}"#;

let resp = txn.query(&q)?;
println!("{:#?}", resp.schema);

let txn = dgraph.new_txn();
// Perform some queries and mutations.

let res = txn.commit();
if res.is_err() {
  // Retry or handle error
}

docker-compose -f docker-compose-*.yaml up -d

cargo test -- --test-threads=1

cargo run --features="compile-protobufs" --bin protoc