Function TestConditionalUpsertExample0JSON

dgraph/cmd/alpha/upsert_test.go:989–1052

(t *testing.T)

}

func TestConditionalUpsertExample0JSON(t *testing.T) {
	require.NoError(t, dropAll())
	require.NoError(t, alterSchema(`email: string @index(exact) .`))

	// Mutation with wrong name
	m1 := `
{
  "query": "{q(func: eq(email, \"email@company.io\")) {v as uid}}",
  "cond": " @if(eq(len(v), 0)) ",
  "set": [
    {
      "uid": "uid(v)",
      "name": "Wrong"
    },
    {
      "uid": "uid(v)",
      "email": "email@company.io"
    }
  ]
}`
	mr, err := mutationWithTs(mutationInp{body: m1, typ: "application/json", commitNow: true})
	require.NoError(t, err)
	require.True(t, len(mr.keys) == 0)
	result := QueryResult{}
	require.NoError(t, json.Unmarshal(mr.data, &result))
	require.Equal(t, 0, len(result.Queries["q"]))

	// query should return the wrong name
	q1 := `
{
  q(func: has(email)) {
    uid
    name
    email
  }
}`
	res, _, err := queryWithTs(queryInp{body: q1, typ: "application/dql"})
	require.NoError(t, err)
	require.Contains(t, res, "Wrong")

	// mutation with correct name
	m2 := `
{
  "query": "{q(func: eq(email, \"email@company.io\")) {v as uid}}",
  "cond": "@if(eq(len(v), 1))",
  "set": [
    {
      "uid": "uid(v)",
      "name": "Ashish"
    }
  ]
}`
	mr, err = mutationWithTs(mutationInp{body: m2, typ: "application/json", commitNow: true})
	require.NoError(t, err)
	require.True(t, len(mr.keys) == 0)
	require.Equal(t, []string{"name"}, splitPreds(mr.preds))
	result = QueryResult{}
	require.NoError(t, json.Unmarshal(mr.data, &result))