Function TestPgDatabaseView

server/catalog_test.go:12–55

(t *testing.T)

)

func TestPgDatabaseView(t *testing.T) {
	db, err := sql.Open("duckdb", ":memory:")
	if err != nil {
		t.Fatalf("Failed to open database: %v", err)
	}
	defer func() { _ = db.Close() }()

	if err := initPgCatalog(db, processStartTime, processStartTime, "dev", "dev"); err != nil {
		t.Fatalf("Failed to init pg_catalog: %v", err)
	}

	// Test that pg_database view has all expected columns (PostgreSQL 16 compatible)
	expectedColumns := []string{
		"oid", "datname", "datdba", "encoding", "datlocprovider",
		"datistemplate", "datallowconn", "datconnlimit", "datfrozenxid",
		"datminmxid", "dattablespace", "datcollate", "datctype",
		"daticulocale", "daticurules", "datcollversion", "datacl",
	}

	rows, err := db.Query("SELECT * FROM pg_database LIMIT 1")
	if err != nil {
		t.Fatalf("Failed to query pg_database: %v", err)
	}
	defer func() { _ = rows.Close() }()

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

	if len(columns) != len(expectedColumns) {
		t.Errorf("Expected %d columns, got %d", len(expectedColumns), len(columns))
	}

	for i, expected := range expectedColumns {
		if i >= len(columns) {
			t.Errorf("Missing column %d: %s", i, expected)
			continue
		}
		if columns[i] != expected {
			t.Errorf("Column %d: expected %q, got %q", i, expected, columns[i])
		}
	}
}

func TestPgDatabaseViewContent(t *testing.T) {
	db, err := sql.Open("duckdb", ":memory:")