Function TestUpsertExample0

dgraph/cmd/alpha/upsert_test.go:40–108

(t *testing.T)

}

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

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

  mutation {
    set {
      uid(v) <name> "Wrong" .
      uid(v) <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"]))

	// 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 := `
upsert {
  query {
    q(func: eq(email, "email@company.io")) {
      v as uid
    }
  }

  mutation {
    set {
      uid(v) <name> "Ashish" .
    }
  }
}`
	mr, err = mutationWithTs(mutationInp{body: m2, typ: "application/rdf", commitNow: true})
	require.NoError(t, err)