Function buildSessionPgDatabaseViewSQL

server/sessionmeta/sessionmeta.go:164–218

(database string)

		buildSessionInformationSchemaTablesViewSQL(access),
		buildSessionInformationSchemaSchemataViewSQL(access),
		buildSessionInformationSchemaViewsViewSQL(access),
		buildSessionInformationSchemaSequencesViewSQL(access),
	}
	return strings.Join(parts, ";\n") + ";"
}

func (p *MetadataAccessPolicy) relationPredicate(schemaExpression, relationExpression string) string {
	if p == nil {
		return "TRUE"
	}
	schemas := normalizedSQLValues(p.AllowedSchemas)
	relations := normalizedSQLValues(p.AllowedRelations)
	parts := make([]string, 0, 2)
	if len(schemas) > 0 {
		parts = append(parts, fmt.Sprintf("lower(%s) IN (%s)", schemaExpression, quotedSQLValues(schemas)))
	}
	if len(relations) > 0 {
		parts = append(parts, fmt.Sprintf("lower(%s || '.' || %s) IN (%s)", schemaExpression, relationExpression, quotedSQLValues(relations)))
	}
	if len(parts) == 0 {
		return "FALSE"
	}
	return "(" + strings.Join(parts, " OR ") + ")"
}

func (p *MetadataAccessPolicy) schemaPredicate(schemaExpression string) string {
	if p == nil {
		return "TRUE"
	}
	values := append([]string(nil), p.AllowedSchemas...)
	for _, relation := range p.AllowedRelations {
		if schema, _, ok := strings.Cut(relation, "."); ok {
			values = append(values, schema)
		}
	}
	values = normalizedSQLValues(values)
	if len(values) == 0 {
		return "FALSE"
	}
	return fmt.Sprintf("lower(%s) IN (%s)", schemaExpression, quotedSQLValues(values))
}

func normalizedSQLValues(values []string) []string {
	seen := make(map[string]struct{}, len(values))
	for _, value := range values {
		value = strings.ToLower(strings.TrimSpace(value))
		if value != "" {
			seen[value] = struct{}{}
		}
	}
	result := make([]string, 0, len(seen))
	for value := range seen {
		result = append(result, value)
	}
	sort.Strings(result)
	return result
}