如何使用ISqlSugarClient进行数据访问，并实现了统一的批量依赖注入
生活随笔
收集整理的這篇文章主要介紹了
如何使用ISqlSugarClient进行数据访问，并实现了统一的批量依赖注入
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
倉儲層當(dāng)前有接口 IRepository<T> 抽象類 BaseRepository<T> 業(yè)務(wù)邏輯層有抽象類 BaseBusiness<M, E> 接口 IBusiness<M, E>，其中使用ISqlSugarClient，其中還有E表示 BaseEntity，M為 BaseDto 請用C# 給出一個案例，支持不同表對應(yīng)不同的業(yè)務(wù)邏輯層，然后不同倉儲實(shí)例，不同表的業(yè)務(wù)，都實(shí)現(xiàn)統(tǒng)一的批量依賴注入。
以下是一個更新后的C#示例，演示了如何使用ISqlSugarClient進(jìn)行數(shù)據(jù)訪問，并實(shí)現(xiàn)了統(tǒng)一的批量依賴注入：
using System;
using System.Collections.Generic;
using SqlSugar; // 實(shí)體類
public class BaseEntity
{
[SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
public int Id { get; set; }
// 其他實(shí)體屬性...
} public class ProductEntity : BaseEntity
{
public string Name { get; set; }
// 其他產(chǎn)品實(shí)體屬性...
} public class CustomerEntity : BaseEntity
{
public string FirstName { get; set; }
public string LastName { get; set; }
// 其他客戶實(shí)體屬性...
} // 數(shù)據(jù)傳輸對象（DTO）
public class BaseDto
{
// 公共DTO屬性...
} public class ProductDto : BaseDto
{
public string Name { get; set; }
// 其他產(chǎn)品DTO屬性...
} public class CustomerDto : BaseDto
{
public string FirstName { get; set; }
public string LastName { get; set; }
// 其他客戶DTO屬性...
} // 倉儲層
public interface IRepository<T>
{
void Add(T entity);
void Update(T entity);
void Delete(T entity);
T GetById(int id);
// 其他倉儲操作方法...
} public abstract class BaseRepository<T> : IRepository<T> where T : BaseEntity
{
protected readonly ISqlSugarClient _db; public BaseRepository(ISqlSugarClient db)
{
_db = db;
} public void Add(T entity)
{
_db.Insertable(entity).ExecuteCommand();
} public void Update(T entity)
{
_db.Updateable(entity).ExecuteCommand();
} public void Delete(T entity)
{
_db.Deleteable<T>().In(entity.Id).ExecuteCommand();
} public T GetById(int id)
{
return _db.Queryable<T>().InSingle(id);
} // 其他倉儲操作方法的實(shí)現(xiàn)...
} // 業(yè)務(wù)邏輯層
public interface IBusiness<M, E> where M : BaseDto where E : BaseEntity
{
void Process(M model);
// 其他業(yè)務(wù)邏輯方法...
} public abstract class BaseBusiness<M, E> : IBusiness<M, E> where M : BaseDto where E : BaseEntity
{
protected readonly IRepository<E> _repository; public BaseBusiness(IRepository<E> repository)
{
_repository = repository;
} public abstract void Process(M model);
// 其他業(yè)務(wù)邏輯方法...
} // 具體業(yè)務(wù)邏輯類
public class ProductBusiness : BaseBusiness<ProductDto, ProductEntity>
{
public ProductBusiness(IRepository<ProductEntity> repository) : base(repository)
{
} public override void Process(ProductDto model)
{
// 實(shí)現(xiàn)產(chǎn)品業(yè)務(wù)邏輯
Console.WriteLine("Processing product: " + model.Name);
}
} public class CustomerBusiness : BaseBusiness<CustomerDto, CustomerEntity>
{
public CustomerBusiness(IRepository<CustomerEntity> repository) : base(repository)
{
} public override void Process(CustomerDto model)
{
// 實(shí)現(xiàn)客戶業(yè)務(wù)邏輯
Console.WriteLine("Processing customer: " + model.FirstName + " " + model.LastName);
}
} // 批量依賴注入容器
public class DependencyInjector
{
private readonly ISqlSugarClient _db; public DependencyInjector(ISqlSugarClient db)
{
_db = db;
} public IEnumerable<BaseBusiness<M, E>> ResolveBusinesses<M, E>() where M : BaseDto where E : BaseEntity
{
var repositoryType = typeof(IRepository<E>);
var businessType = typeof(IBusiness<M, E>); var assemblies = AppDomain.CurrentDomain.GetAssemblies();
var businessTypes = new List<Type>(); foreach (var assembly in assemblies)
{
var types = assembly.GetTypes();
foreach (var type in types)
{
if (type.BaseType != null && type.BaseType.IsGenericType)
{
var baseType = type.BaseType.GetGenericTypeDefinition();
if (baseType == businessType)
{
businessTypes.Add(type);
}
}
}
} foreach (var businessTypeItem in businessTypes)
{
var repositoryGenericType = repositoryType.MakeGenericType(businessTypeItem.GetGenericArguments());
var repository = Activator.CreateInstance(repositoryGenericType, _db);
var business = Activator.CreateInstance(businessTypeItem, repository); yield return (BaseBusiness<M, E>)business;
}
}
} // 使用示例
class Program
{
static void Main(string[] args)
{
// 模擬ISqlSugarClient的實(shí)例
var db = new SqlSugarClient(new ConnectionConfig()
{
ConnectionString = "YourConnectionString",
DbType = DbType.SqlServer,
IsAutoCloseConnection = true,
}); // 實(shí)例化依賴注入容器
var injector = new DependencyInjector(db); // 解析并實(shí)例化業(yè)務(wù)邏輯類
var businesses = injector.ResolveBusinesses<BaseDto, BaseEntity>(); // 使用業(yè)務(wù)邏輯類進(jìn)行操作
foreach (var business in businesses)
{
// 處理業(yè)務(wù)邏輯
business.Process(new ProductDto { Name = "Sample Product" });
business.Process(new CustomerDto { FirstName = "John", LastName = "Doe" });
}
}
}
原創(chuàng)，轉(zhuǎn)載請說明出處。
總結(jié)
以上是生活随笔為你收集整理的如何使用ISqlSugarClient进行数据访问，并实现了统一的批量依赖注入的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： [译] D3.js 嵌套选择集 (Nes
- 下一篇： 【OCP-052】052考试题库一变再变