当前位置：首页 > news >正文

SQL进阶之旅 Day 15：动态SQL与条件查询构建

news 来源：原创 2025/6/6 18:05:03

【SQL进阶之旅 Day 15】动态SQL与条件查询构建

开篇

欢迎来到“SQL进阶之旅”系列的第15天！今天我们将深入探讨动态SQL与条件查询构建这一重要主题。动态SQL是后端开发和数据库工程师在解决复杂业务需求时的利器，它能够根据运行时的输入参数灵活生成查询语句，从而满足多样化的数据处理需求。无论是在报表系统、搜索功能还是复杂的业务逻辑中，动态SQL都发挥着不可替代的作用。

本篇文章将从理论基础入手，逐步深入到实际应用场景，并结合完整代码示例和性能测试，为你提供全面的学习体验。

理论基础

动态SQL是指在运行时根据用户输入或外部条件动态生成SQL查询语句的技术。它通常用于以下场景：

查询条件不固定（如多条件搜索）
动态生成表名或列名
分页查询或其他需要动态调整的SQL逻辑

动态SQL的核心实现方式包括字符串拼接和使用预编译语句（Prepared Statements）。下面分别介绍两种方式的工作原理。

字符串拼接

字符串拼接是最直接的方式，但存在SQL注入风险，例如：

-- 示例：危险的字符串拼接
DECLARE @sql NVARCHAR(MAX);
SET @sql = 'SELECT * FROM users WHERE username = ''' + @username + ''';';
EXEC(@sql);

这种方式虽然简单，但在生产环境中应尽量避免。

预编译语句

预编译语句通过占位符（如?或:param）来安全地传递参数，有效防止SQL注入。以下是PostgreSQL中的一个例子：

DO $$
DECLAREquery TEXT;condition TEXT := 'age > 20';
BEGINquery := 'SELECT * FROM users WHERE ' || condition || ' AND active = TRUE';EXECUTE query;
END $$;

适用场景

动态SQL最常见的应用场景包括：

多条件搜索：电商平台的商品筛选功能，用户可以根据品牌、价格区间、评分等条件自由组合搜索。
动态报表生成：根据用户选择的时间范围、指标字段等生成不同的报表。
权限控制：根据用户角色动态调整可查询的数据范围。

下面我们以一个多条件商品搜索为例，展示动态SQL的实际应用。

代码实践

假设我们有一个商品表products，结构如下：

CREATE TABLE products (id SERIAL PRIMARY KEY,name VARCHAR(255),brand VARCHAR(100),price DECIMAL(10, 2),rating INT,stock INT
);-- 插入测试数据
INSERT INTO products (name, brand, price, rating, stock)
VALUES
('Laptop', 'BrandA', 1200.00, 5, 100),
('Smartphone', 'BrandB', 800.00, 4, 50),
('Tablet', 'BrandC', 300.00, 3, 75);

我们需要实现一个多条件搜索功能，允许用户按品牌、价格区间、评分进行筛选。

实现方式1：字符串拼接

-- 示例：字符串拼接实现动态SQL
DO $$
DECLAREsql_query TEXT;brand_filter TEXT := 'BrandA';min_price NUMERIC := 500;max_price NUMERIC := 1500;min_rating INT := 4;
BEGINsql_query := 'SELECT * FROM products WHERE 1=1';IF brand_filter IS NOT NULL THENsql_query := sql_query || ' AND brand = ''' || brand_filter || '''';END IF;IF min_price IS NOT NULL THENsql_query := sql_query || ' AND price >= ' || min_price::TEXT;END IF;IF max_price IS NOT NULL THENsql_query := sql_query || ' AND price <= ' || max_price::TEXT;END IF;IF min_rating IS NOT NULL THENsql_query := sql_query || ' AND rating >= ' || min_rating::TEXT;END IF;EXECUTE sql_query;
END $$;

实现方式2：预编译语句

-- 示例：使用预编译语句实现动态SQL
DO $$
DECLAREsql_query TEXT := 'SELECT * FROM products WHERE 1=1';params TEXT[] := ARRAY[];brand_filter TEXT := 'BrandA';min_price NUMERIC := 500;max_price NUMERIC := 1500;min_rating INT := 4;
BEGINIF brand_filter IS NOT NULL THENsql_query := sql_query || ' AND brand = $' || array_length(params, 1) + 1;params := array_append(params, brand_filter);END IF;IF min_price IS NOT NULL THENsql_query := sql_query || ' AND price >= $' || array_length(params, 1) + 1;params := array_append(params, min_price::TEXT);END IF;IF max_price IS NOT NULL THENsql_query := sql_query || ' AND price <= $' || array_length(params, 1) + 1;params := array_append(params, max_price::TEXT);END IF;IF min_rating IS NOT NULL THENsql_query := sql_query || ' AND rating >= $' || array_length(params, 1) + 1;params := array_append(params, min_rating::TEXT);END IF;EXECUTE sql_query USING unnest(params);
END $$;