| 2226 | ("dblink", InternalTraversal.dp_string), |
| 2227 | ) |
| 2228 | def _get_synonyms(self, connection, schema, filter_names, dblink, **kw): |
| 2229 | owner = self.denormalize_schema_name( |
| 2230 | schema or self.default_schema_name |
| 2231 | ) |
| 2232 | |
| 2233 | has_filter_names, params = self._prepare_filter_names(filter_names) |
| 2234 | query = select( |
| 2235 | dictionary.all_synonyms.c.synonym_name, |
| 2236 | dictionary.all_synonyms.c.table_name, |
| 2237 | dictionary.all_synonyms.c.table_owner, |
| 2238 | dictionary.all_synonyms.c.db_link, |
| 2239 | ).where(dictionary.all_synonyms.c.owner == owner) |
| 2240 | if has_filter_names: |
| 2241 | query = query.where( |
| 2242 | dictionary.all_synonyms.c.synonym_name.in_( |
| 2243 | params["filter_names"] |
| 2244 | ) |
| 2245 | ) |
| 2246 | result = self._execute_reflection( |
| 2247 | connection, query, dblink, returns_long=False |
| 2248 | ).mappings() |
| 2249 | return result.all() |
| 2250 | |
| 2251 | @lru_cache() |
| 2252 | def _all_objects_query( |