ABP引入SqlSugar框架的简单版创建使用_实用技巧_

 [SugarTable("BasBloodLevel")] public class BasBloodLevel { [SugarColumn(IsPrimaryKey = true, IsIdentity = true)] public int Id { get; set; } public string Code { get; set; } }

 /// 
 /// 基类接口,其他接口继承该接口 /// 
 ///  public interface IBaseRepository where TEntity : class { /// 
 /// 根据ID查询 /// 
 ///  ///  Task QueryByID(object objId); /// 
 /// 添加 /// 
 ///  ///  Task Add(TEntity model); /// 
 /// 修改 /// 
 ///  ///  Task Update(TEntity model); /// 
 /// 删除 /// 
 ///  ///  Task DeleteByIds(object[] ids); }

 /// 
 /// 基类实现 /// 
 ///  public class BaseRepository : DbContext, IBaseRepository where TEntity : class, new() { /// 
 /// 写入实体数据 /// 
 ///  ///  public async Task Add(TEntity model) { //这里需要注意的是，如果使用了Task.Run()就会导致 sql语句日志无法记录改成下面的 //var i = await Task.Run(() => Db.Insertable(model).ExecuteCommand()); var i = await Db.Insertable(model).ExecuteCommandAsync(); return i > 0; } /// 
 /// 根据ID删除 /// 
 ///  ///  public async Task DeleteByIds(object[] ids) { var i = await Db.Deleteable().In(ids).ExecuteCommandAsync(); return i > 0; } /// 
 /// 根据ID查询一条数据 /// 
 ///  ///  public async Task QueryByID(object objId) { return await Db.Queryable().InSingleAsync(objId); } /// 
 /// 更新实体数据 /// 
 ///  ///  public async Task Update(TEntity model) { //这种方式会以主键为条件 var i = await Db.Updateable(model).ExecuteCommandAsync(); return i > 0; } }

 public class DbContext where T : class, new() { public DbContext() { Db = new SqlSugarClient(new ConnectionConfig() { //数据库地址我们可以直接读取 ABP框架的配置文件，但是为了方便我直接写死了 ConnectionString = "Server=****; Database=****; Uid=sa; Pwd=****;MultipleActiveResultSets=true;", DbType = DbType.SqlServer, InitKeyType = InitKeyType.Attribute,//从特性读取主键和自增列信息 IsAutoCloseConnection = true,//开启自动释放模式 }); //调式代码 用来打印SQL Db.Aop.OnLogExecuting = (sql, pars) => { Console.WriteLine(sql + "\r\n" + Db.Utilities.SerializeObject(pars.ToDictionary(it => it.ParameterName, it => it.Value))); Console.WriteLine(); }; } //注意：不能写成静态的 public SqlSugarClient Db;//用来处理事务多表查询和复杂的操作 public SimpleClient CurrentDb { get { return new SimpleClient(Db); } }//用来操作当前表的数据 public SimpleClient BasBloodLevelDb { get { return new SimpleClient(Db); } }//用来处理User表的常用操作 }

 [DependsOn(typeof(AbpZeroCoreModule))] public class Module : AbpModule { public override void Initialize() { IocManager.Register(typeof(IBaseRepository<>), typeof(BaseRepository<>), DependencyLifeStyle.Singleton); //依赖注入程序集 IocManager.RegisterAssemblyByConvention(typeof(Module).GetAssembly()); } }

 public class BasBloodBreedAppService : BloodTestLibSystemAppServiceBase,IApplicationService { private IBaseRepository _baseRepository { get; set; } public BasBloodBreedAppService(IBaseRepository baseRepository) { _baseRepository = baseRepository; } public async Task GetBase() { var ce=await _baseRepository.QueryByID(1); return ce; } }