Function TestNoConflictQuery2

query/query4_test.go:359–419

(t *testing.T)

}

func TestNoConflictQuery2(t *testing.T) {
	schema := `
		type node {
		name_noconflict: string
		address_conflict: string
		child: uid
		}

		name_noconflict: string @noconflict .
		address_conflict: string .
		child: uid .
	`
	setSchema(schema)

	type node struct {
		ID      string `json:"uid"`
		Name    string `json:"name_noconflict"`
		Child   *node  `json:"child"`
		Address string `json:"address_conflict"`
	}

	child := node{ID: "_:blank-0", Name: "child", Address: "dgraph labs"}
	js, err := json.Marshal(child)
	require.NoError(t, err)

	res, err := client.NewTxn().Mutate(context.Background(),
		&api.Mutation{SetJson: js, CommitNow: true})
	require.NoError(t, err)

	in := []node{}
	for i := 0; i < 5; i++ {
		in = append(in, node{ID: "_:blank-0", Name: fmt.Sprintf("%d", i+1),
			Child: &node{ID: res.GetUids()["blank-0"]}})
	}

	errChan := make(chan error)
	for i := range in {
		go func(n node) {
			js, err := json.Marshal(n)
			require.NoError(t, err)

			_, err = client.NewTxn().Mutate(context.Background(),
				&api.Mutation{SetJson: js, CommitNow: true})
			errChan <- err
		}(in[i])
	}

	errs := []error{}
	for i := 0; i < len(in); i++ {
		errs = append(errs, <-errChan)
	}

	hasError := false
	for _, e := range errs {
		if e != nil {
			hasError = true
			require.Contains(t, e.Error(), "Transaction has been aborted. Please retry")
		}