forked from DataDog/go-sqllexer
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathsqllexer.go
More file actions
800 lines (728 loc) · 21.8 KB
/
Copy pathsqllexer.go
File metadata and controls
800 lines (728 loc) · 21.8 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
package sqllexer
import (
"unicode/utf8"
)
type TokenType int
const (
ERROR TokenType = iota
EOF
SPACE // space or newline
STRING // string literal
INCOMPLETE_STRING // incomplete string literal so that we can obfuscate it, e.g. 'abc
NUMBER // number literal
IDENT // identifier
QUOTED_IDENT // quoted identifier
OPERATOR // operator
WILDCARD // wildcard *
COMMENT // comment
MULTILINE_COMMENT // multiline comment
PUNCTUATION // punctuation
DOLLAR_QUOTED_FUNCTION // dollar quoted function
DOLLAR_QUOTED_STRING // dollar quoted string
POSITIONAL_PARAMETER // numbered parameter
BIND_PARAMETER // bind parameter
FUNCTION // function
SYSTEM_VARIABLE // system variable
UNKNOWN // unknown token
COMMAND // SQL commands like SELECT, INSERT
KEYWORD // Other SQL keywords
JSON_OP // JSON operators
BOOLEAN // boolean literal
NULL // null literal
PROC_INDICATOR // procedure indicator
CTE_INDICATOR // CTE indicator
ALIAS_INDICATOR // alias indicator
)
// Token represents a SQL token with its type and value.
type Token struct {
Type TokenType
Value string
isTableIndicator bool // true if the token is a table indicator
hasDigits bool
hasQuotes bool // private - only used by trimQuotes
isSimpleIdentifier bool // true if quoted ident started with a letter and only used alphanumerics afterwards
lastValueToken LastValueToken // private - internal state
}
type LastValueToken struct {
Type TokenType
Value string
isTableIndicator bool
isSimpleIdentifier bool
}
// getLastValueToken can be private since it's only used internally
func (t *Token) getLastValueToken() *LastValueToken {
t.lastValueToken.Type = t.Type
t.lastValueToken.Value = t.Value
t.lastValueToken.isTableIndicator = t.isTableIndicator
t.lastValueToken.isSimpleIdentifier = t.isSimpleIdentifier
return &t.lastValueToken
}
type LexerConfig struct {
DBMS DBMSType `json:"dbms,omitempty"`
// ExecutableComments scans the body of a MySQL executable comment
// (/*! ... */ and /*!NNNNN ... */) as SQL rather than emitting the whole
// construct as one MULTILINE_COMMENT token.
//
// Defaults to true; New sets it before applying options. Not omitempty,
// because a false here is a deliberate choice and should serialize.
ExecutableComments bool `json:"executable_comments"`
}
type lexerOption func(*LexerConfig)
func WithDBMS(dbms DBMSType) lexerOption {
dbms = getDBMSFromAlias(dbms)
return func(c *LexerConfig) {
c.DBMS = dbms
}
}
// WithExecutableComments controls how MySQL executable comments are tokenized.
//
// MySQL executes the body of /*! ... */ and /*!NNNNN ... */ when the server is
// at least version NNNNN, so `id=1/*!50000union select pw from users*/` runs
// the union on any MySQL >= 5.0. Lexing that as one comment token hides the
// statement from anything reading the token stream, and leaves two tokens where
// a whole union used to be.
//
// On by default, and dialect-aware: a caller that declares PostgreSQL, SQL
// Server, Oracle or Snowflake gets a plain comment, because those engines do
// not execute the construct. A caller that declares MySQL, or declares nothing,
// gets the body lexed as SQL -- the reading that matches what a MySQL server
// would do, which is the one anything reading untrusted input has to assume.
//
// Pass false to get a single MULTILINE_COMMENT token whatever the dialect.
// Query normalization may want that, so an optimizer hint stays a comment in
// obfuscated output.
func WithExecutableComments(enabled bool) lexerOption {
return func(c *LexerConfig) {
c.ExecutableComments = enabled
}
}
// SQL Lexer inspired from Rob Pike's talk on Lexical Scanning in Go
type Lexer struct {
src string // the input src string
cursor int // the current position of the cursor
start int // the start position of the current token
config *LexerConfig
token *Token
hasQuotes bool // true if any quotes in token
hasDigits bool // true if the token has digits
isTableIndicator bool // true if the token is a table indicator
isSimpleIdentifier bool // true if current quoted ident started with a letter and only used alphanumerics afterwards
execComments bool // mirrors config.ExecutableComments, read once per token
inExecComment bool // true while scanning the body of a MySQL executable comment
}
func New(input string, opts ...lexerOption) *Lexer {
lexer := &Lexer{
src: input,
config: &LexerConfig{ExecutableComments: true},
token: &Token{},
}
for _, opt := range opts {
opt(lexer.config)
}
lexer.execComments = lexer.config.ExecutableComments && executesComments(lexer.config.DBMS)
return lexer
}
// Scan scans the next token and returns it.
func (s *Lexer) Scan() *Token {
ch := s.peek()
if s.execComments {
ch = s.skipExecutableCommentDelimiters(ch)
}
switch {
case isSpace(ch):
return s.scanWhitespace()
case isLetter(ch):
return s.scanIdentifier(ch)
case isDoubleQuote(ch):
// MySQL by default (without ANSI_QUOTES mode) treats double quotes as string literals
if s.config.DBMS == DBMSMySQL {
return s.scanStringWithDelimiter('"')
}
return s.scanDoubleQuotedIdentifier('"')
case isSingleQuote(ch):
return s.scanStringWithDelimiter('\'')
case isSingleLineComment(ch, s.lookAhead(1)):
return s.scanSingleLineComment(ch)
case isMultiLineComment(ch, s.lookAhead(1)):
return s.scanMultiLineComment()
case isLeadingSign(ch):
// if the leading sign is followed by a digit, then it's a number
// although this is not strictly true, it's good enough for our purposes
nextCh := s.lookAhead(1)
if isDigit(nextCh) || nextCh == '.' {
return s.scanNumberWithLeadingSign()
}
return s.scanOperator(ch)
case isDigit(ch):
return s.scanNumber(ch)
case isWildcard(ch):
return s.scanWildcard()
case ch == '$':
if isDigit(s.lookAhead(1)) {
// if the dollar sign is followed by a digit, then it's a numbered parameter
return s.scanPositionalParameter()
}
if s.config.DBMS == DBMSSQLServer && isLetter(s.lookAhead(1)) {
return s.scanIdentifier(ch)
}
return s.scanDollarQuotedString()
case ch == ':':
if s.config.DBMS == DBMSOracle && isAlphaNumeric(s.lookAhead(1)) {
return s.scanBindParameter()
}
return s.scanOperator(ch)
case ch == '`':
if s.config.DBMS == DBMSMySQL {
return s.scanDoubleQuotedIdentifier('`')
}
return s.scanUnknown() // backtick is only valid in mysql
case ch == '#':
// SQL Server names temporary tables #temp, so there a # opens an
// identifier. It is the only dialect that does, and saying so is the
// caller's job.
if s.config.DBMS == DBMSSQLServer {
return s.scanIdentifier(ch)
}
// PostgreSQL spells three JSON path operators #> #>> #-, but only
// PostgreSQL does, so recognising them requires being told. Guessing
// from the two characters alone is what a bypass is made of: MySQL
// reads `admin'#-` as a comment to end of line and logs you in.
if s.config.DBMS == DBMSPostgres && (s.lookAhead(1) == '>' || s.lookAhead(1) == '-') {
return s.scanOperator(ch)
}
// Everything else: a comment to end of line. MySQL says so outright,
// and a caller that has not named its dialect gets the same reading,
// because the alternative is worse for the one that cannot afford to
// guess. A WAF scanning untrusted input has no idea what is behind it;
// scanning `admin'#` as an identifier and an operator hides a login
// bypass that MySQL would execute, while scanning a stray # in some
// other dialect as a comment costs a token.
return s.scanSingleLineComment(ch)
case ch == '@':
if s.lookAhead(1) == '@' {
if isAlphaNumeric(s.lookAhead(2)) {
return s.scanSystemVariable()
}
s.start = s.cursor
s.nextBy(2) // consume @@
return s.emit(JSON_OP)
}
if isAlphaNumeric(s.lookAhead(1)) {
if s.config.DBMS == DBMSSnowflake {
return s.scanIdentifier(ch)
}
return s.scanBindParameter()
}
if s.lookAhead(1) == '?' || s.lookAhead(1) == '>' {
s.start = s.cursor
s.nextBy(2) // consume @? or @>
return s.emit(JSON_OP)
}
fallthrough
case isOperator(ch):
return s.scanOperator(ch)
case isPunctuation(ch):
if ch == '[' && s.config.DBMS == DBMSSQLServer {
return s.scanDoubleQuotedIdentifier('[')
}
return s.scanPunctuation()
case isEOF(ch):
return s.emit(EOF)
default:
return s.scanUnknown()
}
}
// lookAhead returns the rune n positions ahead of the cursor.
func (s *Lexer) lookAhead(n int) rune {
pos := s.cursor + n
if pos >= len(s.src) || pos < 0 {
return eofRune
}
// Fast path for ASCII
b := s.src[pos]
if b < utf8.RuneSelf {
return rune(b)
}
// Slow path for non-ASCII
r, _ := utf8.DecodeRuneInString(s.src[pos:])
return r
}
// peek returns the rune at the cursor position.
func (s *Lexer) peek() rune {
return s.lookAhead(0)
}
// nextBy advances the cursor by n positions and returns the rune at the cursor position.
func (s *Lexer) nextBy(n int) rune {
// advance the cursor by n and return the rune at the cursor position
if s.cursor+n > len(s.src) {
return eofRune
}
s.cursor += n
if s.cursor >= len(s.src) {
return eofRune
}
// Fast path for ASCII
b := s.src[s.cursor]
if b < utf8.RuneSelf {
return rune(b)
}
// Slow path for non-ASCII
r, _ := utf8.DecodeRuneInString(s.src[s.cursor:])
return r
}
// next advances the cursor by 1 position and returns the rune at the cursor position.
func (s *Lexer) next() rune {
return s.nextBy(1)
}
func (s *Lexer) matchAt(match []rune) bool {
if s.cursor+len(match) > len(s.src) {
return false
}
for i, ch := range match {
if s.src[s.cursor+i] != byte(ch) {
return false
}
}
return true
}
func (s *Lexer) scanNumberWithLeadingSign() *Token {
s.start = s.cursor
ch := s.next() // consume the leading sign
return s.scanDecimalNumber(ch)
}
func (s *Lexer) scanNumber(ch rune) *Token {
s.start = s.cursor
return s.scanNumberic(ch)
}
func (s *Lexer) scanNumberic(ch rune) *Token {
s.start = s.cursor
if ch == '0' {
nextCh := s.lookAhead(1)
if nextCh == 'x' || nextCh == 'X' {
return s.scanHexNumber()
} else if nextCh >= '0' && nextCh <= '7' {
return s.scanOctalNumber()
}
}
ch = s.next() // consume first digit
return s.scanDecimalNumber(ch)
}
func (s *Lexer) scanDecimalNumber(ch rune) *Token {
// scan digits
for isDigit(ch) || ch == '.' || isExpontent(ch) {
if isExpontent(ch) {
ch = s.next()
if isLeadingSign(ch) {
ch = s.next()
}
} else {
ch = s.next()
}
}
return s.emit(NUMBER)
}
func (s *Lexer) scanHexNumber() *Token {
ch := s.nextBy(2) // consume 0x or 0X
for isDigit(ch) || ('a' <= ch && ch <= 'f') || ('A' <= ch && ch <= 'F') {
ch = s.next()
}
return s.emit(NUMBER)
}
func (s *Lexer) scanOctalNumber() *Token {
ch := s.nextBy(2) // consume the leading 0 and number
for '0' <= ch && ch <= '7' {
ch = s.next()
}
return s.emit(NUMBER)
}
func (s *Lexer) scanStringWithDelimiter(delimiter rune) *Token {
s.start = s.cursor
escaped := false
escapedQuote := false
// SQL Server (T-SQL) and Oracle do not use backslash as a string escape
// character; a quote inside a literal is escaped by doubling it ('').
backslashEscapes := s.config.DBMS != DBMSSQLServer && s.config.DBMS != DBMSOracle
ch := s.next() // consume opening quote
for ; !isEOF(ch); ch = s.next() {
if escaped {
escaped = false
escapedQuote = ch == delimiter
continue
}
if backslashEscapes && ch == '\\' {
escaped = true
continue
}
if ch == delimiter {
s.next() // consume the closing quote
return s.emit(STRING)
}
}
// Special case: if we ended with an escaped quote (e.g. ESCAPE '\')
if escapedQuote {
return s.emit(STRING)
}
// If we get here, we hit EOF before finding closing quote
return s.emit(INCOMPLETE_STRING)
}
func (s *Lexer) scanIdentifier(ch rune) *Token {
s.start = s.cursor
node := keywordRoot
pos := s.cursor
// If first character is Unicode, skip trie lookup
if ch > 127 {
for isIdentifier(ch, s.lookAhead(1)) {
s.hasDigits = s.hasDigits || isDigit(ch)
ch = s.nextBy(utf8.RuneLen(ch))
}
if s.start == s.cursor {
return s.scanUnknown()
}
return s.emit(IDENT)
}
// ASCII characters - try keyword matching
for isAsciiLetter(ch) || ch == '_' {
// Convert to uppercase for case-insensitive matching
upperCh := ch
if ch >= 'a' && ch <= 'z' {
upperCh -= 32
}
// Get array index for this character
idx := trieIndex(upperCh)
if idx < 0 {
// Invalid character for trie, break out
node = keywordRoot
ch = s.next()
break
}
// Try to follow trie path using direct array access
if next := node.children[idx]; next != nil {
node = next
pos = s.cursor
ch = s.next()
} else {
// No more matches possible in trie
// Reset node for next potential keyword
// and continue scanning identifier
node = keywordRoot
ch = s.next()
break
}
}
// If we found a complete keyword and next char is whitespace
if node.isEnd && (isPunctuation(ch) || isSpace(ch) || isMultiLineComment(ch, s.lookAhead(1)) ||
s.atExecCommentClose(ch) || isEOF(ch)) {
s.cursor = pos + 1 // Include the last matched character
s.isTableIndicator = node.isTableIndicator
return s.emit(node.tokenType)
}
// Continue scanning identifier if no keyword match
for isIdentifier(ch, s.lookAhead(1)) {
s.hasDigits = s.hasDigits || isDigit(ch)
ch = s.nextBy(utf8.RuneLen(ch))
}
if s.start == s.cursor {
return s.scanUnknown()
}
if ch == '(' {
return s.emit(FUNCTION)
}
return s.emit(IDENT)
}
func (s *Lexer) scanDoubleQuotedIdentifier(delimiter rune) *Token {
closingDelimiter := delimiter
if delimiter == '[' {
closingDelimiter = ']'
}
s.start = s.cursor
s.hasQuotes = true
s.isSimpleIdentifier = true
firstRune := true
ch := s.next() // consume the opening quote
specialCase := []rune{closingDelimiter, '.', delimiter}
for {
// encountered the closing quote
// BUT if it's followed by .", then we should keep going
// e.g. postgres "foo"."bar"
// e.g. sqlserver [foo].[bar]
if ch == closingDelimiter {
if s.matchAt(specialCase) {
s.isSimpleIdentifier = false
ch = s.nextBy(3) // consume the "."
continue
}
if firstRune {
s.isSimpleIdentifier = false
}
break
}
if isEOF(ch) {
s.hasQuotes = false // if we hit EOF, we clear the quotes
s.isSimpleIdentifier = false
return s.emit(ERROR)
}
s.hasDigits = s.hasDigits || isDigit(ch)
if s.isSimpleIdentifier {
if firstRune {
if !isLetter(ch) {
s.isSimpleIdentifier = false
}
firstRune = false
} else if !isAlphaNumeric(ch) {
s.isSimpleIdentifier = false
}
}
// Advance by actual decoded rune size.
// This handles truncated UTF-8 sequences correctly.
_, size := utf8.DecodeRuneInString(s.src[s.cursor:])
ch = s.nextBy(size)
}
s.next() // consume the closing quote (ASCII)
return s.emit(QUOTED_IDENT)
}
func (s *Lexer) scanWhitespace() *Token {
// scan whitespace, tab, newline, carriage return
s.start = s.cursor
ch := s.next()
for isSpace(ch) {
ch = s.next()
}
return s.emit(SPACE)
}
func (s *Lexer) scanOperator(lastCh rune) *Token {
s.start = s.cursor
ch := s.next() // consume the first character
// Check for json operators
switch lastCh {
case '-':
if ch == '>' {
ch = s.next()
if ch == '>' {
s.next()
return s.emit(JSON_OP) // ->>
}
return s.emit(JSON_OP) // ->
}
case '#':
if ch == '>' {
ch = s.next()
if ch == '>' {
s.next()
return s.emit(JSON_OP) // #>>
}
return s.emit(JSON_OP) // #>
} else if ch == '-' {
s.next()
return s.emit(JSON_OP) // #-
}
case '?':
if ch == '|' {
s.next()
return s.emit(JSON_OP) // ?|
} else if ch == '&' {
s.next()
return s.emit(JSON_OP) // ?&
}
case '<':
if ch == '@' {
s.next()
return s.emit(JSON_OP) // <@
}
}
for isOperator(ch) && !(lastCh == '=' && (ch == '?' || ch == '@')) {
// hack: we don't want to treat "=?" as an single operator
lastCh = ch
ch = s.next()
}
return s.emit(OPERATOR)
}
func (s *Lexer) scanWildcard() *Token {
s.start = s.cursor
s.next()
return s.emit(WILDCARD)
}
func (s *Lexer) scanSingleLineComment(ch rune) *Token {
s.start = s.cursor
if ch == '#' {
ch = s.next() // consume the opening #
} else {
ch = s.nextBy(2) // consume the opening dashes
}
for ch != '\n' && !isEOF(ch) {
ch = s.next()
}
return s.emit(COMMENT)
}
func (s *Lexer) scanMultiLineComment() *Token {
s.start = s.cursor
ch := s.nextBy(2) // consume the opening slash and asterisk
for {
if ch == '*' && s.lookAhead(1) == '/' {
s.nextBy(2) // consume the closing asterisk and slash
break
}
if isEOF(ch) {
// encountered EOF before closing comment
// this usually happens when the comment is truncated
return s.emit(ERROR)
}
ch = s.next()
}
return s.emit(MULTILINE_COMMENT)
}
// skipExecutableCommentDelimiters consumes any run of MySQL executable comment
// delimiters at the cursor and returns the rune Scan should dispatch on. The
// delimiters emit no token of their own, so scanning has to carry on past them
// to reach one; looping rather than recursing keeps a run of empty comments
// (/*!*//*!*/...) from growing the stack once per delimiter.
func (s *Lexer) skipExecutableCommentDelimiters(ch rune) rune {
for {
// Closing delimiter of a body we are lexing. Reached only outside
// strings and comments, so a */ inside a quoted literal does not end
// the body -- which is what MySQL does too.
if s.atExecCommentClose(ch) {
s.nextBy(2)
s.inExecComment = false
ch = s.peek()
continue
}
if isMultiLineComment(ch, s.lookAhead(1)) && s.lookAhead(2) == '!' {
s.consumeExecutableCommentOpening()
ch = s.peek()
continue
}
return ch
}
}
// executesComments reports whether a dialect runs the body of /*! ... */.
//
// MySQL does, and so does anything that has not said what it is: a consumer
// that cannot name its backend -- a WAF in front of an unknown one -- has to
// read the construct the way the engine that executes it would.
func executesComments(dbms DBMSType) bool {
switch dbms {
case DBMSPostgres, DBMSSQLServer, DBMSOracle, DBMSSnowflake:
return false
default:
return true
}
}
// atExecCommentClose reports whether the cursor sits on the `*/` that ends the
// executable comment body currently being lexed.
//
// It is a token boundary like a space is: `/*!50000or*/` executes as the
// operator, so `or` has to reach the keyword trie as a complete word rather
// than decay to an IDENT because the rune after it is a `*`.
func (s *Lexer) atExecCommentClose(ch rune) bool {
return s.inExecComment && ch == '*' && s.lookAhead(1) == '/'
}
// consumeExecutableCommentOpening consumes the opening `/*!` of a MySQL
// executable comment plus the version gate when one is present, leaving the
// cursor on the body so it is lexed as ordinary SQL until Scan reaches the
// closing `*/`.
//
// A version gate is exactly five digits (50000 is 5.0.0). Anything shorter is
// not a gate, so those digits stay part of the body and lex as a number.
func (s *Lexer) consumeExecutableCommentOpening() {
s.nextBy(3) // consume the opening slash, asterisk and bang
digits := 0
for digits < 5 && isDigit(s.lookAhead(digits)) {
digits++
}
if digits == 5 {
s.nextBy(5)
}
s.inExecComment = true
}
func (s *Lexer) scanPunctuation() *Token {
s.start = s.cursor
s.next()
return s.emit(PUNCTUATION)
}
func (s *Lexer) scanDollarQuotedString() *Token {
s.start = s.cursor
ch := s.next() // consume the dollar sign
tagStart := s.cursor
for s.cursor < len(s.src) && ch != '$' {
ch = s.next()
}
s.next() // consume the closing dollar sign of the tag
tag := s.src[tagStart-1 : s.cursor] // include the opening and closing dollar sign e.g. $tag$
tagRune := []rune(tag)
tagLen := len(tagRune)
for s.cursor < len(s.src) {
if s.matchAt(tagRune) {
s.nextBy(tagLen) // consume the closing tag
if tag == "$func$" {
return s.emit(DOLLAR_QUOTED_FUNCTION)
}
return s.emit(DOLLAR_QUOTED_STRING)
}
s.next()
}
return s.emit(ERROR)
}
func (s *Lexer) scanPositionalParameter() *Token {
s.start = s.cursor
ch := s.nextBy(2) // consume the dollar sign and the number
for {
if !isDigit(ch) {
break
}
ch = s.next()
}
return s.emit(POSITIONAL_PARAMETER)
}
func (s *Lexer) scanBindParameter() *Token {
s.start = s.cursor
ch := s.nextBy(2) // consume the (colon|at sign) and the char
for {
if !isAlphaNumeric(ch) {
break
}
ch = s.next()
}
return s.emit(BIND_PARAMETER)
}
func (s *Lexer) scanSystemVariable() *Token {
s.start = s.cursor
ch := s.nextBy(2) // consume @@
// Must be followed by at least one alphanumeric character
if !isAlphaNumeric(ch) {
return s.emit(ERROR)
}
for isAlphaNumeric(ch) {
ch = s.next()
}
return s.emit(SYSTEM_VARIABLE)
}
func (s *Lexer) scanUnknown() *Token {
// When we see an unknown token, we advance the cursor by the full rune length.
// This is important for multi-byte UTF-8 characters (e.g., full-width punctuation)
// to avoid splitting them into separate byte tokens.
s.start = s.cursor
_, size := utf8.DecodeRuneInString(s.src[s.cursor:])
s.cursor += size
return s.emit(UNKNOWN)
}
// Modify emit function to use positions and maintain links
func (s *Lexer) emit(t TokenType) *Token {
tok := s.token
lastValueToken := tok.lastValueToken
// Zero other fields
*tok = Token{
Type: t,
Value: s.src[s.start:s.cursor],
isTableIndicator: s.isTableIndicator,
lastValueToken: lastValueToken,
}
tok.hasDigits = s.hasDigits
tok.hasQuotes = s.hasQuotes
tok.isSimpleIdentifier = s.isSimpleIdentifier
// Reset lexer state
s.start = s.cursor
s.isTableIndicator = false
s.hasDigits = false
s.isSimpleIdentifier = false
return tok
}