pub fn statement_source(
catalog: &impl SessionCatalog,
stmt: &Statement<Aug>,
) -> Option<StatementSource>Expand description
Resolves the existing source that stmt drives, mirroring how the
purification paths below resolve it themselves.
None means the statement drives no such source: it names its connection
outright (CREATE SOURCE, CREATE SINK), or the name does not resolve to a
source. Purification reports the latter itself, and bails on it before
opening any connection. A Statement variant that instead reaches
upstream through an existing catalog item needs an arm here, or callers see
no source at all.