Generates a subsource name by prepending source schema name if present For eg. if source is `a.b`, then `a` will be prepended to the subsource name so that it's generated in the same schema as source
(
source_name: &UnresolvedItemName,
subsource_name: &str,
)
| 130 | /// For eg. if source is `a.b`, then `a` will be prepended to the subsource name |
| 131 | /// so that it's generated in the same schema as source |
| 132 | fn source_export_name_gen( |
| 133 | source_name: &UnresolvedItemName, |
| 134 | subsource_name: &str, |
| 135 | ) -> Result<UnresolvedItemName, PlanError> { |
| 136 | let mut partial = normalize::unresolved_item_name(source_name.clone())?; |
| 137 | partial.item = subsource_name.to_string(); |
| 138 | Ok(UnresolvedItemName::from(partial)) |
| 139 | } |
| 140 | |
| 141 | // TODO(database-issues#8620): Remove once subsources are removed |
| 142 | /// Validates the requested subsources do not have name conflicts with each other |
no test coverage detected