1.实体框架(EF)简介
与ADO.NET的关系
全称是ADO.NET Entity Framework,是微软开发的基于ADO.NET的ORM(Object/Relational Mapping)框架
特点:
1. 支持多种数据库(MSSQL, Oracle, and DB2)
2. 强劲的映射引擎,能很好地支持存储过程;
3. 提供Visual Studio集成工具,进行可视化操作
4. 能够与ASP.NET, WPF, WCF, WCF Data Services进行很好的集成。
2.edmx文件
新建一个PKE.edmx
用XML打开的情况
3.简单的增删改查
using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Text;
namespace FirstEF
{
class Program
{
static void Main(string[] args)
{
Query();
Console.ReadKey();
}
/// <summary>
/// 数据上下文对象
/// </summary>
static CoolPEKEntities DBpek = new CoolPEKEntities();
//新增
static void Add()
{
//1.创建实体对象
TUser user = new TUser()
{
UserName = "刘德华",
PassWord = "001",
CreatTime = DateTime.Now,
Roel = 0
};
//2.通过EF新增到数据库
//将对象 加入到 数据上下文 的 TUser 集合中
DBpek.TUsers.Add(user);
//调用数据上下文的保存方法 将对象 存数据库
DBpek.SaveChanges();
Console.WriteLine("添加成功!");
}
//查询
static void Query()
{
//标准查询
//List<TUser> listTUser = DBpek.TUsers.Where(d => d.UserName == "刘德华").ToList();
//listTUser.ForEach(d => Console.WriteLine(d.UserID + "," + d.UserName + "," + d.CreatTime));
//linq查询
List<TUser> list = DBpek.TUsers.ToList();
var listlinq = from d in list
where d.UserName == "刘德华"
select d
;
foreach (var user in listlinq)
{
Console.WriteLine(user.UserID + "," + user.UserName + "," + user.CreatTime);
}
}
//修改 -- 官方推荐修改方式(先查询,再修改)
static void Update()
{
//查询出1个要修改的对象
var use = DBpek.TUsers.Where(d => d.UserID == 53).FirstOrDefault();
Console.WriteLine("修改前:" + use.UserName);
use.UserName = "张学友";
DBpek.SaveChanges();
Console.WriteLine("修改后:" + use.UserName);
Console.WriteLine("修改成功!");
}
//删除 -- 不推荐用官方的先查后删(自己直接删)
static void Delete()
{
//创建要删除的对象
TUser u = new TUser() { UserID = 55 };
//附加到EF中
DBpek.TUsers.Attach(u);
//标记为删除
DBpek.TUsers.Remove(u);
//执行SQL
DBpek.SaveChanges();
Console.WriteLine("删除成功!");
}
}
}
4.延迟加载
原因:
/************************************************************************/
/*集合的标准查询运算符方法,来自于System.Linq.Enumerable里给IEnumerable接口添加的查询方法
* List<string> listStr = new List<string>();
*
*EF上下文里的 DBSet<T> 里的标准查询运算符方法,来自于System.Linq.Queryable里 给IQueryable接口添加的方法
*延迟加载,本质原因一: 当前可能通过多个SQO方法来组合 查询条件,那么每个方法 都只是添加一个查询条件而已,
* 无法确定本次查询条件是否已经添加结束
* 所以,没有办法在每个SQO方法的时候确定SQL语句是什么,只能返回一个包含了所有添加条件的 DbQuery对象
* 当使用这个 DbQuery对象 的时候,才根据所有条件生成 SQL 语句,查询数据库
/************************************************************************/
DbQuery<TUser> dbQuery = DBpek.TUsers.Where(d => d.UserName == "刘德华").OrderBy(d => d.UserID) as DbQuery<TUser>;
TUser u = dbQuery.FirstOrDefault();
Console.WriteLine(u.UserName);
5.Include及时加载-生成inner join
//按需加载的缺点:会为每次调用外键实体时,都会去查询数据(EF有小优化:相同的外键实体值查一次)
IQueryable<PKE_DeviceNumber> dba = DBpek.PKE_DeviceNumber;
foreach (PKE_DeviceNumber pkeDeviceNumber in dba)
{
Console.WriteLine(pkeDeviceNumber.DeviceNumber + "," + pkeDeviceNumber.PKE_Franchiser.Remark);
}
使用Include方法,只调用一次连接查询
//连接查询(生成 InnerJoin)
IQueryable<PKE_DeviceNumber> db = DBpek.PKE_DeviceNumber.Include
("PKE_Franchiser");
foreach (PKE_DeviceNumber pkeDeviceNumber in db)
{
Console.WriteLine(pkeDeviceNumber.DeviceNumber + "," + pkeDeviceNumber.PKE_Franchiser.Remark);
}
6.EF容器--修改时,不使用Attach( )方式,使用Entry<T>
1.代理类的用处
2.修改时,不使用Attach( )方式
3.修改时,使用Entry设置状态
-
//修改 -- 优化(创建对象 直接修改)
-
static void Update2()
-
{
-
//方法1:取消验证
-
//DBpek.Configuration.ValidateOnSaveEnabled = false;
-
//1.查询出1个要修改的对象
-
TUser user = new TUser() { UserID = 44, PassWord = "aaa" };
-
//2.将对象加入 EF容器,设置当前实体对象的 状态管理对象
-
DbEntityEntry<TUser> entry = DBpek.Entry<TUser>(user);
-
//3.设置 该对象 未被修改过
-
entry.State = EntityState.Unchanged;
-
//4.设置 要修改的对象的(PassWord属性) 为修改状态,entry.State自动为Modified
-
entry.Property("PassWord").IsModified = true;
-
//5.保存到数据库 -- EF上下文根据entry.State=modified生成sql
-
try
-
{
-
DBpek.SaveChanges();
-
}
-
catch (DbEntityValidationException ex)
-
{
-
Console.WriteLine(ex.EntityValidationErrors);
-
}
-
Console.WriteLine("修改后:" + user.UserName);
-
Console.WriteLine("修改成功!");
-
}
出现验证问题?
解决方法1:
static Program()
{
//方法1:取消验证
DBpek.Configuration.ValidateOnSaveEnabled = false;
}
解决方法2:
根据错误 添加UserName.
7.EF配置文件
8.三层
DAL/User.cs
using System;
using System.Collections.Generic;
using System.Data.Entity.Infrastructure;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using MODEL.Models;
using System.Data;
namespace DAL
{
public class User
{
//数据上下文
private OumindBlogContext db = new OumindBlogContext();
//新增方法
public int Add(MODEL.Models.User model)
{
db.Users.Add(model);
return db.SaveChanges();
}
#region 根据用户ID删除
/// <summary>
/// 根据用户ID删除
/// </summary>
/// <param name="uid"></param>
/// <returns></returns>
public int Del(int uid)
{
MODEL.Models.User us = new MODEL.Models.User() { uId = uid };
db.Users.Attach(us);
db.Users.Remove(us);
return db.SaveChanges();
}
#endregion
/// <summary>
/// 根据条件删除
/// </summary>
/// <param name="delWhere"></param>
/// <returns></returns>
public int DelBy(Expression<Func<MODEL.Models.User, bool>> delWhere)
{
List<MODEL.Models.User> listDeleting = db.Users.Where(delWhere).ToList();
listDeleting.ForEach(d => db.Users.Remove(d));
return db.SaveChanges();
}
/// <summary>
/// 条件修改
/// </summary>
/// <param name="model">要修改的实体对象</param>
/// <param name="proNames">修改的属性名称</param>
/// <returns></returns>
public int Modify(MODEL.Models.User model, params string[] proNames)
{
DbEntityEntry entry = db.Entry<MODEL.Models.User>(model);
entry.State = System.Data.Entity.EntityState.Unchanged;
foreach (var s in proNames)
{
entry.Property(s).IsModified = true;
}
return db.SaveChanges();
}
/// <summary>
/// 条件查询
/// </summary>
/// <param name="whereLambda"></param>
/// <returns></returns>
public List<MODEL.Models.User> GetListBy(Expression<Func<MODEL.Models.User, bool>> whereLambda)
{
return db.Users.Where(whereLambda).ToList();
}
/// <summary>
/// 条件查询(排序)
/// </summary>
/// <typeparam name="TKey"></typeparam>
/// <param name="whereLambda"></param>
/// <param name="orderLambda"></param>
/// <returns></returns>
public List<MODEL.Models.User> GetListBy<TKey>(Expression<Func<MODEL.Models.User, bool>> whereLambda,
Expression<Func<MODEL.Models.User, TKey>> orderLambda)
{
return db.Users.Where(whereLambda).OrderBy(orderLambda).ToList();
}
/// <summary>
/// 分页查询
/// </summary>
/// <typeparam name="Tkey"></typeparam>
/// <param name="whereLambda">查询条件</param>
/// <param name="orderLambda">排序条件</param>
/// <param name="pageIndex">页码</param>
/// <param name="pageSize">页容量</param>
/// <returns></returns>
public List<MODEL.Models.User> GetPageList<Tkey>(Expression<Func<MODEL.Models.User, bool>> whereLambda,
Expression<Func<MODEL.Models.User, Tkey>> orderLambda, int pageIndex, int pageSize)
{
return db.Users.Where(whereLambda).OrderBy(orderLambda).Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList();
}
}
}