首页
/ FreeSql 动态查询条件转换为 SQL 语句的实现方案

FreeSql 动态查询条件转换为 SQL 语句的实现方案

2025-06-15 21:55:37作者:董斯意

背景介绍

在使用 FreeSql 进行数据库操作时,我们经常会遇到需要根据前端传入的动态条件构建 SQL 查询语句的需求。FreeSql 提供了 DynamicFilterInfo 类型来表示动态查询条件,但在直接执行原生 SQL 时,无法直接使用 WhereDynamicFilter 方法。本文将介绍如何将 DynamicFilterInfo 转换为 SQL 条件语句的完整解决方案。

核心实现思路

实现动态查询条件转换为 SQL 语句的核心思路是递归解析 DynamicFilterInfo 结构,并根据不同的操作符生成对应的 SQL 条件表达式。同时需要考虑参数化查询,防止 SQL 注入。

完整实现代码

以下是完整的实现代码,包含查询条件生成、参数处理以及排序条件生成等功能:

public class QueryHelper
{
    public static (string, Dictionary<string, object>, string) GenerateWhereString(DynamicFilterInfo filterInfo)
    {
        string order = "Id desc";
        var lstValues = new Dictionary<string, object>();
        int index = 0;
        var whereClause = GenerateWhereClause(filterInfo, ref index);

        filterInfo.Travel((filterInfo) => lstValues.Add(lstValues.Count.ToString(), GetValue(filterInfo)));
        return (whereClause, lstValues, order);
    }

    public static string GenerateOrder(QueryCondition queryCondition)
    {
        string order = "Id desc";
        if (queryCondition.sort.Count > 0)
        {
            order = string.Empty;
            foreach (var item in queryCondition.sort)
            {
                order += $"{item.field} {item.order},";
            }
            order = order.Trim(',');
        }
        return order;
    }

    static bool isArray = false;
    static DateTime[] dates;
    static bool isDate1 = false;

    protected static string GenerateWhereClause(DynamicFilterInfo filterInfo, ref int index)
    {
        var lstConditions = new List<string>();

        if (filterInfo.Value != null && filterInfo.Value.ToString().Trim() != string.Empty)
        {
            if (filterInfo.Value.GetType() == typeof(JArray))
            {
                isArray = true;
                dates = Newtonsoft.Json.JsonConvert.DeserializeObject<DateTime[]>(filterInfo.Value.ToString());
                isDate1 = true;
                lstConditions.Add(ConvertToCondition(filterInfo, index++));
            }
            isArray = false;
            lstConditions.Add(ConvertToCondition(filterInfo, index++));            
        }
        
        if (filterInfo.Filters != null && filterInfo.Filters.Count > 0)
        {
            foreach (var subGroup in filterInfo.Filters)
            {
                if (subGroup.Value != null && subGroup.Value.ToString().Trim() != string.Empty)
                {
                    lstConditions.Add(GenerateWhereClause(subGroup, ref index));
                }
            }
        }

        return $"({lstConditions.JoinAsString(filterInfo.Logic.ToString().ToLower() == "and" ? " and " : " or ")})";
    }

    protected static string ConvertToCondition(DynamicFilterInfo condition, int index)
    {
        string left = GetLeft(condition, index);
        string right = GetRight(condition, index);
        
        switch (condition.Operator.ToString().ToLower())
        {
            case "equals":
            case "equal":
            case "eq":
            case "=":
            case "==":
                return $"{left} = {right}";
            case "<>":
            case "!=":
            case "notequal":
                return $"{left} <> {right}";
            case "greater":
            case "greaterthan":
            case ">":
                return $"{left} > {right}";
            case "greaterorequal":
            case "greaterthanorequal":
            case ">=":
                return $"{left} >= {right}";
            case "less":
            case "lessthan":
            case "<":
                return $"{left} < {right}";
            case "lessorequal":
            case "lessthanorequal":
            case "<=":
                return $"{left} <= {right}";
            case "startwith":
                return $"{left} like {right}";
            case "notstartwith":
                return $"{left} not like {right}";
            case "endwith":
                return $"{left} like {right}";
            case "notendwith":
                return $"{left} not like {right}";
            case "contain":
            case "contains":
            case "like":
                return $"{left} like {right}";
            case "notcontains":
                return $"{left} not like {right}";
            case "range":
                return $"{left} in({right})";
            case "daterange":
                if (isArray)
                {
                    return $"{left} >={right}";
                }
                else
                {
                    return $"{left} <={right}";
                }
            case "in":
            case "any":
                return $"{left} in({right})";
            case "notany":
            case "notcontain":
                return $"{left} not in({right})";
            default:
                throw new InvalidOperationException($"Unknown dynamic query operator: {condition.Operator}");
        }
    }

    protected static object GetValue(DynamicFilterInfo condition)
    {
        switch (condition.Operator.ToString().ToLower())
        {
            case "startwith":
            case "notstartwith":
                return $"{condition.Value}%";
            case "endwith":
            case "notendwith":
                return $"%{condition.Value}";
            case "contain":
            case "contains":
            case "like":              
            case "notcontains":
                return $"%{condition.Value}%";
            case "daterange":
                if (isDate1)
                {
                    isDate1 = false;
                    return dates[0];
                }
                else
                {
                    return dates[1];
                }
            default:
                return condition.Value;
        }
    }

    protected static string GetLeft(DynamicFilterInfo condition, int index)
    {
        return condition.Field;
    }

    protected static string GetRight(DynamicFilterInfo condition, int index)
    {
        return $"@{index}";
    }
}

public static class FilterExtensions
{
    public static void Travel(this DynamicFilterInfo dynamicFilterInfo, Action<DynamicFilterInfo> conditionAction)
    {
        if (dynamicFilterInfo.Value != null && dynamicFilterInfo.Value.ToString().Trim() != string.Empty)
        {
            if (dynamicFilterInfo.Value.GetType() == typeof(JArray))
            {
                conditionAction(dynamicFilterInfo);
            }
            conditionAction(dynamicFilterInfo);
        }
        
        if (dynamicFilterInfo.Filters != null && dynamicFilterInfo.Filters.Count > 0)
        {
            foreach (var subGroup in dynamicFilterInfo.Filters)
            {
                Travel(subGroup, conditionAction);
            }
        }
    }

    public static string JoinAsString<T>(this IEnumerable<T> source, string separator)
    {
        return string.Join(separator, source);
    }
}

使用示例

var (predicate, args, order) = QueryHelper.GenerateWhereString(search.FilterInfo);
var sql = "select * from table"; // 你的SQL语句

if (args.Count > 0)
{
    if (sql.IndexOf("where", StringComparison.OrdinalIgnoreCase) > 0)
    {
        sql = sql + predicate;
    }
    else
    {
        sql = $"{sql} where {predicate}";
    }
    
    DbParameter[] cmdParms = _reportRepository.FreeSql.Ado.GetDbParamtersByObject(args);
    var cmdType = System.Data.CommandType.Text;
    var dynamics = _reportRepository.FreeSql.Ado.Query<dynamic>(cmdType, sql, cmdParms);
}

实现解析

  1. 递归解析查询条件GenerateWhereClause 方法递归遍历 DynamicFilterInfo 结构,处理嵌套的查询条件。

  2. 操作符转换ConvertToCondition 方法将各种操作符(如 equals、contains 等)转换为对应的 SQL 表达式。

  3. 参数处理GetValue 方法根据不同的操作符对参数值进行适当处理,例如为 like 查询添加 % 通配符。

  4. 日期范围处理:特别处理了日期范围查询,支持数组形式的日期范围参数。

  5. 扩展方法FilterExtensions 提供了遍历 DynamicFilterInfo 的扩展方法,方便收集所有参数值。

注意事项

  1. 此实现支持大多数常见的查询操作符,但可能需要根据实际需求进行扩展。

  2. 对于复杂的嵌套查询条件,确保逻辑运算符(AND/OR)的正确应用。

  3. 日期范围查询需要特殊处理,确保传入的参数是有效的日期数组。

  4. 使用参数化查询可以有效防止 SQL 注入攻击。

总结

通过上述实现,我们可以轻松地将 FreeSql 的动态查询条件转换为原生 SQL 语句,同时保持参数化查询的安全性。这种方法特别适用于需要直接执行原生 SQL 但又希望利用 FreeSql 动态查询功能的场景。开发者可以根据实际需求对代码进行扩展和优化,以适应更复杂的查询需求。

登录后查看全文
热门项目推荐

项目优选

收起
openHiTLS-examplesopenHiTLS-examples
本仓将为广大高校开发者提供开源实践和创新开发平台,收集和展示openHiTLS示例代码及创新应用,欢迎大家投稿,让全世界看到您的精巧密码实现设计,也让更多人通过您的优秀成果,理解、喜爱上密码技术。
C
47
253
openHiTLSopenHiTLS
旨在打造算法先进、性能卓越、高效敏捷、安全可靠的密码套件,通过轻量级、可剪裁的软件技术架构满足各行业不同场景的多样化要求,让密码技术应用更简单,同时探索后量子等先进算法创新实践,构建密码前沿技术底座!
C
347
381
RuoYi-Vue3RuoYi-Vue3
🎉 (RuoYi)官方仓库 基于SpringBoot,Spring Security,JWT,Vue3 & Vite、Element Plus 的前后端分离权限管理系统
Vue
871
516
ohos_react_nativeohos_react_native
React Native鸿蒙化仓库
C++
179
263
openGauss-serveropenGauss-server
openGauss kernel ~ openGauss is an open source relational database management system
C++
131
184
kernelkernel
deepin linux kernel
C
22
5
nop-entropynop-entropy
Nop Platform 2.0是基于可逆计算理论实现的采用面向语言编程范式的新一代低代码开发平台,包含基于全新原理从零开始研发的GraphQL引擎、ORM引擎、工作流引擎、报表引擎、规则引擎、批处理引引擎等完整设计。nop-entropy是它的后端部分,采用java语言实现,可选择集成Spring框架或者Quarkus框架。中小企业可以免费商用
Java
7
0
Cangjie-ExamplesCangjie-Examples
本仓将收集和展示高质量的仓颉示例代码,欢迎大家投稿,让全世界看到您的妙趣设计,也让更多人通过您的编码理解和喜爱仓颉语言。
Cangjie
335
1.09 K
harmony-utilsharmony-utils
harmony-utils 一款功能丰富且极易上手的HarmonyOS工具库,借助众多实用工具类,致力于助力开发者迅速构建鸿蒙应用。其封装的工具涵盖了APP、设备、屏幕、授权、通知、线程间通信、弹框、吐司、生物认证、用户首选项、拍照、相册、扫码、文件、日志,异常捕获、字符、字符串、数字、集合、日期、随机、base64、加密、解密、JSON等一系列的功能和操作,能够满足各种不同的开发需求。
ArkTS
31
0
CangjieCommunityCangjieCommunity
为仓颉编程语言开发者打造活跃、开放、高质量的社区环境
Markdown
1.08 K
0