fix sqlserver named parameter

DataDog · Oct 23, 2024 · 9246d82 · 9246d82
1 parent 9117b42
commit 9246d82
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 1 deletion.
diff --git a/obfuscate_and_normalize_test.go b/obfuscate_and_normalize_test.go
@@ -411,6 +411,20 @@ multiline comment */
 				Size:       11,
 			},
 		},
+		{
+			input:    `DELETE [discount]  WHERE [description]=@1`,
+			expected: `DELETE discount WHERE description = @1`,
+			statementMetadata: StatementMetadata{
+				Tables:     []string{"discount"},
+				Comments:   []string{},
+				Commands:   []string{"DELETE"},
+				Procedures: []string{},
+				Size:       11,
+			},
+			lexerOpts: []lexerOption{
+				WithDBMS(DBMSSQLServer),
+			},
+		},
 	}
 
 	obfuscator := NewObfuscator(

diff --git a/sqllexer.go b/sqllexer.go
@@ -370,7 +370,7 @@ func (s *Lexer) scanWhitespace() Token {
 func (s *Lexer) scanOperator(lastCh rune) Token {
 	s.start = s.cursor
 	ch := s.next()
-	for isOperator(ch) && !(lastCh == '=' && ch == '?') {
+	for isOperator(ch) && !(lastCh == '=' && (ch == '?' || ch == '@')) {
 		// hack: we don't want to treat "=?" as an single operator
 		lastCh = ch
 		ch = s.next()