Function TestProtocolRowDescription

tests/integration/protocol_test.go:477–524

TestProtocolRowDescription tests that column metadata is correctly returned

(t *testing.T)

// TestProtocolRowDescription tests that column metadata is correctly returned
func TestProtocolRowDescription(t *testing.T) {
	t.Run("column_names", func(t *testing.T) {
		rows, err := testHarness.DuckgresDB.Query("SELECT 1 AS col_a, 2 AS col_b, 3 AS col_c")
		if err != nil {
			t.Fatalf("Query failed: %v", err)
		}
		defer func() { _ = rows.Close() }()

		columns, err := rows.Columns()
		if err != nil {
			t.Fatalf("Columns failed: %v", err)
		}

		expected := []string{"col_a", "col_b", "col_c"}
		if len(columns) != len(expected) {
			t.Fatalf("Expected %d columns, got %d", len(expected), len(columns))
		}
		for i, col := range columns {
			if col != expected[i] {
				t.Errorf("Column %d: expected %q, got %q", i, expected[i], col)
			}
		}
	})

	t.Run("column_types", func(t *testing.T) {
		rows, err := testHarness.DuckgresDB.Query("SELECT 1::INTEGER, 'text'::TEXT, TRUE::BOOLEAN")
		if err != nil {
			t.Fatalf("Query failed: %v", err)
		}
		defer func() { _ = rows.Close() }()

		types, err := rows.ColumnTypes()
		if err != nil {
			t.Fatalf("ColumnTypes failed: %v", err)
		}

		if len(types) != 3 {
			t.Fatalf("Expected 3 column types, got %d", len(types))
		}

		// Just verify we can access type info
		for i, ct := range types {
			name := ct.Name()
			dbType := ct.DatabaseTypeName()
			t.Logf("Column %d: name=%q, dbType=%q", i, name, dbType)
		}
	})
}

// TestProtocolMultipleStatements tests handling of multiple statements
func TestProtocolMultipleStatements(t *testing.T) {