Как исправить Incorrect syntax near в SQL

 1-- Правильный SELECT
 2SELECT column1, column2 FROM table_name WHERE condition;
 3
 4-- Правильный INSERT
 5INSERT INTO table_name (column1, column2) VALUES (value1, value2);
 6
 7-- Правильный UPDATE
 8UPDATE table_name SET column1 = value1 WHERE condition;
 9
10-- Правильный DELETE
11DELETE FROM table_name WHERE condition;

 1-- Неправильно
 2SELECT * FROM users WHERE name = 'John's data';
 3
 4-- Правильно
 5SELECT * FROM users WHERE name = 'John''s data';
 6
 7-- Или используй двойные кавычки
 8SELECT * FROM users WHERE name = "John's data";
 9
10-- Для динамических запросов
11DECLARE @name NVARCHAR(50) = 'John''s data';
12SELECT * FROM users WHERE name = @name;

 1-- Неправильно
 2SELECT * FROM order WHERE status = 'active';
 3
 4-- Правильно - используй квадратные скобки
 5SELECT * FROM [order] WHERE status = 'active';
 6
 7-- Или используй двойные кавычки
 8SELECT * FROM "order" WHERE status = 'active';
 9
10-- Или переименуй таблицу
11SELECT * FROM orders WHERE status = 'active';

 1-- Неправильно
 2SELECT u.name, o.order_id 
 3FROM users u, orders o 
 4WHERE u.id = o.user_id;
 5
 6-- Правильно - используй явный JOIN
 7SELECT u.name, o.order_id 
 8FROM users u 
 9INNER JOIN orders o ON u.id = o.user_id;
10
11-- Или LEFT JOIN
12SELECT u.name, o.order_id 
13FROM users u 
14LEFT JOIN orders o ON u.id = o.user_id;

1-- Неправильно
2SELECT * FROM users WHERE id IN (SELECT user_id FROM orders WHERE status = 'active';
3
4-- Правильно - добавь закрывающую скобку
5SELECT * FROM users WHERE id IN (SELECT user_id FROM orders WHERE status = 'active');
6
7-- Или используй EXISTS
8SELECT * FROM users u 
9WHERE EXISTS (SELECT 1 FROM orders o WHERE o.user_id = u.id AND o.status = 'active');

 1# sql_validator.py
 2import re
 3from typing import Dict, List
 4
 5class SQLValidator:
 6    def __init__(self):
 7        self.reserved_words = [
 8            'SELECT', 'FROM', 'WHERE', 'INSERT', 'UPDATE', 'DELETE',
 9            'JOIN', 'INNER', 'LEFT', 'RIGHT', 'OUTER', 'ON', 'AND', 'OR',
10            'ORDER', 'BY', 'GROUP', 'HAVING', 'LIMIT', 'OFFSET'
11        ]
12    
13    def validate_sql_syntax(self, sql: str) -> Dict:
14        errors = []
15        
16        # Проверь парные скобки
17        if not self._check_brackets(sql):
18            errors.append("Unmatched brackets")
19        
20        # Проверь кавычки
21        if not self._check_quotes(sql):
22            errors.append("Unmatched quotes")
23        
24        # Проверь базовую структуру
25        if not self._check_basic_structure(sql):
26            errors.append("Invalid SQL structure")
27        
28        # Проверь резервированные слова
29        reserved_issues = self._check_reserved_words(sql)
30        if reserved_issues:
31            errors.extend(reserved_issues)
32        
33        return {
34            'valid': len(errors) == 0,
35            'errors': errors,
36            'sql': sql
37        }
38    
39    def _check_brackets(self, sql: str) -> bool:
40        stack = []
41        for char in sql:
42            if char == '(':
43                stack.append(char)
44            elif char == ')':
45                if not stack:
46                    return False
47                stack.pop()
48        return len(stack) == 0
49    
50    def _check_quotes(self, sql: str) -> bool:
51        single_quotes = sql.count("'")
52        double_quotes = sql.count('"')
53        return single_quotes % 2 == 0 and double_quotes % 2 == 0
54    
55    def _check_basic_structure(self, sql: str) -> bool:
56        sql_upper = sql.upper()
57        # Проверь наличие основных ключевых слов
58        if 'SELECT' in sql_upper and 'FROM' not in sql_upper:
59            return False
60        if 'INSERT' in sql_upper and 'VALUES' not in sql_upper:
61            return False
62        return True
63    
64    def _check_reserved_words(self, sql: str) -> List[str]:
65        issues = []
66        words = re.findall(r'\b\w+\b', sql.upper())
67        for word in words:
68            if word in self.reserved_words:
69                issues.append(f"Reserved word '{word}' might need escaping")
70        return issues
71
72# Использование
73validator = SQLValidator()
74result = validator.validate_sql_syntax("SELECT * FROM users WHERE name = 'John'")
75print(f"SQL validation: {result}")

 1# sql_fixer.py
 2import re
 3
 4class SQLFixer:
 5    def __init__(self):
 6        self.reserved_words = [
 7            'ORDER', 'GROUP', 'USER', 'PASSWORD', 'KEY', 'INDEX'
 8        ]
 9    
10    def fix_sql_syntax(self, sql: str) -> str:
11        # Исправь кавычки
12        sql = self._fix_quotes(sql)
13        
14        # Исправь резервированные слова
15        sql = self._fix_reserved_words(sql)
16        
17        # Исправь скобки
18        sql = self._fix_brackets(sql)
19        
20        return sql
21    
22    def _fix_quotes(self, sql: str) -> str:
23        # Замени одинарные кавычки внутри строк на двойные
24        pattern = r"'([^']*'[^']*)'"
25        sql = re.sub(pattern, r'"\1"', sql)
26        return sql
27    
28    def _fix_reserved_words(self, sql: str) -> str:
29        for word in self.reserved_words:
30            # Добавь квадратные скобки вокруг резервированных слов
31            pattern = rf'\b{word}\b'
32            sql = re.sub(pattern, f'[{word}]', sql, flags=re.IGNORECASE)
33        return sql
34    
35    def _fix_brackets(self, sql: str) -> str:
36        # Добавь недостающие закрывающие скобки
37        open_count = sql.count('(')
38        close_count = sql.count(')')
39        if open_count > close_count:
40            sql += ')' * (open_count - close_count)
41        return sql
42
43# Использование
44fixer = SQLFixer()
45fixed_sql = fixer.fix_sql_syntax("SELECT * FROM order WHERE name = 'John's data'")
46print(f"Fixed SQL: {fixed_sql}")

 1# sql_error_monitor.py
 2import pyodbc
 3from datetime import datetime
 4
 5def monitor_sql_errors(connection_string: str):
 6    try:
 7        conn = pyodbc.connect(connection_string)
 8        cursor = conn.cursor()
 9        
10        # Получи информацию об ошибках SQL
11        cursor.execute("""
12            SELECT 
13                ERROR_NUMBER() as error_number,
14                ERROR_MESSAGE() as error_message,
15                ERROR_LINE() as error_line,
16                ERROR_PROCEDURE() as error_procedure
17            FROM sys.messages 
18            WHERE message_id = 102
19        """)
20        
21        errors = cursor.fetchall()
22        
23        cursor.close()
24        conn.close()
25        
26        return {
27            'sql_errors': errors,
28            'timestamp': datetime.now()
29        }
30    except Exception as e:
31        return {
32            'error': str(e),
33            'timestamp': datetime.now()
34        }
35
36# Мониторинг
37connection_string = "DRIVER={SQL Server};SERVER=localhost;DATABASE=testdb;UID=user;PWD=password"
38status = monitor_sql_errors(connection_string)
39print(f"SQL error monitoring: {status}")