面对ORM工具的选型,用过PetaPoco、 SqlSugar、nhibernate-core、EntityFrameworkCore、 ORM选择是一个非常纠结切难以下手的问题。当时围绕Dapper、EF、Nhibernate发生了激烈的讨论。 选择EF因为微软的支持,同时选择Dapper代替ADO.NET 操作数据库,而且Dapper比PetaPoco、SqlSugar好在使用的人多且环境多,出现的问题和支持可以得到很好的解决。
目前来说EF和Dapper是.NET平台最主流的ORM工具,团队成员的接受程度很高,学习成本最低,因为主主流,所以相关的资料非常齐全,各种坑也最少。
- 支持工作单元模式,也支持事务,也支持数据库仓储和工作单元模型
- 能帮助你快速的构建项目的数据访问层
- 支持EF和Dapper ,简单操作使用EF,复杂sql操作使用Dapper
- 支持Mysql和Mssql
- 支持同步和异步操作,推荐使用异步 PS:参考其他开源项目,切使用MIT协议的项目
引入nuget
<PackageReference Include="Sop.Data" Version="1.0.0" />
创建实体对象,继承IEntity
public class School : IEntity
{
public int Id { get; set; }
public string SchoolId { get; set; }
public string Name { get; set; }
}
创建仓储接口和实现类,分别继承IRepository和EfCoreRepository
public class SchoolRepository: EfCoreRepository<School>,ISchoolRepository
{
public SchoolRepository(DbContext context) : base(context)
{
}
}
public interface ISchoolRepository : IRepository<School>
{
}
注入服务
private readonly IUnitOfWork _unitOfWork;
private readonly ISchoolRepository _schoolRepository;
/// <summary>
///
/// </summary>
public MsEfDbRepositoryTest()
{
var services = new ServiceCollection();
services.AddSopData<EfDbBaseDbContext>(opt =>
{
opt.UseMySql("server =127.0.0.1;database=soptestdb;uid=root;password=123456;");
});
var sp = services.BuildServiceProvider();
_unitOfWork = sp.GetRequiredService<IUnitOfWork>();
_schoolRepository = sp.GetRequiredService<ISchoolRepository>();
}
在Controller中使用
public class ValuesController : ControllerBase
{
private readonly ISchoolRepository _schoolRepository;
private readonly IUnitOfWork _unitOfWork;
public ValuesController(ISchoolRepository schoolRepository, IUnitOfWork unitOfWork)
{
_schoolRepository = schoolRepository;
_unitOfWork = unitOfWork;
}
}
查询
//根据主键查询
_schoolRepository.GetById(Id)
//不带追踪的查询,返回数据不能用于更新或删除操作,性能快
schoolRepository.TableNoTracking.First(x => x.Id == Id);
//带追踪的查询,返回数据可以用于更新或删除操作,性能稍慢
schoolRepository.Table.First(x => x.Id == Id);
//分页查询
_schoolRepository.TableNoTracking.ToPagedList(1,10);
//sql语句查询
_unitOfWork.QueryAsync<School>("select * from school");
//sql分页查询
_unitOfWork.QueryPagedListAsync<School>(1, 10, "select * from school order by id");
关于查询,暴露了返回IQueryable的TableNoTracking、Table这两个属性,让开发人员自己组装Lambda表达式进行查询操作
新增
//新增,支持批量新增
_schoolRepository.Insert(school);
_unitOfWork.SaveChanges();
//sql语句新增
_unitOfWork.ExecuteAsync("insert school(id,name) values(@Id,@Name)",
school);
编辑
//编辑,支持批量编辑
var school = _schoolRepository.GetByIdAsync(Id);
school.Name="newschool";
_schoolRepository.Update(school);
_unitOfWork.SaveChanges();
//编辑,不用先查询
var school = new School
{
Id = "xxxxxx",
Name = "newschool"
};
_schoolRepository.Update(school, x => x.Name);
_unitOfWork.SaveChanges();
//sql语句编辑
_unitOfWork.ExecuteAsync("update school set name=@Name where id=@Id",
school);
删除
//删除,支持批量删除
_schoolRepository.Delete(school);
_unitOfWork.SaveChanges();
//根据lambda删除
_schoolRepository.Delete(x => x.Id == Id);
_unitOfWork.SaveChanges();
事务
//工作单元模式使用事务
await _schoolRepository.InsertAsync(school1);
await _schoolRepository.InsertAsync(school1);
await _unitOfWork.SaveChangesAsync();
//dapper使用事务
using (var tran = _unitOfWork.BeginTransaction())
{
try
{
await _unitOfWork.ExecuteAsync("insert school(id,name) values(@Id,@Name)",
school1,tran);
await _unitOfWork.ExecuteAsync("insert school(id,name) values(@Id,@Name)",
school2,tran);
tran.Commit();
}
catch (Exception e)
{
tran.Rollback();
}
}
//dapper+ef混合使用事务
using (var tran = _unitOfWork.BeginTransaction())
{
try
{
await _schoolRepository.InsertAsync(school1);
await _unitOfWork.SaveChangesAsync();
await _unitOfWork.ExecuteAsync("insert school(id,name) values(@Id,@Name)",
school2);
tran.Commit();
}
catch (Exception e)
{
tran.Rollback();
}
}
高级用法
//通过GetConnection可以使用更多dapper扩展的方法
_unitOfWork.GetConnection().QueryAsync("select * from school");
MIT