Function TestBulkLoaderNoDqlSchema

systest/integration2/bulk_loader_test.go:125–189

(t *testing.T)

}

func TestBulkLoaderNoDqlSchema(t *testing.T) {
	conf := dgraphtest.NewClusterConfig().WithNumAlphas(2).WithNumZeros(1).
		WithACL(time.Hour).WithReplicas(1).WithBulkLoadOutDir(t.TempDir())
	c, err := dgraphtest.NewLocalCluster(conf)
	require.NoError(t, err)
	defer func() { c.Cleanup(t.Failed()) }()

	// start zero
	require.NoError(t, c.StartZero(0))
	require.NoError(t, c.HealthCheck(true))

	baseDir := t.TempDir()
	gqlSchemaFile := filepath.Join(baseDir, "gql.schema")
	require.NoError(t, os.WriteFile(gqlSchemaFile, []byte(gqlSchema), os.ModePerm))
	dataFile := filepath.Join(baseDir, "data.json")
	require.NoError(t, os.WriteFile(dataFile, []byte(jsonData), os.ModePerm))

	opts := dgraphtest.BulkOpts{
		DataFiles:      []string{dataFile},
		GQLSchemaFiles: []string{gqlSchemaFile},
	}
	require.NoError(t, c.BulkLoad(opts))

	// start Alphas
	require.NoError(t, c.Start())

	// run some queries and ensure everything looks good
	hc, err := c.HTTPClient()
	require.NoError(t, err)
	require.NoError(t, hc.LoginIntoNamespace(dgraphapi.DefaultUser,
		dgraphapi.DefaultPassword, x.RootNamespace))

	params := dgraphapi.GraphQLParams{
		Query: `query {
			getMessage(uniqueId: 3) {
				content
				author
			}
		}`,
	}
	data, err := hc.RunGraphqlQuery(params, false)
	require.NoError(t, err)
	dgraphapi.CompareJSON(`{
		"getMessage": {
		  "content": "DVTCTXCVYI",
		  "author": "USYMVFJYXA"
		}
	  }`, string(data))

	require.NoError(t, hc.LoginIntoNamespace(dgraphapi.DefaultUser, dgraphapi.DefaultPassword, 1))
	params = dgraphapi.GraphQLParams{
		Query: `query {
			getTemplate(uniqueId: 2) {
				content
			}
		}`,
	}
	data, err = hc.RunGraphqlQuery(params, false)