Function buildSessionPgAttributeViewSQL

server/sessionmeta/sessionmeta.go:508–548

()

		CROSS JOIN active_catalog ac
		WHERE r.database_name = ac.catalog
	`,
		internalNames, access.relationPredicate("schema_name", "table_name"),
		internalNames, access.relationPredicate("schema_name", "view_name"),
		internalNames, access.relationPredicate("schema_name", "sequence_name"),
		internalNames, access.relationPredicate("schema_name", "table_name"),
	)
}

func buildSessionPgNamespaceViewSQL(access *MetadataAccessPolicy) string {
	sql := `
		CREATE OR REPLACE VIEW main.pg_namespace AS
		WITH active_catalog AS (
			SELECT current_database() AS catalog
		),
		user_namespaces AS (
			SELECT schema_oid AS oid, schema_name, database_name FROM duckdb_tables()
			UNION
			SELECT schema_oid AS oid, schema_name, database_name FROM duckdb_views()
			UNION
			SELECT schema_oid AS oid, schema_name, database_name FROM duckdb_sequences()
			UNION
			SELECT schema_oid AS oid, schema_name, database_name FROM duckdb_indexes()
		)
		SELECT DISTINCT
			oid,
			CASE WHEN schema_name = 'main' THEN 'public' ELSE schema_name END AS nspname,
			CASE WHEN schema_name = 'main' THEN 6171::BIGINT ELSE 10::BIGINT END AS nspowner,
			NULL AS nspacl
		FROM user_namespaces n
		CROSS JOIN active_catalog ac
		WHERE n.database_name = ac.catalog
			AND n.schema_name NOT LIKE '__ducklake_metadata_%'
			AND {{ACCESS}}
		UNION ALL
		SELECT 11::BIGINT AS oid, 'pg_catalog' AS nspname, 10::BIGINT AS nspowner, NULL AS nspacl
		UNION ALL
		SELECT 12::BIGINT AS oid, 'information_schema' AS nspname, 10::BIGINT AS nspowner, NULL AS nspacl
		UNION ALL
		SELECT 99::BIGINT AS oid, 'pg_toast' AS nspname, 10::BIGINT AS nspowner, NULL AS nspacl
	`
	return strings.Replace(sql, "{{ACCESS}}", access.schemaPredicate("n.schema_name"), 1)
}

func pgTypeOIDCaseSQL(dataTypeExpr, fallbackExpr string) string {