EF5.x Code First 一对多关联条件查询,Contains,Any,All

背景

通过多个部门id获取所有用户，部门和用户是多对多。

已知部门id，获取该部门包括该部门下的所有子部门的所有用户。

关系如下：

public class Entity:IEntity{public Guid Id { get; set; }public string CreateUser { get; set; }public DateTime CreateTime { get; set; }public string ModifyUser { get; set; }public DateTime? ModifyTime { get; set; }[Timestamp]public Byte[] RowVersion { get; set; }}
//组织架构
public class WMS_Org : Entity{public WMS_Org() { }public string OrgName { get; set; }public string OrgDesc { get; set; }public int OrgOrder { get; set; }public string OrgFatherId { get; set; }public virtual ICollection<WMS_OrgUser> OrgUserIds { get; set; }}
//用户public class WMS_User : Entity{public WMS_User() { }public string UserName { get; set; }public string NickName { get; set; }public string UserPwd { get; set; }public string Sex { get; set; }public string Phone { get; set; }public string Email { get; set; }public string QQ { get; set; }public string Address { get; set; }public string Remark { get; set; }public virtual ICollection<WMS_OrgUser> UserOrgIds { get; set; }}
//组织架构和用户的关联
public class WMS_OrgUser : Entity{public WMS_OrgUser() { }public Guid OrgId { get; set; }[ForeignKey("OrgId")]public virtual WMS_Org Org { get; set; }public Guid UserId { get; set; }[ForeignKey("UserId")]public virtual WMS_User User { get; set; }}
已知组织的id

如上图，我单击0100组织架构，要获取该组织架构下的所有用户，首先由于用户是挂载到每个节点上的，所有需要事先遍历获取所有的子节点获取节点的id

放到Guid[]数组里

提交后台查询
//DBSET=DbSet<WMS_User>，ids=Guid[] ids参数
//第一种方式All
DBSET.Where(p => p.UserOrgIds.All(o=>ids.Contains(o.OrgId)));//第二种方式Any
DBSET.Where(p => p.UserOrgIds.Any(o=>ids.Contains(o.OrgId)));

注意EF采用Contains构造in的sql语句

很直观的可以看出两个区别，一个是All，一个Any，那么产生的sql有什么区别呢？

//All，EF产生的是inner Join
SELECT 
[Extent1].[Id] AS [Id], 
[Extent1].[UserName] AS [UserName], 
[Extent1].[NickName] AS [NickName], 
[Extent1].[UserPwd] AS [UserPwd], 
[Extent1].[Sex] AS [Sex], 
[Extent1].[Phone] AS [Phone], 
[Extent1].[Email] AS [Email], 
[Extent1].[QQ] AS [QQ], 
[Extent1].[Address] AS [Address], 
[Extent1].[Remark] AS [Remark], 
[Extent1].[Disable] AS [Disable], 
[Extent1].[CreateUser] AS [CreateUser], 
[Extent1].[CreateTime] AS [CreateTime], 
[Extent1].[ModifyUser] AS [ModifyUser], 
[Extent1].[ModifyTime] AS [ModifyTime], 
[Extent1].[RowVersion] AS [RowVersion]
FROM [dbo].[WMS_User] AS [Extent1]
WHERE NOT EXISTS (
SELECT 1 AS [C1]
FROM [dbo].[WMS_OrgUser] AS [Extent2]
WHERE ([Extent1].[Id] = [Extent2].[UserId])
AND (
(
NOT (
[Extent2].[OrgId] IN (CAST('4e108b91-be3c-4cf4-a074-3767b9b8c7dc' AS UNIQUEIDENTIFIER), 
CAST('1cc15f8c-3758-47d3-862a-5287ab5d0651' AS UNIQUEIDENTIFIER), 
CAST('e1bf6f5a-800a-4fd4-9309-576c1d84ba2f' AS UNIQUEIDENTIFIER), 
CAST('a436b8a9-4b3a-4bf9-bbdd-839571e03915' AS UNIQUEIDENTIFIER), 
CAST('b0d6aead-e72f-4fd5-b2cd-e575454d3a4c' AS UNIQUEIDENTIFIER))
)
)
OR (
CASE 
WHEN (
[Extent2].[OrgId] IN (
CAST('4e108b91-be3c-4cf4-a074-3767b9b8c7dc' AS UNIQUEIDENTIFIER), 
CAST('1cc15f8c-3758-47d3-862a-5287ab5d0651' AS UNIQUEIDENTIFIER), 
CAST('e1bf6f5a-800a-4fd4-9309-576c1d84ba2f' AS UNIQUEIDENTIFIER), 
CAST('a436b8a9-4b3a-4bf9-bbdd-839571e03915' AS UNIQUEIDENTIFIER), 
CAST('b0d6aead-e72f-4fd5-b2cd-e575454d3a4c' AS UNIQUEIDENTIFIER))
) THEN CAST(1 AS BIT)
WHEN (
NOT (
[Extent2].[OrgId] IN (
CAST('4e108b91-be3c-4cf4-a074-3767b9b8c7dc' AS UNIQUEIDENTIFIER), 
CAST('1cc15f8c-3758-47d3-862a-5287ab5d0651' AS UNIQUEIDENTIFIER), 
CAST('e1bf6f5a-800a-4fd4-9309-576c1d84ba2f' AS UNIQUEIDENTIFIER), 
CAST('a436b8a9-4b3a-4bf9-bbdd-839571e03915' AS UNIQUEIDENTIFIER), 
CAST('b0d6aead-e72f-4fd5-b2cd-e575454d3a4c' AS UNIQUEIDENTIFIER))
)
) THEN CAST(0 AS BIT)
END IS NULL
)
)
)
//Any方式,EF生成的Exists
SELECT 
[Extent1].[Id] AS [Id], 
[Extent1].[UserName] AS [UserName], 
[Extent1].[NickName] AS [NickName], 
[Extent1].[UserPwd] AS [UserPwd], 
[Extent1].[Sex] AS [Sex], 
[Extent1].[Phone] AS [Phone], 
[Extent1].[Email] AS [Email], 
[Extent1].[QQ] AS [QQ], 
[Extent1].[Address] AS [Address], 
[Extent1].[Remark] AS [Remark], 
[Extent1].[CreateUser] AS [CreateUser], 
[Extent1].[CreateTime] AS [CreateTime], 
[Extent1].[ModifyUser] AS [ModifyUser], 
[Extent1].[ModifyTime] AS [ModifyTime], 
[Extent1].[RowVersion] AS [RowVersion]
FROM [dbo].[WMS_User] AS [Extent1]
WHERE  EXISTS (SELECT 1 AS [C1]FROM [dbo].[WMS_OrgUser] AS [Extent2]WHERE ([Extent1].[Id] = [Extent2].[UserId]) AND ([Extent2].[OrgId] IN (cast('bd3c010c-476f-45e6-8d83-ad741cc55309' as uniqueidentifier),cast('4e108b91-be3c-4cf4-a074-3767b9b8c7dc' as uniqueidentifier),cast('1cc15f8c-3758-47d3-862a-5287ab5d0651' as uniqueidentifier),cast('e1bf6f5a-800a-4fd4-9309-576c1d84ba2f' as uniqueidentifier),cast('a436b8a9-4b3a-4bf9-bbdd-839571e03915' as uniqueidentifier),cast('b0d6aead-e72f-4fd5-b2cd-e575454d3a4c' as uniqueidentifier),cast('79ddb55a-1587-4928-a312-58da0c091459' as uniqueidentifier),cast('618de87e-2d97-4c0a-b6c1-acd072c305e2' as uniqueidentifier)))
)

也就是说All是包括条件和不在条件之内的任何值，而Any是严格在条件之内的值，但其实我们想要的是Inner Join的方式，相当于是懒加载方式，那么需要加上Include，也就是

IQueryable<WMS_OrgUser> test5 = _db.wmsOrgUser.Include("User").Where(p => ids.Contains(p.OrgId));
SELECT 
1 AS [C1], 
[Extent1].[Id] AS [Id], 
[Extent1].[OrgId] AS [OrgId], 
[Extent1].[UserId] AS [UserId], 
[Extent1].[CreateUser] AS [CreateUser], 
[Extent1].[CreateTime] AS [CreateTime], 
[Extent1].[ModifyUser] AS [ModifyUser], 
[Extent1].[ModifyTime] AS [ModifyTime], 
[Extent1].[RowVersion] AS [RowVersion], 
[Extent2].[Id] AS [Id1], 
[Extent2].[UserName] AS [UserName], 
[Extent2].[NickName] AS [NickName], 
[Extent2].[UserPwd] AS [UserPwd], 
[Extent2].[Sex] AS [Sex], 
[Extent2].[Phone] AS [Phone], 
[Extent2].[Email] AS [Email], 
[Extent2].[QQ] AS [QQ], 
[Extent2].[Address] AS [Address], 
[Extent2].[Remark] AS [Remark], 
[Extent2].[Disable] AS [Disable], 
[Extent2].[CreateUser] AS [CreateUser1], 
[Extent2].[CreateTime] AS [CreateTime1], 
[Extent2].[ModifyUser] AS [ModifyUser1], 
[Extent2].[ModifyTime] AS [ModifyTime1], 
[Extent2].[RowVersion] AS [RowVersion1]
FROM  [dbo].[WMS_OrgUser] AS [Extent1]
INNER JOIN [dbo].[WMS_User] AS [Extent2] ON [Extent1].[UserId] = [Extent2].[Id]
WHERE [Extent1].[OrgId] IN (cast('4e108b91-be3c-4cf4-a074-3767b9b8c7dc' as uniqueidentifier),cast('1cc15f8c-3758-47d3-862a-5287ab5d0651' as uniqueidentifier),cast('e1bf6f5a-800a-4fd4-9309-576c1d84ba2f' as uniqueidentifier),cast('a436b8a9-4b3a-4bf9-bbdd-839571e03915' as uniqueidentifier),cast('b0d6aead-e72f-4fd5-b2cd-e575454d3a4c' as uniqueidentifier)
)

　　

条件关联查询，并实现分页
var list = dal.FindByPage(start, pageSize, u => u.OrderByDescending(c => c.CreateTime), u => u.UserOrgIds.All(o => ids.Contains(o.OrgId)), out total);//防止转json时候嵌套异常var result = from f in listselect new{Id = f.Id,UserName = f.UserName,Address = f.Address,Email = f.Email,Sex = f.Sex,CreateUser = f.CreateUser,CreateTime = f.CreateTime,NickName = f.NickName,Phone = f.Phone,QQ = f.QQ,Remark = f.Remark,UserPwd = f.UserPwd};return result;

 

 public virtual IEnumerable<T> FindByPage(int startIndex, int pageSize, Func<IQueryable<T>, IOrderedQueryable<T>> order, Expression<Func<T, bool>> filters, out int Total){try{IQueryable<T> rs = order(DBSET.Where(filters));Total = rs.Count();if (startIndex < 0 || pageSize < 1){return null;// rs.ToList();
                }else{return rs.Skip(startIndex * pageSize).Take(pageSize).ToList();}}catch (Exception e){Total = 0;log.Error("FindByPage:" + order.ToString() + " " + filters.ToString() + " " + e.Message);return null;}}

 

 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/402660.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Spring5：@Autowired注解、@Resource注解和@Service注解

Spring5：@Autowired注解、@Resource注解和@Service注解

From: https://www.cnblogs.com/szlbm/p/5512931.html 什么是注解 传统的Spring做法是使用.xml文件来对bean进行注入或者是配置aop、事物&#xff0c;这么做有两个缺点&#xff1a; 1、如果所有的内容都配置在.xml文件中&#xff0c;那么.xml文件将会十分庞大&#xff1b;如…
阅读更多...
C#通过SSH连接MySql

C#通过SSH连接MySql

出于安全考虑&#xff0c;有的时候数据库服务器只能通过SSH访问&#xff0c;比如MySql服务装在了服务器A上&#xff0c;并且A机器只允许B机器才能访问&#xff0c;而部署环境可能在C机器上&#xff0c;这时候就要C服务器通过B服务器连接A服务器&#xff0c;这时候就需要用到SSH…
阅读更多...
CCNA实验(8) -- PPP HDLC

CCNA实验(8) -- PPP HDLC

HDLC帧格式与以太帧格式有很大差别&#xff0c;HDLC帧没有源MAC和目的MAC地址。HDLC不能提供验证&#xff0c;缺少对链路保护。Cisco设备与Cisco设备连接&#xff0c;可用HDLC封装。Cisco设备与非Cisco设备连接&#xff0c;应使用PPP协议。PPP经过4个过程在点到点链路上建立连接…
阅读更多...
Spring Boot实战：数据库操作

Spring Boot实战：数据库操作

From: https://www.cnblogs.com/paddix/p/8178943.html 上篇文章中已经通过一个简单的HelloWorld程序讲解了Spring boot的基本原理和使用。本文主要讲解如何通过spring boot来访问数据库&#xff0c;本文会演示三种方式来访问数据库&#xff0c;第一种是JdbcTemplate&#xff0…
阅读更多...
PDB调试Python程序

PDB调试Python程序

pdb是python内置的调试工具, 它可以在终端中调试Python程序, 这允许pdb在很多无法安装IDE的服务器上使用. 虽然远程调试使用广泛, 但在必要的时候&#xff08;比如难以在本地搭建运行环境&#xff09;pdb仍然是一个便利的选择. 我们可以在python源代码中设置断点&#xff1a; i…
阅读更多...
不使用中间变量交换2个数据

不使用中间变量交换2个数据

2019独角兽企业重金招聘Python工程师标准>>> 第一种方法&#xff1a; <!-- lang: cpp -->aab;ba-b;aa-b;可能产生越界和溢出。 第二种方法&#xff1a; <!-- lang: cpp -->aa^b;ba^b;aa^b;这种方法只适用整形数。 写成宏的形式 <!-- lang: cpp -->…
阅读更多...
slf4j的简单用法以及与log4j的区别

slf4j的简单用法以及与log4j的区别

From: https://www.cnblogs.com/qlqwjy/p/9275415.html 之前在项目中用的日志记录器都是log4j的日志记录器&#xff0c;可是到了新公司发现都是slf4j&#xff0c;于是想着研究一下slf4j的用法。 注意:每次引入Logger的时候注意引入的jar包&#xff0c;因为有Logger的包太多了。…
阅读更多...
PS不能存储，因为程序错误

PS不能存储，因为程序错误

当PS中遇到不能存储文件&#xff0c;因为程序错误时&#xff0c;可以这样&#xff1a; http://www.zcool.com.cn/article/ZMTgwOTQw.html 转载于:https://www.cnblogs.com/kjcy8/p/6072599.html
阅读更多...
MEF相关总结

MEF相关总结

&#xff08;1&#xff09;蛮好的一篇文章&#xff1a;LoveJenny的MEF 打造的插件系统 一个简单单很能容易理解的例子讲解了MEF. &#xff08;2&#xff09;原理方面的看Bēniaǒ成长笔记的《MEF程序设计指南》博文汇总 &#xff08;3&#xff09;http://www.cnblogs.com/pszw/…
阅读更多...
JdbcType类型和Java类型的对应关系

JdbcType类型和Java类型的对应关系

From: https://www.cnblogs.com/tongxuping/p/7134113.html 在Oracle中有些字段不是必填时在用户使用的时候会出现数据null的情况。这个时候在Oracle中是无法进行插入的。 1 JDBC Type Java Type 2 CHAR String 3 VARCHAR String 4 L…
阅读更多...
MyBatis Generator配置文件翻译

MyBatis Generator配置文件翻译

From: https://www.cnblogs.com/GaiDynasty/p/4088531.html <classPathEntry> 驱动文件指定配置项 <classPathEntry location"/Program Files/IBM/SQLLIB/java/db2java.zip" /> <columnOverride> 将数据库中的字段重命名为实体类的属性 colu…
阅读更多...
java实现计算字符串表达式

java实现计算字符串表达式

ScriptEngineManager manager new ScriptEngineManager(); ScriptEngine engine manager.getEngineByName("JavaScript");Object result engine.eval("12");转载于:https://www.cnblogs.com/highfly2012/p/6080374.html
阅读更多...
Android：Application

Android：Application

1.Application是程序真正的入口&#xff0c;启动时会先执行Application再执行其他组件。2.建立自己的Application类&#xff0c;需要在xml里将application修改自己的application类&#xff1a;<applicationandroid:name"com.example.aexh_19_application.MyApplication…
阅读更多...
实体entity、JavaBean、Model、POJO、domain的区别

实体entity、JavaBean、Model、POJO、domain的区别

From: https://blog.csdn.net/u011665991/article/details/81201499 Java Bean、POJO、 Entity、 VO &#xff0c; 其实都是java 对象&#xff0c;只不过用于不同场合罢了。 按照 Spring MVC 分层结构&#xff1a; JavaBean: 表示层 &#xff08;Presentation Layer&#xf…
阅读更多...
【Linux_Fedora_系统管理系列】_1_用户登录和系统初始配置

【Linux_Fedora_系统管理系列】_1_用户登录和系统初始配置

发现一个问题&#xff0c;在FC14 的Firefox浏览器中&#xff0c;编辑和排版好的博文&#xff0c;在windows下用chrome或者猎豹浏览器打开后&#xff0c;排版就变得阅读 不是很容易里&#xff0c;而且经常不经意的断行。不知道园子的管理人员时候注意到了这个问题。 Linux系统的…
阅读更多...
HDU 2202 计算几何

HDU 2202 计算几何

最大三角形 Time Limit: 5000/2000 MS (Java/Others) Memory Limit: 32768/32768 K (Java/Others)Total Submission(s): 4015 Accepted Submission(s): 1433 Problem Description老师在计算几何这门课上给Eddy布置了一道题目&#xff0c;题目是这样的&#xff1a;给定二维…
阅读更多...
SpringBoot系列十：SpringBoot整合Redis

SpringBoot系列十：SpringBoot整合Redis

From: https://www.cnblogs.com/leeSmall/p/8728231.html 声明&#xff1a;本文来源于MLDN培训视频的课堂笔记&#xff0c;写在这里只是为了方便查阅。 1、概念&#xff1a;SpringBoot 整合 Redis 2、背景 Redis 的数据库的整合在 java 里面提供的官方工具包&#xff1a;j…
阅读更多...
海贼王革命家—龙—实力到底如何?

海贼王革命家—龙—实力到底如何?

龙——整个海贼王世界中最神秘的人物&#xff0c;令世界政府最担心的存在&#xff0c;是所有迷最为期待的实力展现&#xff0c;他的身上好像有着无数的秘密等着尾田为我们揭晓。 路飞的父亲——未来的海贼王、卡普的儿子——海军英雄、革民军首领——唯一可以跟世界政府抗衡的组…
阅读更多...
python模块介绍- xlwt 创建xls文件（excel）

python模块介绍- xlwt 创建xls文件（excel）

python模块介绍- xlwt 创建xls文件&#xff08;excel&#xff09; 2013-06-24磁针石 #承接软件自动化实施与培训等gtalk&#xff1a;ouyangchongwu#gmail.comqq 37391319 博客:http://blog.csdn.net/oychw #版权所有&#xff0c;转载刊登请来函联系 # 深圳测试自动化python项目…
阅读更多...
SpringBoot(六)：SpringBoot整合Redis

SpringBoot(六)：SpringBoot整合Redis

From: https://blog.csdn.net/plei_yue/article/details/79362372 前言 在本篇文章中将SpringBoot整合Redis&#xff0c;使用的是RedisTemplate&#xff0c;分别实现了SpringBoot与redis的单机版、集群版、哨兵模式的整合。 Maven依赖 <!-- 整合redis --> <…
阅读更多...
最新文章

Copyright @ 2022~2023