SmartSql For Asp.Net Core 最佳实践

常规操作

安装 SmartSql

Install-Package SmartSql

安装 SmartSql.DIExtension

Install-Package SmartSql.DIExtension

配置SmartSqlConfig.xml

• 写库（Write）必选 唯一节点
• 读库（Read）可选 多节点配置

Postgresql

• Postgresql 客户端 Npgsql

Install-Package Npgsql

<?xml version="1.0" encoding="utf-8" ?>

  
  
    
    
    
  
  
    
  

MYSQL

• 安装mysql 客户端 Mysql.Data

Install-Package Mysql.Data

• 配置SmartSqlMapConfig.xml

<?xml version="1.0" encoding="utf-8" ?>

  
  
    
    
    
    
  
  
    
        
     
  

MSSQL

<?xml version="1.0" encoding="utf-8" ?>

  
  
    
    
    
    
    
  
  
    
  

注入依赖

 services.AddSmartSql();
 services.AddRepositoryFactory();
 services.AddRepositoryFromAssembly((options) =>
 {
    options.AssemblyString = "SmartSql.Starter.Repository";
 });

定义仓储接口

    /// 

    /// 属性可选： [SqlMap(Scope = "User")] ,不设置 则默认 Scope 模板：I{Scope}Repository
    /// 可传入自定义模板
    /// RepositoryBuilder builder=new RepositoryBuilder("I{Scope}DAL");
    /// 
    public interface IUserRepository
    {
        /// 

        /// 属性可选 [Statement(Execute = ExecuteBehavior.Auto,Id = "Query")]
        /// 默认 Execute：Auto ，自动判断 执行类型
        /// 默认 Id : 方法名
        /// 
        /// 
        /// 
        IEnumerable Query(object reqParams);
        long GetRecord(object reqParams);
        User Get(object reqParams);
        long Insert(User entity);
        int Update(User entity);
        int Delete(User entity);
    }

尽情享用

    public class UserService
    {
        private readonly ISmartSqlMapper _smartSqlMapper;
        private readonly IUserRepository _userRepository;

        public UserService(
             ISmartSqlMapper smartSqlMapper
            , IUserRepository userRepository)
        {
            _smartSqlMapper = smartSqlMapper;
            _userRepository = userRepository;
        }

        public long Add(AddRequest request)
        {
            int existsNum = _userRepository.Exists(new { request.UserName });
            if (existsNum > 0)
            {
                throw new ArgumentException($"{nameof(request.UserName)} has already existed!");
            }
            return _userRepository.Add(new Entitiy.User
            {
                UserName = request.UserName,
                Password = request.Password,
                Status = Entitiy.UserStatus.Ok,
                CreationTime = DateTime.Now,
            });
        }

        public void UseTransaction()
        {
            try
            {
                _smartSqlMapper.BeginTransaction();
                //Biz();
                _smartSqlMapper.CommitTransaction();
            }
            catch (Exception ex)
            {
                _smartSqlMapper.RollbackTransaction();
                throw ex;
            }
        }
    }