summaryrefslogtreecommitdiff
path: root/sqlparse
diff options
context:
space:
mode:
authorVictor Uriarte <victor.m.uriarte@intel.com>2016-06-02 13:53:26 -0700
committerVictor Uriarte <victor.m.uriarte@intel.com>2016-06-02 13:53:26 -0700
commit81e408a4f2c8281e0da7c93ed75da90df1a518e2 (patch)
tree9dd97e37e57964120187acb7229af9001bdbdc69 /sqlparse
parente4c5625e1476e56cc5f06fec446571737b8a3f95 (diff)
downloadsqlparse-81e408a4f2c8281e0da7c93ed75da90df1a518e2.tar.gz
Remove redundant functions
Diffstat (limited to 'sqlparse')
-rw-r--r--sqlparse/__init__.py2
-rw-r--r--sqlparse/engine/__init__.py16
2 files changed, 2 insertions, 16 deletions
diff --git a/sqlparse/__init__.py b/sqlparse/__init__.py
index b2494c0..794bf57 100644
--- a/sqlparse/__init__.py
+++ b/sqlparse/__init__.py
@@ -35,7 +35,7 @@ def parsestream(stream, encoding=None):
:returns: A generator of :class:`~sqlparse.sql.Statement` instances.
"""
stack = engine.FilterStack()
- stack.full_analyze()
+ stack.enable_grouping()
return stack.run(stream, encoding)
diff --git a/sqlparse/engine/__init__.py b/sqlparse/engine/__init__.py
index 1268bd1..c6b8b0c 100644
--- a/sqlparse/engine/__init__.py
+++ b/sqlparse/engine/__init__.py
@@ -9,9 +9,6 @@ from sqlparse import lexer
from sqlparse.engine import grouping
from sqlparse.engine.filter import StatementFilter
-# XXX remove this when cleanup is complete
-Filter = object
-
class FilterStack(object):
@@ -22,20 +19,9 @@ class FilterStack(object):
self.split_statements = False
self._grouping = False
- def _flatten(self, stream):
- for token in stream:
- if token.is_group():
- for t in self._flatten(token.tokens):
- yield t
- else:
- yield token
-
def enable_grouping(self):
self._grouping = True
- def full_analyze(self):
- self.enable_grouping()
-
def run(self, sql, encoding=None):
stream = lexer.tokenize(sql, encoding)
# Process token stream
@@ -71,7 +57,7 @@ class FilterStack(object):
def _run2(stream):
for stmt in stream:
- stmt.tokens = list(self._flatten(stmt.tokens))
+ stmt.tokens = list(stmt.flatten())
for filter_ in self.postprocess:
stmt = filter_.process(self, stmt)
yield stmt