summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/sql
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2020-05-18 16:08:33 -0400
committerMike Bayer <mike_mp@zzzcomputing.com>2020-05-18 16:21:54 -0400
commit53af60b3536221f2503af29c1e90cf9db1295faf (patch)
tree13d5e142ed0759e63fb4fee7aa244519703e42ed /lib/sqlalchemy/sql
parentde1fd55af4ef352ebbc95e03d868aab2995a8261 (diff)
downloadsqlalchemy-53af60b3536221f2503af29c1e90cf9db1295faf.tar.gz
Streamline visitors.iterate
This method might be used more significantly in the ORM refactor, so further refine it. * all get_children() methods now work entirely based on iterators. Basically only select() was sensitive to this anymore and it now chains the iterators together * remove all kinds of flags like column_collections, schema_visitor that apparently aren't used anymore. * remove the "depthfirst" visitors as these don't seem to be used either. * make sure select() yields its columns first as these will be used to determine the current mapper. Change-Id: I05273a2d5306a57c2d1b0979050748cf3ac964bf
Diffstat (limited to 'lib/sqlalchemy/sql')
-rw-r--r--lib/sqlalchemy/sql/elements.py23
-rw-r--r--lib/sqlalchemy/sql/schema.py29
-rw-r--r--lib/sqlalchemy/sql/selectable.py11
-rw-r--r--lib/sqlalchemy/sql/traversals.py19
-rw-r--r--lib/sqlalchemy/sql/util.py2
-rw-r--r--lib/sqlalchemy/sql/visitors.py92
6 files changed, 47 insertions, 129 deletions
diff --git a/lib/sqlalchemy/sql/elements.py b/lib/sqlalchemy/sql/elements.py
index e7c1f3f77..43115f117 100644
--- a/lib/sqlalchemy/sql/elements.py
+++ b/lib/sqlalchemy/sql/elements.py
@@ -388,19 +388,18 @@ class ClauseElement(
clause-level).
"""
- result = []
try:
traverse_internals = self._traverse_internals
except AttributeError:
- return result
+ return []
- for attrname, obj, meth in _get_children.run_generated_dispatch(
- self, traverse_internals, "_generated_get_children_traversal"
- ):
- if obj is None or attrname in omit_attrs:
- continue
- result.extend(meth(obj, **kw))
- return result
+ return itertools.chain.from_iterable(
+ meth(obj, **kw)
+ for attrname, obj, meth in _get_children.run_generated_dispatch(
+ self, traverse_internals, "_generated_get_children_traversal"
+ )
+ if attrname not in omit_attrs and obj is not None
+ )
def self_group(self, against=None):
# type: (Optional[Any]) -> ClauseElement
@@ -4302,8 +4301,14 @@ class ColumnClause(
def get_children(self, column_tables=False, **kw):
if column_tables and self.table is not None:
+ # TODO: this is only used by ORM query deep_entity_zero.
+ # this is being removed in a later release so remove
+ # column_tables also at that time.
return [self.table]
else:
+ # override base get_children() to not return the Table
+ # or selectable that is parent to this column. Traversals
+ # expect the columns of tables and subqueries to be leaf nodes.
return []
@HasMemoized.memoized_attribute
diff --git a/lib/sqlalchemy/sql/schema.py b/lib/sqlalchemy/sql/schema.py
index 08dc487d4..8d28d6309 100644
--- a/lib/sqlalchemy/sql/schema.py
+++ b/lib/sqlalchemy/sql/schema.py
@@ -117,10 +117,6 @@ class SchemaItem(SchemaEventTarget, visitors.Visitable):
else:
spwd(self)
- def get_children(self, **kwargs):
- """used to allow SchemaVisitor access"""
- return []
-
def __repr__(self):
return util.generic_repr(self, omit_kwarg=["info"])
@@ -820,21 +816,6 @@ class Table(DialectKWArgs, SchemaItem, TableClause):
metadata._add_table(self.name, self.schema, self)
self.metadata = metadata
- def get_children(
- self, column_collections=True, schema_visitor=False, **kw
- ):
- # TODO: consider that we probably don't need column_collections=True
- # at all, it does not seem to impact anything
- if not schema_visitor:
- return TableClause.get_children(
- self, column_collections=column_collections, **kw
- )
- else:
- if column_collections:
- return list(self.columns)
- else:
- return []
-
@util.deprecated(
"1.4",
"The :meth:`_schema.Table.exists` method is deprecated and will be "
@@ -1656,16 +1637,6 @@ class Column(DialectKWArgs, SchemaItem, ColumnClause):
selectable.foreign_keys.update(fk)
return c.key, c
- def get_children(self, schema_visitor=False, **kwargs):
- if schema_visitor:
- return (
- [x for x in (self.default, self.onupdate) if x is not None]
- + list(self.foreign_keys)
- + list(self.constraints)
- )
- else:
- return ColumnClause.get_children(self, **kwargs)
-
class ForeignKey(DialectKWArgs, SchemaItem):
"""Defines a dependency between two columns.
diff --git a/lib/sqlalchemy/sql/selectable.py b/lib/sqlalchemy/sql/selectable.py
index 27b9425ec..0f3d24191 100644
--- a/lib/sqlalchemy/sql/selectable.py
+++ b/lib/sqlalchemy/sql/selectable.py
@@ -3454,8 +3454,8 @@ class Select(
_traverse_internals = (
[
- ("_from_obj", InternalTraversal.dp_clauseelement_list),
("_raw_columns", InternalTraversal.dp_clauseelement_list),
+ ("_from_obj", InternalTraversal.dp_clauseelement_list),
("_where_criteria", InternalTraversal.dp_clauseelement_list),
("_having_criteria", InternalTraversal.dp_clauseelement_list),
("_order_by_clauses", InternalTraversal.dp_clauseelement_list,),
@@ -3944,10 +3944,11 @@ class Select(
self._assert_no_memoizations()
def get_children(self, **kwargs):
- return list(set(self._iterate_from_elements())) + super(
- Select, self
- ).get_children(
- omit_attrs=["_from_obj", "_correlate", "_correlate_except"]
+ return itertools.chain(
+ super(Select, self).get_children(
+ omit_attrs=["_from_obj", "_correlate", "_correlate_except"]
+ ),
+ self._iterate_from_elements(),
)
@_generative
diff --git a/lib/sqlalchemy/sql/traversals.py b/lib/sqlalchemy/sql/traversals.py
index 4a135538e..8c63fcba1 100644
--- a/lib/sqlalchemy/sql/traversals.py
+++ b/lib/sqlalchemy/sql/traversals.py
@@ -1,5 +1,6 @@
from collections import deque
from collections import namedtuple
+import itertools
import operator
from . import operators
@@ -589,28 +590,22 @@ class _GetChildren(InternalTraversal):
return (element,)
def visit_clauseelement_list(self, element, **kw):
- return tuple(element)
+ return element
def visit_clauseelement_tuples(self, element, **kw):
- tup = ()
- for elem in element:
- tup += elem
- return tup
+ return itertools.chain.from_iterable(element)
def visit_fromclause_canonical_column_collection(self, element, **kw):
- if kw.get("column_collections", False):
- return tuple(element)
- else:
- return ()
+ return ()
def visit_string_clauseelement_dict(self, element, **kw):
- return tuple(element.values())
+ return element.values()
def visit_fromclause_ordered_set(self, element, **kw):
- return tuple(element)
+ return element
def visit_clauseelement_unordered_set(self, element, **kw):
- return tuple(element)
+ return element
def visit_dml_ordered_values(self, element, **kw):
for k, v in element:
diff --git a/lib/sqlalchemy/sql/util.py b/lib/sqlalchemy/sql/util.py
index ca5bde091..0a67ff9bf 100644
--- a/lib/sqlalchemy/sql/util.py
+++ b/lib/sqlalchemy/sql/util.py
@@ -267,7 +267,7 @@ def find_tables(
_visitors["table"] = tables.append
- visitors.traverse(clause, {"column_collections": False}, _visitors)
+ visitors.traverse(clause, {}, _visitors)
return tables
diff --git a/lib/sqlalchemy/sql/visitors.py b/lib/sqlalchemy/sql/visitors.py
index 8f6bb2333..574896cc7 100644
--- a/lib/sqlalchemy/sql/visitors.py
+++ b/lib/sqlalchemy/sql/visitors.py
@@ -32,10 +32,8 @@ from ..util import symbol
__all__ = [
"iterate",
- "iterate_depthfirst",
"traverse_using",
"traverse",
- "traverse_depthfirst",
"cloned_traverse",
"replacement_traverse",
"Traversible",
@@ -568,23 +566,20 @@ CloningVisitor = CloningExternalTraversal
ReplacingCloningVisitor = ReplacingExternalTraversal
-def iterate(obj, opts):
+def iterate(obj, opts=util.immutabledict()):
r"""traverse the given expression structure, returning an iterator.
traversal is configured to be breadth-first.
- The central API feature used by the :func:`.visitors.iterate` and
- :func:`.visitors.iterate_depthfirst` functions is the
+ The central API feature used by the :func:`.visitors.iterate`
+ function is the
:meth:`_expression.ClauseElement.get_children` method of
- :class:`_expression.ClauseElement`
- objects. This method should return all the
- :class:`_expression.ClauseElement` objects
- which are associated with a particular :class:`_expression.ClauseElement`
- object.
- For example, a :class:`.Case` structure will refer to a series of
- :class:`_expression.ColumnElement`
- objects within its "whens" and "else\_" member
- variables.
+ :class:`_expression.ClauseElement` objects. This method should return all
+ the :class:`_expression.ClauseElement` objects which are associated with a
+ particular :class:`_expression.ClauseElement` object. For example, a
+ :class:`.Case` structure will refer to a series of
+ :class:`_expression.ColumnElement` objects within its "whens" and "else\_"
+ member variables.
:param obj: :class:`_expression.ClauseElement` structure to be traversed
@@ -592,49 +587,17 @@ def iterate(obj, opts):
empty in modern usage.
"""
- # fasttrack for atomic elements like columns
+ yield obj
children = obj.get_children(**opts)
if not children:
- return [obj]
+ return
- traversal = deque()
- stack = deque([obj])
+ stack = deque([children])
while stack:
- t = stack.popleft()
- traversal.append(t)
- for c in t.get_children(**opts):
- stack.append(c)
- return iter(traversal)
-
-
-def iterate_depthfirst(obj, opts):
- """traverse the given expression structure, returning an iterator.
-
- traversal is configured to be depth-first.
-
- :param obj: :class:`_expression.ClauseElement` structure to be traversed
-
- :param opts: dictionary of iteration options. This dictionary is usually
- empty in modern usage.
-
- .. seealso::
-
- :func:`.visitors.iterate` - includes a general overview of iteration.
-
- """
- # fasttrack for atomic elements like columns
- children = obj.get_children(**opts)
- if not children:
- return [obj]
-
- stack = deque([obj])
- traversal = deque()
- while stack:
- t = stack.pop()
- traversal.appendleft(t)
- for c in t.get_children(**opts):
- stack.append(c)
- return iter(traversal)
+ t_iterator = stack.popleft()
+ for t in t_iterator:
+ yield t
+ stack.append(t.get_children(**opts))
def traverse_using(iterator, obj, visitors):
@@ -642,18 +605,16 @@ def traverse_using(iterator, obj, visitors):
objects.
:func:`.visitors.traverse_using` is usually called internally as the result
- of the :func:`.visitors.traverse` or :func:`.visitors.traverse_depthfirst`
- functions.
+ of the :func:`.visitors.traverse` function.
:param iterator: an iterable or sequence which will yield
:class:`_expression.ClauseElement`
structures; the iterator is assumed to be the
- product of the :func:`.visitors.iterate` or
- :func:`.visitors.iterate_depthfirst` functions.
+ product of the :func:`.visitors.iterate` function.
:param obj: the :class:`_expression.ClauseElement`
that was used as the target of the
- :func:`.iterate` or :func:`.iterate_depthfirst` function.
+ :func:`.iterate` function.
:param visitors: dictionary of visit functions. See :func:`.traverse`
for details on this dictionary.
@@ -662,7 +623,6 @@ def traverse_using(iterator, obj, visitors):
:func:`.traverse`
- :func:`.traverse_depthfirst`
"""
for target in iterator:
@@ -705,20 +665,6 @@ def traverse(obj, opts, visitors):
return traverse_using(iterate(obj, opts), obj, visitors)
-def traverse_depthfirst(obj, opts, visitors):
- """traverse and visit the given expression structure using the
- depth-first iterator.
-
- The iteration of objects uses the :func:`.visitors.iterate_depthfirst`
- function, which does a depth-first traversal using a stack.
-
- Usage is the same as that of :func:`.visitors.traverse` function.
-
-
- """
- return traverse_using(iterate_depthfirst(obj, opts), obj, visitors)
-
-
def cloned_traverse(obj, opts, visitors):
"""clone the given expression structure, allowing modifications by
visitors.