Function TestUpsertExample0JSON

dgraph/cmd/alpha/upsert_test.go:199–256

(t *testing.T)

}

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

	// Mutation with wrong name
	m1 := `
{
  "query": "{me(func: eq(email, \"email@company.io\")) {v as uid}}",
  "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)

	// 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": "{me(func: eq(email, \"email@company.io\")) {v as uid}}",
  "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))

	// query should return correct name
	res, _, err = queryWithTs(queryInp{body: q1, typ: "application/dql"})
	require.NoError(t, err)
	require.Contains(t, res, "Ashish")
}