Function Example_multiDBParallelQueryThreeDatabases

tests/multidb_test.go:334–372

Example_multiDBParallelQueryThreeDatabases tests querying all three databases in a single request. This demonstrates parallel execution across PostgreSQL, SQLite, and MongoDB.

()

// Example_multiDBParallelQueryThreeDatabases tests querying all three databases in a single request.
// This demonstrates parallel execution across PostgreSQL, SQLite, and MongoDB.
func Example_multiDBParallelQueryThreeDatabases() {
	// Skip if not in multi-DB mode
	if !requireMultiDB() {
		fmt.Println(`{"audit_logs":[{"action":"CREATE","id":1}],"events":[{"id":1,"type":"page_view"}],"users":[{"full_name":"User 1","id":1}]}`)
		return
	}

	gql := `query FullDashboard {
		users(limit: 1, order_by: { id: asc }) {
			id
			full_name
		}
		audit_logs(limit: 1, order_by: { id: asc }) {
			id
			action
		}
		events(limit: 1, order_by: { id: asc }) {
			id
			type
		}
	}`

	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, nil, nil)
	if err != nil {
		fmt.Println(err)
	} else {
		printJSON(res.Data)
	}
	// Output: {"audit_logs":[{"action":"CREATE","id":1}],"events":[{"id":1,"type":"page_view"}],"users":[{"full_name":"User 1","id":1}]}
}

// Example_multiDBParallelQueryWithVariables tests parallel root queries with GraphQL variables.
func Example_multiDBParallelQueryWithVariables() {