C# 数据操作系列 - 16 SqlSugar 完结篇

爱谁谁
发布: 2025-09-14 08:56:22
原创
632人浏览过
  1. 前言

在前一篇文章中,我们详细介绍了sqlsugar的增删改查操作,这些已经足以满足日常工程开发的需求。然而,还有一些在开发中不常用但非常有用的方法。接下来,让我们一起来看看还有哪些有趣的内容。

C# 数据操作系列 - 16 SqlSugar 完结篇

  1. 不同寻常的查询

之前我们介绍了针对单个表的查询,这些查询模式相对简单。虽然在开发中已经足够使用,但难免会遇到一些特殊情况。以下这些方法就是为了解决这些意料之外的情况。

1.1 多表查询

SqlSugar提供了一种特殊的多表查询方案,使用IQueryable接口。让我们看看如何操作:

ISugarQueryable<T, T2> Queryable<T, T2>(Expression<Func<T, T2, object[]>> joinExpression);
ISugarQueryable<T, T2> Queryable<T, T2>(ISugarQueryable<T> joinQueryable1, ISugarQueryable<T2> joinQueryable2, Expression<Func<T, T2, bool>> joinExpression) where T : class, new() where T2 : class, new();
ISugarQueryable<T, T2> Queryable<T, T2>(ISugarQueryable<T> joinQueryable1, ISugarQueryable<T2> joinQueryable2, JoinType joinType, Expression<Func<T, T2, bool>> joinExpression) where T : class, new() where T2 : class, new();
ISugarQueryable<T, T2> Queryable<T, T2>(Expression<Func<T, T2, bool>> joinExpression) where T : class, new();
登录后复制

这些方法属于SqlSugarClient类的方法,SqlSugar提供了最多12个泛型的方法支持,当然在实际开发中,遇到5个表的联查已经很少见。除非是在做报表程序,否则就需要审查一下数据表模型是否合理了。以下以这四个方法为例,介绍一下多表查询的使用方法:

首先,定义两个模型类:

public class Person
{
    [SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
    public int Id { get; set; }
    public string Name { get; set; }
    public int Age { get; set; }
}
<p>public class Employee
{
[SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
public int Id { get; set; }
public string Name { get; set; }
public int PersonId { get; set; }
[SugarColumn(IsIgnore = true)]
public Person Person { get; set; }
}
登录后复制

简单描述一下两个类的关系:一个雇员身份对应一个人,但一个人不一定会有一个雇员身份。

现在,从第一个方法开始介绍:

var query = context.Client.Queryable<Person, Employee>((pr, em) => new object[]
{
JoinType.Left,
em.PersonId == pr.Id
});
登录后复制

第一个返回值是两个表的连接方式,例如:Left代表左连接,Inner表示内连接,Right表示右连接;第二个返回值是两个表之间的连接依据。这是一个固定的形式,返回一个Object数组,其中第一个是连接方式,第二个是通过哪个(些)字段进行连接。

生成的SQL类似如下:

SELECT <pre class="brush:php;toolbar:false;">pr.<div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:php;toolbar:false;">Id
登录后复制
登录后复制
,
pr
登录后复制
.
Name
登录后复制
,
pr
登录后复制
.
Age
登录后复制
FROM
Person
登录后复制
pr Left JOIN
Employee
登录后复制
em ON (
em
登录后复制
.
PersonId
登录后复制
=
pr
登录后复制
.
Id
登录后复制
)

第二个方法:

var query = context.Client.Queryable(context.Client.Queryable<Person>(),
context.Client.Queryable<Employee>(),
(pr, em) => pr.Id == em.PersonId);
登录后复制

这个方法使用内连接连接两个表,最后一个参数用来指定两个表之间的连接字段。

生成的SQL类似如下:

SELECT  <pre class="brush:php;toolbar:false;">pr.<div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:php;toolbar:false;">Id
登录后复制
AS
Person.Id
登录后复制
,
pr
登录后复制
.
Name
登录后复制
AS
Person.Name
登录后复制
,
pr
登录后复制
.
Age
登录后复制
AS
Person.Age
登录后复制
,
em
登录后复制
.
Id
登录后复制
AS
Employee.Id
登录后复制
,
em
登录后复制
.
Name
登录后复制
AS
Employee.Name
登录后复制
,
em
登录后复制
.
PersonId
登录后复制
AS
Employee.PersonId
登录后复制
,
em
登录后复制
.
DeptId
登录后复制
AS
Employee.DeptId
登录后复制
FROM (SELECT
Id
登录后复制
,
Name
登录后复制
,
Age
登录后复制
FROM
Person
登录后复制
) pr Inner JOIN (SELECT
Id
登录后复制
,
Name
登录后复制
,
PersonId
登录后复制
,
DeptId
登录后复制
FROM
Employee
登录后复制
) em ON (
pr
登录后复制
.
Id
登录后复制
=
em
登录后复制
.
PersonId
登录后复制
)

第三个方法在第二个方法的基础上,可以指定连接方式:

var query = context.Client.Queryable(context.Client.Queryable<Person>(),
context.Client.Queryable<Employee>(),
JoinType.Left,
(pr, em) => pr.Id == em.PersonId);
登录后复制

最后一个方法:

var query = context.Client.Queryable<Person, Employee>((pr, em) => pr.Id == em.PersonId);
登录后复制

直接指定两个表之间的联系方式。

需要指出的是,所有的方法都只是返回了一个可查询对象,如果不进行后续的投影(进行select)则可能会提示主键冲突。而且,所有的方法在进行ToXXX之前都不会立即执行。

1.2 查询函数

SqlSugar添加了很多我们常用的方法,使其可以映射为sql语句。我们来看一下支持哪些内容:

public class SqlFunc
{
public static TResult AggregateAvg<TResult>(TResult thisValue);//针对这个列进行取平均数统计
public static int AggregateCount<TResult>(TResult thisValue);// 统计这个列数量 等价于 SQL里的 count(x)
public static int AggregateDistinctCount<TResult>(TResult thisValue);/ 返回去重之后的数量
public static TResult AggregateMax<TResult>(TResult thisValue);//返回最大值
public static TResult AggregateMin<TResult>(TResult thisValue);// 返回最小值
public static TResult AggregateSum<TResult>(TResult thisValue);// 返回总和
public static bool Between(object value, object start, object end);// 判断列的值是否在两个值之间
public static int CharIndex(string findChar, string searchValue);// SQL 的charindex
public static bool Contains(string thisValue, string parameterValue);// 是否包含
public static bool ContainsArray<T>(T[] thisValue, object InField);// 数组是否包含
public static bool ContainsArray<T>(List<T> thisValue, object InField);//列表是否包含
public static bool ContainsArrayUseSqlParameters<T>(List<T> thisValue, object InField);// 
public static bool ContainsArrayUseSqlParameters<T>(T[] thisValue, object InField);// 
public static DateTime DateAdd(DateTime date, int addValue, DateType dataType);// 时间添加
public static DateTime DateAdd(DateTime date, int addValue);// 日期添加
public static bool DateIsSame(DateTime date1, DateTime date2);// 时间是否相同
public static bool DateIsSame(DateTime? date1, DateTime? date2);//时间是否相同
public static bool DateIsSame(DateTime date1, DateTime date2, DateType dataType);//时间是否相同,根据DateType判断
public static int DateValue(DateTime date, DateType dataType);// 根据dateType, 返回具体的时间值
public static bool EndsWith(string thisValue, string parameterValue);//字符串是否以某些值结尾
public static bool Equals(object thisValue, object parameterValue);//是否相等
public static DateTime GetDate();//返回当前数据库时间
public static string GetRandom();// 
public static TResult GetSelfAndAutoFill<TResult>(TResult value);// 
public static bool HasNumber(object thisValue);//返回是否大于0,且不能为Null
public static bool HasValue(object thisValue);// 是否有值,且不为Null
public static CaseThen IF(bool condition);// sql 里的if判断
public static TResult IIF<TResult>(bool Expression, TResult thenValue, TResult elseValue);// case when
public static TResult IsNull<TResult>(TResult thisValue, TResult ifNullValue);// sql 里的 IsNull
public static bool IsNullOrEmpty(object thisValue);//判断是否是Null或者空
public static int Length(object value);//取长度
public static TResult MappingColumn<TResult>(TResult oldColumnName, string newColumnName);// 列名映射
public static string MergeString(string value1, string value2);
public static string MergeString(string value1, string value2, string value3, string value4);
public static string MergeString(string value1, string value2, string value3, string value4, string value5);
public static string MergeString(string value1, string value2, string value3, string value4, string value5, string value6);
public static string MergeString(string value1, string value2, string value3);
public static string MergeString(string value1, string value2, string value3, string value4, string value5, string value6, string value7);
public static string Replace(object value, string oldChar, string newChar);// 替换
public static bool StartsWith(string thisValue, string parameterValue);
public static Subqueryable<T> Subqueryable<T>() where T : class, new();
public static string Substring(object value, int index, int length);// 获取子串
public static bool ToBool(object value);//类型转换
public static DateTime ToDate(object value);// 类型转换
public static decimal ToDecimal(object value);// 类型转换
public static double ToDouble(object value);// 类型转换
public static Guid ToGuid(object value);// 类型转换
public static int ToInt32(object value);// 类型转换
public static long ToInt64(object value);// 类型转换
public static string ToLower(object thisValue);// 类型转换
public static string ToString(object value);// 类型转换
public static TimeSpan ToTime(object value);// 类型转换
public static string ToUpper(object thisValue);// 类型转换
public static string Trim(object thisValue);// 去除首尾的空格
}
登录后复制

这里的方法大多简单直接,我就不一一演示了。

1.3 动态查询

之前我们写的查询条件都是固定好的,至少在编程的时候就知道最终查询条件是什么了。但是在开发过程中,有时候并不会那么早的知道最终查询条件或者说查询需要根据用户输入来调整查询条件,那么如何实现呢?

常见的解决方案有以下几种:

  • 使用SQL语句,动态拼接SQL语句,然后根据SQL语句执行返回结果
  • 在使用Lambda表达式时,进行动态拼接Lambda表达式获取IQueryable接口,然后根据条件添加方法进行查询

这三种方法各有优略,使用查询接口会有一个明显的问题就是对应用层开放了更高的权限,使用SQL语句也是同样的道理。所以更符合逻辑的是使用动态拼接Lambda表达式。

当然,SqlSugar在这三种方案之上,提供了另外两种方案:

正是上一篇文中提到的IConditionalModel和WhereIF。我们先来看一下IConditionalModel如何使用:

千面数字人
千面数字人

千面 Avatar 系列:音频转换让静图随声动起来,动作模仿让动漫复刻真人动作,操作简单,满足多元创意需求。

千面数字人 156
查看详情 千面数字人
var conditions = new List<IConditionalModel>();
var query = context.Client.Queryable<Person>().Where(conditions);
登录后复制

可以在Where中传入IConditionModel类型。SqlSugar提供了两个受支持的实现类:

public class ConditionalCollections : IConditionalModel
{
public ConditionalCollections();
public List<KeyValuePair<WhereType, ConditionalModel>> ConditionalList { get; set; }
}</p><p>public class ConditionalModel : IConditionalModel
{
public ConditionalModel();
public string FieldName { get; set; }
public string FieldValue { get; set; }
public ConditionalType ConditionalType { get; set; }
public Func<string, object> FieldValueConvertFunc { get; set; }
}
登录后复制

对于一个集合里的兄弟 ConditionModel,表示查询条件都是 and 关系。而ConditionCollections则不同,其中ConditionList表示是一个键值对集合。键是WhereType类型,ConditionModel是值。我们先说说 WhereType:

public enum WhereType
{
And = 0,
Or = 1
}
登录后复制

分别表示And,Or。怎样理解呢?就是说,这一条键值对与前一个关系模型是And还是Or。

看一下示例:

// and id=100 and (id=1 or id=2 and id=1)
conModels.Add(new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "100" });
conModels.Add(new ConditionalCollections() { ConditionalList=new List<KeyValuePair<WhereType, ConditionalModel>>()
{
new  KeyValuePair<WhereType, ConditionalModel>
( WhereType.And ,
new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "1" }),
new  KeyValuePair<WhereType, ConditionalModel>
(WhereType.Or,
new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "2" }),
new  KeyValuePair<WhereType, ConditionalModel>
( WhereType.And,
new ConditionalModel() { FieldName = "id", ConditionalType = ConditionalType.Equal, FieldValue = "2" })
}});
var student = db.Queryable<Student>().Where(conModels).ToList();
登录后复制

继续看一下WhereIF,WhereIF的使用就相对简单一点:

ISugarQueryable<T> WhereIF(bool isWhere, Expression<Func<T, bool>> expression);
登录后复制

示例代码:

var query = context.Client.Queryable<Person>().WhereIF(string.IsNullOrEmpty(input), p => p.Age > 10);
登录后复制

理解起来也很容易,第一个参数如果结果为False,则不执行后续的查询,否则就执行。

  1. 一些高级玩法

除了增删改查,SqlSugar还提供了一些别的有意思的机制,继续我们的探索吧。

2.1 批量操作

SqlSugar提供了一种一次性记录很多操作然后统一提交执行的模式,之前的操作都是仅支持批量插入、批量修改、批量删除。在这种模式下,SqlSugar还支持了批量(插入、修改、删除)。也就是说,在一个批处理中,即可以插入也可以修改还可以删除。

那么我们来看如何让这个功能为我们所用吧:

void AddQueue();
登录后复制

在IDeleteable、IInsertable、IUpdateable、ISugarQueryable都有这个方法,一旦调用这个方法就表示该条指令进行缓存不立即执行,直到调用SqlSugarClient.SaveQueues()。通过调用SaveQueues()保存到数据库中。

值得注意的是:

2.2 事务

SQL本身支持事务,大多数ORM都支持事务,SqlSugar也不例外。SqlSugar通过哪些方法来自己实现一个事务呢?

在SqlSugarClient中执行:

public void BeginTran();
登录后复制

会将SqlSugarClient做一个事务标记,表示之后的操作都是在事务中,直到事务提交或者回滚。

在SimpleClient中执行:

public ITenant AsTenant();
登录后复制

返回一个ITenant实例,然后通过这个实例提交事务或者回滚事务。

2.3 原生SQL执行

SqlSugar在很多地方都添加了原生Sql的支持。

比如说通过如下这种方式,可以使用Sql语句进行查询:

var t12 = context.Client.SqlQueryable<Student>("select * from student").Where(it => it.id > 0).ToPageList(1, 2);
登录后复制

通过以下这种方式,执行SQL:

context.Client.Ado.ExecuteCommand(sql, parameters)
登录后复制

然后,通过以下方式执行存储过程:

context.Client.Ado.UseStoredProcedure()
登录后复制
  1. 总结

优秀的ORM总是有各种各样的方案,也有各种各样的优点。SqlSugar到目前为止,可以告一段落了。当然,我还是剩下了一部分,留给大伙自己去探索挖掘。接下来,我将以Dapper作为《C# 数据操作系列》的最后内容。之后将会以项目的形式,带领大家去了解并学习asp.net core。

以上就是C# 数据操作系列 - 16 SqlSugar 完结篇的详细内容,更多请关注php中文网其它相关文章!

最佳 Windows 性能的顶级免费优化软件
最佳 Windows 性能的顶级免费优化软件

每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。

下载
来源:php中文网
收藏 点赞
上一篇:Win10电脑分屏功能怎么关闭?Win10电脑分屏功能的关闭方法 下一篇:电脑不识别u盘怎么办?
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
作者最新文章
最新问题
相关专题
更多>
热门推荐
开源免费商场系统广告
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新 English
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号