当前位置：首页 > 数据库 > 正文

如何快速上手SQL查询代码？

admin
数据库
2025-06-12
4785

连接数据库后，使用SQL语句描述所需数据，通过执行查询命令获取结果集，最后处理并关闭连接，具体语法取决于数据库类型和编程语言。

数据库查询代码核心步骤与规范

建立数据库连接（关键安全步骤）

# Python示例（使用pymysql）
import pymysql
def get_db_connection():
    try:
        # 使用环境变量管理敏感信息
        conn = pymysql.connect(
            host='localhost',
            user='your_secure_user',
            password=os.getenv("DB_PASSWORD"),  # 从环境变量读取密码
            database='your_db',
            charset='utf8mb4',
            cursorclass=pymysql.cursors.DictCursor
        )
        return conn
    except Exception as e:
        # 记录错误日志而非直接暴露给用户
        logging.error(f"Database connection failed: {str(e)}")
        return None

执行安全查询（防SQL注入）

// Java示例（JDBC预处理语句）
try (Connection conn = DriverManager.getConnection(DB_URL, DB_USER, DB_PASS)) {
    String sql = "SELECT * FROM users WHERE email = ?";  // 参数化查询
    PreparedStatement stmt = conn.prepareStatement(sql);
    stmt.setString(1, userInputEmail);  // 安全绑定参数
    ResultSet rs = stmt.executeQuery();
    while (rs.next()) {
        System.out.println(rs.getString("username"));
    }
} catch (SQLException e) {
    // 返回通用错误信息
    System.out.println("Query execution error");
}

处理查询结果

// Node.js示例（使用mysql2）
const mysql = require('mysql2/promise');
async function queryData() {
    const conn = await mysql.createConnection({
        host: 'localhost',
        user: 'secure_user',
        database: 'app_db',
        password: process.env.DB_PASS
    });
    try {
        const [rows] = await conn.execute(
            'SELECT id, name FROM products WHERE price > ?',
            [minPrice]  // 参数化变量
        );
        return rows;  // 返回结构化数据
    } finally {
        conn.end();  // 确保关闭连接
    }
}

错误处理与资源清理

如何快速上手SQL查询代码？第1张

// C#示例（ADO.NET）
using (SqlConnection conn = new SqlConnection(connString)) 
{
    await conn.OpenAsync();
    string sql = "SELECT COUNT(*) FROM orders WHERE status = @status";
    using (SqlCommand cmd = new SqlCommand(sql, conn)) 
    {
        cmd.Parameters.AddWithValue("@status", "completed");
        int count = (int)await cmd.ExecuteScalarAsync();
        return count;
    }  // 自动释放命令资源
}  // 自动关闭连接

关键安全实践（E-A-T核心）

参数化查询（非拼接SQL）
️ 禁止："SELECT * FROM users WHERE id = " + userInput
正确：使用 / @param 占位符
最小权限原则
数据库账号仅授予必要权限（如禁止DROP/ALTER）
连接池管理
生产环境需配置连接池（如HikariCP, Django CONN_MAX_AGE）
敏感信息保护
- 密码存储：使用Vault或KMS
- 配置文件：禁止提交至代码仓库
输出过滤
前端展示前对查询结果转义（防XSS）

各语言推荐库

语言	安全库	风险库（避免使用）
Python	`pymysql`, `psycopg3`	原生字符串拼接
PHP	`PDO`	`mysql_query()`
JavaScript	`mysql2/promise`	回调函数未转义
Java	`PreparedStatement`	`Statement`

常见破绽案例

//  高危SQL注入示例
$query = "SELECT * FROM accounts WHERE name = '$_GET[name]'";
// 攻击者输入：' OR '1'='1 将泄露所有数据
//  修复方案
$stmt = $pdo->prepare("SELECT * FROM accounts WHERE name = ?");
$stmt->execute([$_GET['name']]);

引用说明
本文遵循OWASP SQL注入防护指南（2025）及以下规范：