Function TestQueryParentAndChildrenViaArrayColumn

tests/array_test.go:14–68

(t *testing.T)

)

func TestQueryParentAndChildrenViaArrayColumn(t *testing.T) {
	skipCassandra(t, "array/collection columns are not seeded in the cassandra fixture")
	skipClickHouse(t, "array/collection columns are not seeded in the fixture")
	if dbType == "mssql" {
		t.Skip("skipping test for mssql (array column joins not yet supported)")
	}
	if dbType == "snowflake" {
		t.Skip("snowflake: test assumes Postgres-style insertion order; Snowflake doesn't guarantee order without ORDER BY")
	}
	if dbType == "bigquery" {
		t.Skip("bigquery: array-column relationship joins need UNNEST lowering in the dialect/simulator")
	}

	gql := `
	query {
		products(limit: 2, order_by: { id: asc }) {
			name
			price
			categories(order_by: { id: asc }) {
				id
				name
			}
		}
		categories(order_by: { id: asc }) {
			name
			products(order_by: { id: asc }) {
				name
			}
		}
	}`

	conf := newConfig(&core.Config{DBType: dbType, DisableAllowList: true, DefaultLimit: 2})
	conf.Tables = []core.Table{
		{
			Name: "products",
			Columns: []core.Column{
				{Name: "category_ids", ForeignKey: "categories.id", Array: true},
			},
		},
	}

	gj, err := core.NewGraphJin(conf, db)
	if err != nil {
		t.Fatal(err)
	}
	defer gj.Close()

	res, err := gj.GraphQL(context.Background(), gql, nil, nil)
	if err != nil {
		t.Error(err)
	}

	exp := `{"categories":[{"name":"Category 1","products":[{"name":"Product 1"},{"name":"Product 2"}]},{"name":"Category 2","products":[{"name":"Product 1"},{"name":"Product 2"}]}],"products":[{"categories":[{"id":1,"name":"Category 1"},{"id":2,"name":"Category 2"}],"name":"Product 1","price":11.5},{"categories":[{"id":1,"name":"Category 1"},{"id":2,"name":"Category 2"}],"name":"Product 2","price":12.5}]}`
	assert.Equal(t, exp, stdJSON(res.Data))
}

func TestInsertIntoTableAndConnectToRelatedTableWithArrayColumn(t *testing.T) {
	skipCassandra(t, "array/collection columns are not seeded in the cassandra fixture")