Function runQueryTest

tests/integration/setup_test.go:314–362

runQueryTest runs a single query test

(t *testing.T, test QueryTest)

// runQueryTest runs a single query test
func runQueryTest(t *testing.T, test QueryTest) {
	t.Helper()

	// Check centralized skip list first
	skipIfKnown(t)

	if test.Skip != "" {
		t.Skipf("Skipping: %s", test.Skip)
		return
	}

	if test.DuckgresOnly || skipPostgresCompare {
		// Only test against Duckgres
		result, err := ExecuteQuery(testHarness.DuckgresDB, test.Query)
		if err != nil {
			t.Fatalf("Failed to execute query: %v", err)
		}
		if test.ExpectError {
			if result.Error == nil {
				t.Errorf("Expected error but query succeeded")
			}
		} else {
			if result.Error != nil {
				t.Errorf("Query failed: %v", result.Error)
			}
		}
		return
	}

	// Compare PostgreSQL and Duckgres
	opts := test.Options
	if opts.FloatTolerance == 0 {
		opts = DefaultCompareOptions()
	}

	result := CompareQueries(testHarness.PostgresDB, testHarness.DuckgresDB, test.Query, opts)

	if test.ExpectError {
		if result.PGError == nil && result.DGError == nil {
			t.Errorf("Expected error but both queries succeeded")
		}
		return
	}

	if !result.Match {
		t.Errorf("Query results do not match:\n  PostgreSQL rows: %d\n  Duckgres rows: %d\n  Differences:\n    %s",
			result.PGRowCount, result.DGRowCount, formatDifferences(result.Differences))
	}
}

// runQueryTests runs multiple query tests
func runQueryTests(t *testing.T, tests []QueryTest) {