sql注入

SQL注入是一种常见的网络安全攻击手段，攻击者通过在应用程序的输入字段中插入恶意SQL代码，篡改数据库查询逻辑，从而非法访问、修改或删除数据库中的数据。以下是详细的介绍及防治方法：

一、SQL注入的原理

攻击原理
- 应用程序未对用户输入进行严格验证或过滤，直接将用户输入拼接到SQL语句中。
- 攻击者通过构造恶意输入（如特殊字符、SQL关键字），改变原SQL查询的逻辑，执行非预期的操作。
攻击场景示例
假设登录功能的SQL查询为：
```
SELECT * FROM users WHERE username = '$username' AND password = '$password';
```
如果用户输入 username = ' OR '1'='1，密码任意，则生成的SQL变为：
```
SELECT * FROM users WHERE username = '' OR '1'='1' AND password = '...';
```
由于 '1'='1' 永远为真，攻击者可绕过身份验证。
攻击类型
- 基本型注入：直接修改查询条件（如 UNION SELECT 获取数据）。
- 报错型注入：利用数据库错误信息获取数据（如 1' AND 1=CONVERT(int,(SELECT TOP 1 name FROM master..sysdatabases))--）。
- 盲注：通过布尔值或时间延迟判断结果（如 1' AND IF(ASCII(SUBSTRING((SELECT password FROM users LIMIT 1),1,1))>97, SLEEP(5), 0)--）。
- 联合查询注入：通过 UNION SELECT 合并多个查询结果（如 1' UNION SELECT null, password FROM users--）。

二、SQL注入的危害

数据泄露
- 攻击者可窃取敏感数据（如用户密码、信用卡号、个人信息）。
数据篡改
- 修改数据库中的数据（如篡改订单金额、用户权限）。
数据删除
- 删除数据库表或关键数据（如 DROP TABLE users;）。
系统瘫痪
- 通过注入恶意代码导致数据库崩溃或服务不可用。
隐私侵犯
- 获取用户隐私信息，违反法律法规（如GDPR）。

三、SQL注入的防治方法

1. 参数化查询（预编译语句）

原理：将用户输入作为参数传递，与SQL语句分离，数据库引擎自动处理参数的转义。

示例：

// 安全写法（参数化查询）
await pool.execute('SELECT * FROM users WHERE username = ?', [username]);

// Java JDBC 示例
String query = "SELECT * FROM users WHERE username = ?";
PreparedStatement pstmt = connection.prepareStatement(query);
pstmt.setString(1, username); // 自动转义特殊字符

优势：
- 输入始终被视为数据，而非可执行代码。
- 防止恶意代码注入，是最推荐的防护方式。

2. 输入验证与过滤

白名单验证：仅允许符合预期格式的输入（如邮箱、手机号）。

# Python 正则验证
import re
if not re.match(r'^[a-zA-Z0-9_-]+$', username):raise ValueError("Invalid username")

长度限制：限制输入长度，防止超长恶意payload。

转义特殊字符：对输入中的特殊字符（如单引号、分号）进行转义。

// PHP 示例（使用PDO转义）
$stmt = $pdo->prepare("SELECT * FROM users WHERE username = :username");
$stmt->execute(['username' => $username]);

3. 最小权限原则

数据库用户权限：

为应用程序分配最小必要权限（如只允许 SELECT 和 INSERT）。
避免使用高权限账户（如 root 或 sa）。

-- MySQL 示例：创建低权限用户
CREATE USER 'app_user'@'localhost' IDENTIFIED BY 'password';
GRANT SELECT, INSERT ON app_db.* TO 'app_user'@'localhost';

4. 使用ORM框架

ORM（对象关系映射）：自动处理SQL转义，减少手写SQL的风险。

# Django ORM 示例
user = User.objects.get(username=username)

// Sequelize 示例
const user = await User.findOne({ where: { username } });

5. 错误信息处理

隐藏敏感错误信息：避免向用户暴露数据库错误详情（如堆栈跟踪）。

# 错误响应示例（不暴露具体错误）
HTTP/1.1 500 Internal Server Error
{"error": "An internal error occurred."}

6. 安全编码实践

避免动态拼接SQL：

禁止直接拼接用户输入到SQL语句中。

对必须拼接的部分（如 ORDER BY 字段），使用白名单限制允许的字段。

# 白名单限制排序字段
allowed_columns = ['name', 'email']
order_by = request.args.get('order_by', 'name')
if order_by not in allowed_columns:order_by = 'name'
query = f"SELECT * FROM users ORDER BY {order_by};"