| 2397 | ("dblink", InternalTraversal.dp_string), |
| 2398 | ) |
| 2399 | def _get_synonyms(self, connection, schema, filter_names, dblink, **kw): |
| 2400 | owner = self.denormalize_schema_name( |
| 2401 | schema or self.default_schema_name |
| 2402 | ) |
| 2403 | |
| 2404 | has_filter_names, params = self._prepare_filter_names(filter_names) |
| 2405 | query = select( |
| 2406 | dictionary.all_synonyms.c.synonym_name, |
| 2407 | dictionary.all_synonyms.c.table_name, |
| 2408 | dictionary.all_synonyms.c.table_owner, |
| 2409 | dictionary.all_synonyms.c.db_link, |
| 2410 | ).where(dictionary.all_synonyms.c.owner == owner) |
| 2411 | if has_filter_names: |
| 2412 | query = query.where( |
| 2413 | dictionary.all_synonyms.c.synonym_name.in_( |
| 2414 | params["filter_names"] |
| 2415 | ) |
| 2416 | ) |
| 2417 | result = self._execute_reflection( |
| 2418 | connection, query, dblink, returns_long=False |
| 2419 | ).mappings() |
| 2420 | return result.all() |
| 2421 | |
| 2422 | @lru_cache() |
| 2423 | def _all_objects_query( |