Function TestMultipleMutation

dgraph/cmd/alpha/upsert_test.go:2260–2335

(t *testing.T)

}

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

	m1 := `
upsert {
  query {
    q(func: eq(email, "email@company.io")) {
      v as uid
    }
  }

  mutation @if(not(eq(len(v), 0))) {
    set {
      uid(v) <name> "not_name" .
      uid(v) <email> "not_email@company.io" .
    }
  }

  mutation @if(eq(len(v), 0)) {
    set {
      _:user <name> "name" .
      _:user <email> "email@company.io" .
    }
  }
}`
	mr, err := mutationWithTs(mutationInp{body: m1, typ: "application/rdf", commitNow: true})
	require.NoError(t, err)
	require.True(t, len(mr.keys) == 0)
	require.Equal(t, []string{"email", "name"}, splitPreds(mr.preds))
	result := QueryResult{}
	require.NoError(t, json.Unmarshal(mr.data, &result))
	require.Equal(t, 0, len(result.Queries["q"]))

	q1 := `
{
  q(func: eq(email, "email@company.io")) {
    name
  }
}`
	res, _, err := queryWithTs(queryInp{body: q1, typ: "application/dql"})
	expectedRes := `
{
  "data": {
    "q": [{
      "name": "name"
     }]
   }
}`
	require.NoError(t, err)
	testutil.CompareJSON(t, res, expectedRes)

	// This time the other mutation will get executed
	_, err = mutationWithTs(mutationInp{body: m1, typ: "application/rdf", commitNow: true})
	require.NoError(t, err)

	q2 := `
{