mirror of
https://github.com/apache/impala.git
synced 2025-12-20 02:20:11 -05:00
71c5ec7af5
The only thing this commit does is upgrade sqlparse. The upgrade was done by downloading and extracting the tarball, nothing else (such as patching). The older version of sqlparse would parse SELECT ' ; ' ; into two statements. Neither statement is complete due to the open quote and this would cause an infinite loop. The bug is already fixed in the newest version of sqlparse. Change-Id: I7ce7c269769ae0cde3dc8ca386d0b0e11bea71c1 Reviewed-on: http://gerrit.cloudera.org:8080/102 Reviewed-by: Casey Ching <casey@cloudera.com> Tested-by: Internal Jenkins
71 lines
1.9 KiB
Python
71 lines
1.9 KiB
Python
import unittest
|
|
|
|
from sqlparse.filters import ColumnsSelect
|
|
from sqlparse.lexer import tokenize
|
|
from sqlparse.pipeline import Pipeline
|
|
|
|
|
|
class Test(unittest.TestCase):
|
|
|
|
def setUp(self):
|
|
self.pipe = Pipeline()
|
|
self.pipe.append(tokenize)
|
|
self.pipe.append(ColumnsSelect())
|
|
|
|
def test_1(self):
|
|
sql = """
|
|
-- type: script
|
|
-- return: integer
|
|
|
|
INCLUDE "Direntry.make.sql";
|
|
|
|
INSERT INTO directories(inode)
|
|
VALUES(:inode)
|
|
LIMIT 1"""
|
|
self.assertEqual([], self.pipe(sql))
|
|
|
|
def test_2(self):
|
|
sql = """
|
|
SELECT child_entry,asdf AS inode, creation
|
|
FROM links
|
|
WHERE parent_dir == :parent_dir AND name == :name
|
|
LIMIT 1"""
|
|
self.assertEqual([u'child_entry', u'inode', u'creation'],
|
|
self.pipe(sql))
|
|
|
|
def test_3(self):
|
|
sql = """
|
|
SELECT
|
|
0 AS st_dev,
|
|
0 AS st_uid,
|
|
0 AS st_gid,
|
|
|
|
dir_entries.type AS st_mode,
|
|
dir_entries.inode AS st_ino,
|
|
COUNT(links.child_entry) AS st_nlink,
|
|
|
|
:creation AS st_ctime,
|
|
dir_entries.access AS st_atime,
|
|
dir_entries.modification AS st_mtime,
|
|
-- :creation AS st_ctime,
|
|
-- CAST(STRFTIME('%s',dir_entries.access) AS INTEGER) AS st_atime,
|
|
-- CAST(STRFTIME('%s',dir_entries.modification) AS INTEGER) AS st_mtime,
|
|
|
|
COALESCE(files.size,0) AS st_size, -- Python-FUSE
|
|
COALESCE(files.size,0) AS size -- PyFilesystem
|
|
|
|
FROM dir_entries
|
|
LEFT JOIN files
|
|
ON dir_entries.inode == files.inode
|
|
LEFT JOIN links
|
|
ON dir_entries.inode == links.child_entry
|
|
|
|
WHERE dir_entries.inode == :inode
|
|
|
|
GROUP BY dir_entries.inode
|
|
LIMIT 1"""
|
|
self.assertEqual([u'st_dev', u'st_uid', u'st_gid', u'st_mode',
|
|
u'st_ino', u'st_nlink', u'st_ctime',
|
|
u'st_atime', u'st_mtime', u'st_size', u'size'],
|
|
self.pipe(sql))
|