使用内联查询进行单元测试

我知道有几个问题与我的类似。

• Dapper：单元测试 SQL 查询 https://stackoverflow.com/questions/20461553/dapper-unit-testing-sql-queries
• 测试简洁的查询 https://stackoverflow.com/questions/8933052/testing-dapper-queries

但我认为上述两个问题都没有符合我要求的明确答案。

现在，我开发了一个新的 WebAPI 项目，并分为 Web API 项目和数据访问技术。我测试 WebAPI 的控制器没有问题，因为我可以模拟数据访问类。

但对于 DataAccess 类，这是一个不同的故事，因为我使用带有内联查询的 Dapper，我有点困惑如何使用单元测试来测试它。我问过一些朋友，他们更喜欢进行集成测试而不是单元测试。

我想知道的是，是否可以对使用 Dapper 和内联查询的 DataAccess 类进行单元测试。

假设我有一个这样的类（这是一个通用存储库类，因为很多代码都有类似的查询，通过表名和字段来区分）

public abstract class Repository<T> : SyncTwoWayXI, IRepository<T> where T : IDatabaseTable
{
       public virtual IResult<T> GetItem(String accountName, long id)
       {
            if (id <= 0) return null;

            SqlBuilder builder = new SqlBuilder();
            var query = builder.AddTemplate("SELECT /**select**/ /**from**/ /**where**/");

            builder.Select(string.Join(",", typeof(T).GetProperties().Where(p => p.CustomAttributes.All(a => a.AttributeType != typeof(SqlMapperExtensions.DapperIgnore))).Select(p => p.Name)));
            builder.From(typeof(T).Name);
            builder.Where("id = @id", new { id });
            builder.Where("accountID = @accountID", new { accountID = accountName });
            builder.Where("state != 'DELETED'");

            var result = new Result<T>();
            var queryResult = sqlConn.Query<T>(query.RawSql, query.Parameters);

            if (queryResult == null || !queryResult.Any())
            {
                result.Message = "No Data Found";
                return result;
            }

            result = new Result<T>(queryResult.ElementAt(0));
            return result;
       }

       // Code for Create, Update and Delete
  }

上面代码的实现就像

public class ProductIndex: IDatabaseTable
{
        [SqlMapperExtensions.DapperKey]
        public Int64 id { get; set; }

        public string accountID { get; set; }
        public string userID { get; set; }
        public string deviceID { get; set; }
        public string deviceName { get; set; }
        public Int64 transactionID { get; set; }
        public string state { get; set; }
        public DateTime lastUpdated { get; set; }
        public string code { get; set; }
        public string description { get; set; }
        public float rate { get; set; }
        public string taxable { get; set; }
        public float cost { get; set; }
        public string category { get; set; }
        public int? type { get; set; }
}

public class ProductsRepository : Repository<ProductIndex>
{
   // ..override Create, Update, Delete method
}

这是我们的方法：

1. 首先，你需要有一个抽象IDbConnection能够嘲笑它：

   public interface IDatabaseConnectionFactory
   {
       IDbConnection GetConnection();
   }
   

2. 您的存储库将从该工厂获取连接并执行Dapper对其进行查询：

   public class ProductRepository
   {
       private readonly IDatabaseConnectionFactory connectionFactory;
   
       public ProductRepository(IDatabaseConnectionFactory connectionFactory)
       {
           this.connectionFactory = connectionFactory;
       }
   
       public Task<IEnumerable<Product>> GetAll()
       {
           return this.connectionFactory.GetConnection().QueryAsync<Product>(
               "select * from Product");
       }
   }
   

3. 您的测试将创建一个包含一些示例行的内存数据库，并检查存储库如何检索它们：

   [Test]
   public async Task QueryTest()
   {
       // Arrange
       var products = new List<Product>
       {
           new Product { ... },
           new Product { ... }
       };
       var db = new InMemoryDatabase();
       db.Insert(products);
       connectionFactoryMock.Setup(c => c.GetConnection()).Returns(db.OpenConnection());
   
       // Act
       var result = await new ProductRepository(connectionFactoryMock.Object).GetAll();
   
       // Assert
       result.ShouldBeEquivalentTo(products);
   }
   

4. 我想有多种方法可以实现这种内存数据库；我们用了OrmLite在之上SQLite数据库：

   public class InMemoryDatabase
   {
       private readonly OrmLiteConnectionFactory dbFactory = new OrmLiteConnectionFactory(":memory:", SqliteOrmLiteDialectProvider.Instance);
   
       public IDbConnection OpenConnection() => this.dbFactory.OpenDbConnection();
   
       public void Insert<T>(IEnumerable<T> items)
       {
           using (var db = this.OpenConnection())
           {
               db.CreateTableIfNotExists<T>();
               foreach (var item in items)
               {
                   db.Insert(item);
               }
           }
       }
   }