源码点我
1、目前Sqlsugar已经具备操作数据库的能力，根据微软电子书，我们按照如下结构创建文件夹来完善我们的项目
namespace NET6.Domain.Dtos
{
public class AddressDto
{
///
/// 收件人姓名
///
public string Name { get; set; }
///
/// 收件人手机号
///
public string Phone { get; set; }
///
/// 省份
///
public string Province { get; set; }
///
/// 城市
///
public string City { get; set; }
///
/// 区域
///
public string Area { get; set; }
///
/// 详细地址
///
public string Detail { get; set; }
///
/// 是否是默认地址
///
public bool IsDefault { get; set; }
}
}
namespace NET6.Domain.ViewModels
{
public class AddressView
{
///
/// 编号
///
public string Id { get; set; }
///
/// 收件人姓名
///
public string Name { get; set; }
///
/// 收件人手机号
///
public string Phone { get; set; }
///
/// 省份
///
public string Province { get; set; }
///
/// 城市
///
public string City { get; set; }
///
/// 区域
///
public string Area { get; set; }
///
/// 详细地址
///
public string Detail { get; set; }
///
/// 是否是默认地址
///
public bool IsDefault { get; set; }
}
}
3、接下来我们为Address创建仓储，为了更好的开发，我们先创建一个泛型的BaseRepository，并在其中编写常用的CRUD方法，然后创建AddressRepository继承于BaseRepository，代码如下
using NET6.Domain.Entities;
using NET6.Domain.Enums;
using SqlSugar;
using System.Data;
using System.Linq.Expressions;
namespace NET6.Infrastructure.Repositories
{
public class BaseRepository where TEntity : EntityBase, new()
{
public SqlSugarClient _sqlSugar;
public BaseRepository(SqlSugarClient sqlSugar)
{
_sqlSugar = sqlSugar;
}
#region 多租户
///
/// 变更数据库
///
/// ExecuteCommandAsync(string sql)
{
return _sqlSugar.Ado.ExecuteCommandAsync(sql);
}
public virtual Task GetDataTableAsync(string sql)
{
return _sqlSugar.Ado.GetDataTableAsync(sql);
}
public virtual Task GetScalarAsync(string sql)
{
return _sqlSugar.Ado.GetScalarAsync(sql);
}
#endregion
#region 事务操作
public void BeginTran()
{
_sqlSugar.BeginTran();
}
public void CommitTran()
{
_sqlSugar.CommitTran();
}
public void RollbackTran()
{
_sqlSugar.RollbackTran();
}
#endregion
#region 库表管理
public bool CreateDataBase()
{
return _sqlSugar.DbMaintenance.CreateDatabase();
}
public bool CopyTable(string oldname, string newname)
{
if (!_sqlSugar.DbMaintenance.IsAnyTable(newname, false))
{
return _sqlSugar.DbMaintenance.BackupTable(oldname, newname, 0);
}
return false;
}
public bool TruncateTable(string tablename)
{
return _sqlSugar.DbMaintenance.TruncateTable(tablename);
}
public void CreateTable(Type entityType)
{
_sqlSugar.CodeFirst.SetStringDefaultLength(200).BackupTable().InitTables(entityType);
}
public void CreateTable(Type[] entityTypes)
{
_sqlSugar.CodeFirst.SetStringDefaultLength(200).BackupTable().InitTables(entityTypes);
}
#endregion
public virtual Task AnyAsync(Expression> exp)
{
return _sqlSugar.Queryable().AnyAsync(exp);
}
public virtual ISugarQueryable Query(Expression> exp)
{
return _sqlSugar.Queryable().Where(a => !a.IsDeleted).Where(exp);
}
public virtual ISugarQueryable QueryDto(Expression> exp)
{
return _sqlSugar.Queryable().Where(a => !a.IsDeleted).Where(exp).Select();
}
public virtual Task GetDtoAsync(Expression> exp)
{
return _sqlSugar.Queryable().Where(s => !s.IsDeleted).Where(exp).Select().FirstAsync();
}
public virtual Task AddAsync(TEntity entity)
{
return _sqlSugar.Insertable(entity).ExecuteCommandAsync();
}
public virtual Task GetAsync(Expression> exp)
{
return _sqlSugar.Queryable().FirstAsync(exp);
}
public virtual async Task DeleteAsync(Expression> wherexp)
{
var result = await _sqlSugar.Deleteable().Where(wherexp).ExecuteCommandAsync();
return result > 0;
}
public virtual async Task UpdateAsync(Expression> wherexp, Expression> upexp)
{
var result = await _sqlSugar.Updateable().Where(wherexp).SetColumns(upexp).ExecuteCommandAsync();
return result > 0;
}
public virtual async Task SoftDeleteAsync(string id)
{
var result = await _sqlSugar.Updateable().Where(a => a.Id.Equals(id)).SetColumns(a => new TEntity()
{
IsDeleted = true,
DeleteTime = DateTime.Now
}).ExecuteCommandAsync();
return result > 0;
}
public virtual async Task SoftDeleteAsync(Expression> wherexp)
{
var result = await _sqlSugar.Updateable().Where(wherexp).SetColumns(a => new TEntity()
{
IsDeleted = true,
DeleteTime = DateTime.Now
}).ExecuteCommandAsync();
return result > 0;
}
#region 泛型CRUD
public virtual Task AnyAsync(Expression> exp) where T : EntityBase, new()
{
return _sqlSugar.Queryable().Where(s => !s.IsDeleted).AnyAsync(exp);
}
public virtual Task GetDtoAsync(Expression> exp) where T : EntityBase, new()
{
return _sqlSugar.Queryable().Where(s => !s.IsDeleted).Where(exp).Select().FirstAsync();
}
public virtual ISugarQueryable QueryDto(Expression> exp) where T : EntityBase, new()
{
return _sqlSugar.Queryable().Where(a => !a.IsDeleted).Where(exp).Select();
}
public virtual Task AddAsync(T entity) where T : EntityBase, new()
{
return _sqlSugar.Insertable(entity).ExecuteCommandAsync();
}
public virtual ISugarQueryable Query(Expression> exp) where T : EntityBase, new()
{
return _sqlSugar.Queryable().Where(s => !s.IsDeleted).Where(exp);
}
public virtual Task GetAsync(Expression> exp) where T : EntityBase, new()
{
return _sqlSugar.Queryable().Where(s => !s.IsDeleted).Where(exp).FirstAsync();
}
public virtual async Task UpdateAsync(Expression> wherexp, Expression> upexp) where T : EntityBase, new()
{
var result = await _sqlSugar.Updateable().Where(wherexp).SetColumns(upexp).ExecuteCommandAsync();
return result > 0;
}
public virtual async Task DeleteAsync(Expression> wherexp) where T : EntityBase, new()
{
var result = await _sqlSugar.Deleteable().Where(wherexp).ExecuteCommandAsync();
return result > 0;
}
public virtual async Task SoftDeleteAsync(string id) where T : EntityBase, new()
{
var result = await _sqlSugar.Updateable().Where(a => a.Id.Equals(id)).SetColumns(a => new TEntity()
{
IsDeleted = true,
DeleteTime = DateTime.Now
}).ExecuteCommandAsync();
return result > 0;
}
public virtual async Task SoftDeleteAsync(Expression> wherexp) where T : EntityBase, new()
{
var result = await _sqlSugar.Updateable().Where(wherexp).SetColumns(a => new TEntity()
{
IsDeleted = true,
DeleteTime = DateTime.Now
}).ExecuteCommandAsync();
return result > 0;
}
#endregion
}
}
using NET6.Domain.Entities;
using NET6.Domain.ViewModels;
using SqlSugar;
namespace NET6.Infrastructure.Repositories
{
public class AddressRepository : BaseRepository
{
public AddressRepository(SqlSugarClient sqlSugar) : base(sqlSugar)
{
}
}
}
4、仓储创建完毕，我们将其注入到项目中，使用Autofac能更方便的实现该功能，打开Nuget，搜索安装Autofac。
#region 引入注册Autofac
builder.Host.UseServiceProviderFactory(new AutofacServiceProviderFactory());
var hostBuilder = builder.Host.ConfigureContainer(builder =>
{
try
{
var assemblyServices = Assembly.Load("NET6.Infrastructure");
builder.RegisterAssemblyTypes(assemblyServices).Where(a => a.Name.EndsWith("Repository")).AsSelf();
}
catch (Exception ex)
{
throw new Exception(ex.Message + "n" + ex.InnerException);
}
});
#endregion
到此，Autofac便配置完成，NET6.Infrastructure项目中所有以Repository结尾的文件都会被注入到项目之中。
