Function Example_multiDBParallelQueryWithVariables

tests/multidb_test.go:375–411

Example_multiDBParallelQueryWithVariables tests parallel root queries with GraphQL variables.

()

// Example_multiDBParallelQueryWithVariables tests parallel root queries with GraphQL variables.
func Example_multiDBParallelQueryWithVariables() {
	// Skip if not in multi-DB mode
	if !requireMultiDB() {
		fmt.Println(`{"audit_logs":[{"action":"CREATE","id":1}],"users":[{"full_name":"User 1","id":1},{"full_name":"User 2","id":2}]}`)
		return
	}

	gql := `query FilteredDashboard($userLimit: Int!, $logLimit: Int!) {
		users(limit: $userLimit, order_by: { id: asc }) {
			id
			full_name
		}
		audit_logs(limit: $logLimit, order_by: { id: asc }) {
			id
			action
		}
	}`

	vars := json.RawMessage(`{"userLimit": 2, "logLimit": 1}`)

	conf := newMultiDBConfig(&core.Config{DisableAllowList: true})
	conf.Tables = multiDBTables()

	gj, err := newMultiDBGraphJin(conf)
	if err != nil {
		fmt.Println(err)
		return
	}

	res, err := gj.GraphQL(context.Background(), gql, vars, nil)
	if err != nil {
		fmt.Println(err)
	} else {
		printJSON(res.Data)
	}
	// Output: {"audit_logs":[{"action":"CREATE","id":1}],"users":[{"full_name":"User 1","id":1},{"full_name":"User 2","id":2}]}
}