summaryrefslogtreecommitdiff
path: root/sqlparse
diff options
context:
space:
mode:
authorAndi Albrecht <albrecht.andi@gmail.com>2016-08-13 17:38:21 +0200
committerAndi Albrecht <albrecht.andi@gmail.com>2016-08-13 17:38:21 +0200
commit2893bd1857d685cf892beac3a7429d03cf1a09f1 (patch)
tree1fc1a427841391137820355f33cdaac119c080b6 /sqlparse
parentb7a30d04427e4e4cbc66d08b780ffbb23ab44931 (diff)
downloadsqlparse-2893bd1857d685cf892beac3a7429d03cf1a09f1.tar.gz
Parse double dollars (PostgreSQL) as literal strings (fixes #277).
Diffstat (limited to 'sqlparse')
-rw-r--r--sqlparse/keywords.py13
-rw-r--r--sqlparse/lexer.py7
2 files changed, 16 insertions, 4 deletions
diff --git a/sqlparse/keywords.py b/sqlparse/keywords.py
index a6ee1d6..eef0d02 100644
--- a/sqlparse/keywords.py
+++ b/sqlparse/keywords.py
@@ -10,13 +10,22 @@ import re
from sqlparse import tokens
-def is_keyword(value):
+def is_keyword(value, remaining):
val = value.upper()
return (KEYWORDS_COMMON.get(val) or
KEYWORDS_ORACLE.get(val) or
KEYWORDS.get(val, tokens.Name)), value
+def parse_literal_string(value, remaining):
+ try:
+ end = remaining[len(value):].index(value)
+ except ValueError:
+ return tokens.Name.Builtin, value
+ literal = remaining[:end + (len(value) * 2)]
+ return tokens.Literal, literal
+
+
SQL_REGEX = {
'root': [
(r'(--|# )\+.*?(\r\n|\r|\n|$)', tokens.Comment.Single.Hint),
@@ -35,7 +44,7 @@ SQL_REGEX = {
(r"`(``|[^`])*`", tokens.Name),
(r"´(´´|[^´])*´", tokens.Name),
- (r'\$([_A-Z]\w*)?\$', tokens.Name.Builtin),
+ (r'\$([_A-Z]\w*)?\$', parse_literal_string),
(r'\?', tokens.Name.Placeholder),
(r'%(\(\w+\))?s', tokens.Name.Placeholder),
diff --git a/sqlparse/lexer.py b/sqlparse/lexer.py
index e7996b2..1979550 100644
--- a/sqlparse/lexer.py
+++ b/sqlparse/lexer.py
@@ -50,11 +50,14 @@ class Lexer(object):
if not m:
continue
elif isinstance(action, tokens._TokenType):
+ consume_pos = m.end() - pos - 1
yield action, m.group()
elif callable(action):
- yield action(m.group())
+ ttype, value = action(m.group(), text[pos:])
+ consume_pos = len(value) - 1
+ yield ttype, value
- consume(iterable, m.end() - pos - 1)
+ consume(iterable, consume_pos)
break
else:
yield tokens.Error, char