1. 程式人生 > >EF5.x Code First一對多關聯條件查詢Contains、Any和All使用示例

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   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 list                         select 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;              }          }