关于如何集成Dapper方式的讨论

[AlphaYu]

目前仓储中下面两个方法支持原生SQL查询，是通过Dapper实现的。

Task<IEnumerable<dynamic>> QueryAsync(string sql, object param = null, int? commandTimeout = null, CommandType? commandType = null, bool writeDb = false);
Task<IEnumerable<TResult>> QueryAsync<TResult>(string sql, object param = null, int? commandTimeout = null, CommandType? commandType = null, bool writeDb = false);

然而实在项目开发过程中总有那么有一些操作(可能占比很低)需要通过原生SQL去做，比方说复杂查询，大批量更新(每条记录更新的内容不同)，大批量插入，大批量删除，直接调用存储过程，直接调用视图等等，极少数情况下不管通过哪种ORM都不如直接拼SQL强；再或者同一个服务中mysql是核心业务库，但是除了核心业务库，还还一个或多个其他库需要查询，这些库有可能是sqlserver,或者oracle。如果这些情况目前仓储都无法应对。

我现在有二个思路：
不管哪种思路都是先在Adnc.Infra.Repository定义接口IAdoRepository.cs

namespace Adnc.Infra.IRepositories;

public interface IAdoRepository
{
    Task<IEnumerable<dynamic>> QueryAsync(string sql, object param = null, IDbTransaction transaction = null, int? commandTimeout = null, CommandType? commandType = null,bool writeDb = false);
    Task<IEnumerable<T>> QueryAsync<T>(string sql, object param = null, IDbTransaction transaction = null, int? commandTimeout = null, CommandType? commandType = null, bool writeDb = false);
    Task<T> QueryFirstAsync<T>(string sql, object param = null, IDbTransaction transaction = null, int? commandTimeout = null, CommandType? commandType = null);
    //其余dapper实现的接口，就不贴了，大量方法。
}

• 第一种思路，创建新的adnc.infra.dapper层，新建AdoRepository类实现IAdoRepository接口以及新增其他一些辅助类。这样的话就非常灵活，只需要注册AdoRepository到容器，在需要使用的application层注入IAdoRepository接口就可以了。数据库链接可以通过ChangeOrSetDbConnection方法调整。不好地方的就是如果需要同时使用EF仓储与原生SQL需要注入EF的仓储又需要注入IAdoRepository。

namespace Adnc.Infra.Dapper.Repositories;
public sealed class AdoRepository : IAdoRepository
{
    private IDbConnection _dbConnection;

    public AdoRepository(){}
    public AdoRepository(DbContext dbContext) => dbContext?.Database?.GetDbConnection();
    public void ChangeOrSetDbConnection(IDbConnection dbConnection)
    {
        if (dbConnection is null)
            throw new ArgumentNullException(nameof(dbConnection));
        _dbConnection = dbConnection;
    }
    public void ChangeOrSetDbConnection(string connectionString, DbTypes dbType)
    {
        if (connectionString.IsNullOrWhiteSpace())
            throw new ArgumentNullException(nameof(connectionString));

        if (dbType == DbTypes.MySql)
            _dbConnection = new MySqlConnection(connectionString);
        //其他数据库
    }

    public async Task<int> ExecuteAsync(string sql, object param = null, IDbTransaction transaction = null, int? commandTimeout = null, CommandType? commandType = null)
    => await SqlMapper.ExecuteAsync(_dbConnection, sql, param, transaction, commandTimeout, commandType);

    public async Task<IDataReader> ExecuteReaderAsync(string sql, object param = null, IDbTransaction transaction = null, int? commandTimeout = null, CommandType? commandType = null)
    => await SqlMapper.ExecuteReaderAsync(_dbConnection, sql, param, transaction, commandTimeout, commandType);
  //其他方法
}

• 第二种思路，直接在现有ef仓储上扩展，新增一个Ado属性，这个属性的类型是IAdoRepository。通过Ado就可以执行大量dapper方法。不好地方的就是其他非mysql数据库不好弄。

    public abstract class AbstractEfBaseRepository<TDbContext, TEntity> : IEfBaseRepository<TEntity>
       where TDbContext : DbContext
       where TEntity : Entity, IEfEntity<long>
    {
        public IAdoRepository Ado { get; }

        public AbstractEfBaseRepository(IAdoRepository adoRepository) => Ado = adoRepository;
   }

怎样才是好的选择？