var client = new DgraphClient(new Channel("127.0.0.1:9080", ChannelCredentials.Insecure));
Multi-tenancyIn multi-tenancy environments, Dgraph provides a new method LoginRequest()
, which will allow the users to login to a specific namespace. In order to create a Dgraph client, and make the client login into namespace 123
:
var lr = new Api.LoginRequest() {
UserId = "userId",
Password = "password",
Namespace = 123
}
client.Login(lr)
In the example above, the client logs into namespace 123
using username userId
and password password
. Once logged in, the client can perform all the operations allowed to the userId
user of namespace 123
. Altering the DatabaseTo set the schema, pass the schema into the DgraphClient.Alter
function, as seen below:
var schema = "name: string @index(exact) .";
var result = client.Alter(new Operation{ Schema = schema });
The returned result object is based on the FluentResults library. You can check the status using result.isSuccess
or result.isFailed
. More information on the result object can be found here. Creating a TransactionTo create a transaction, call DgraphClient.NewTransaction
method, which returns a new Transaction
object. This operation incurs no network overhead. It is good practice to call to wrap the Transaction
in a using
block, so that the Transaction.Dispose
function is called after running the transaction.
using(var transaction = client.NewTransaction()) {
...
}
You can also create Read-Only transactions. Read-Only transactions only allow querying, and can be created using DgraphClient.NewReadOnlyTransaction
. Running a MutationTransaction.Mutate(RequestBuilder)
runs a mutation. It takes in a json mutation string. We define a person object to represent a person and serialize it to a json mutation string. In this example, we are using the JSON.NET library, but you can use any JSON serialization library you prefer.
using(var txn = client.NewTransaction()) {
var alice = new Person{ Name = "Alice" };
var json = JsonConvert.SerializeObject(alice);
var transactionResult = await txn.Mutate(new RequestBuilder().WithMutations(new MutationBuilder{ SetJson = json }));
}
You can also set mutations using RDF format, if you so prefer, as seen below:
var mutation = "_:alice <name> \"Alice\" .";
var transactionResult = await txn.Mutate(new RequestBuilder().WithMutations(new MutationBuilder{ SetNquads = mutation }));
Check out the example in source/Dgraph.tests.e2e/TransactionTest.cs
. Running a QueryYou can run a query by calling Transaction.Query(string)
. You will need to pass in a DQL query string. If you want to pass an additional map of any variables that you might want to set in the query, call Transaction.QueryWithVars(string, Dictionary<string,string>)
with the variables dictionary as the second argument. The response would contain the response string. Let’s run the following query with a variable $a
:
query all($a: string) {
all(func: eq(name, $a))
{
name
}
}
Run the query, deserialize the result from Uint8Array (or base64) encoded JSON and print it out:
// Run query.
var query = @"query all($a: string) {
all(func: eq(name, $a))
{
name
}
}";
var vars = new Dictionary<string,string> { { $a: "Alice" } };
var res = await dgraphClient.NewReadOnlyTransaction().QueryWithVars(query, vars);
// Print results.
Console.Write(res.Value.Json);
Running an Upsert: Query + MutationThe Transaction.Mutate
function allows you to run upserts consisting of one query and one mutation.
var query = @"
query {
user as var(func: eq(email, \"wrong_email@dgraph.io\"))
}";
var mutation = new MutationBuilder{ SetNquads = "uid(user) <email> \"correct_email@dgraph.io\" ." };
var request = new RequestBuilder{ Query = query, CommitNow = true }.withMutation(mutation);
// Upsert: If wrong_email found, update the existing data
// or else perform a new mutation.
await txn.Mutate(request);
Committing a TransactionA transaction can be committed using the Transaction.Commit
method. If your transaction consisted solely of calls to Transaction.Query
or Transaction.QueryWithVars
, and no calls to Transaction.Mutate
, then calling Transaction.Commit
is not necessary. An error will be returned if other transactions running concurrently modify the same data that was modified in this transaction. It is up to the user to retry transactions when they fail.
using(var txn = client.NewTransaction()) {
var result = txn.Commit();
}
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4