using System;

using Dapper;

using Moq;

using Moq.Dapper;

using System.Data;

using System.Data.Common;

using System.Linq;

using System.Collections.Generic;

public class Program

{

    public class ComplexType

    {

        public string StringProperty { get; set; }

        public int IntegerProperty { get; set; }

    }

​

    private static void TestMoqDapperExecuteAsyncIDbConnectionWithoutTransaction()

    {

            var connection = new Mock<IDbConnection>();

​

            connection.SetupDapperAsync(c => c.QueryAsync<int>(It.IsAny<string>(), It.IsAny<object>(), It.IsAny<IDbTransaction>(), It.IsAny<int>(), It.IsAny<CommandType>()))

                      .ReturnsAsync(new List<int>

            {

                5

            });

            var result = connection.Object

                                   .QueryAsync<int>("")

                                   .GetAwaiter()

                                   .GetResult();

​

        Console.WriteLine(string.Format(" Test without transaction {0}", result.Count() != 0 ? "PASSED" : "FAILED"));

    }

    private static void TestMoqDapperExecuteAsyncIDbConnectionWithTransaction()

    {

            var connection = new Mock<IDbConnection>();

            var tran= new Mock<IDbTransaction>();

​

            connection.SetupDapperAsync(c => c.QueryAsync<int>(It.IsAny<string>(), It.IsAny<object>(), It.IsAny<IDbTransaction>(), It.IsAny<int>(), It.IsAny<CommandType>()))

                      .ReturnsAsync(new List<int>

            {

                5

            });

            var result = connection.Object

                                   .QueryAsync<int>("",null,tran.Object)

                                   .GetAwaiter()

                                   .GetResult();

​

        Console.WriteLine(string.Format("Test  with transaction {0}", result.Count() != 0 ? "PASSED" : "FAILED"));

    }

    public static void Main()

    {   

        TestMoqDapperExecuteAsyncIDbConnectionWithoutTransaction();

        TestMoqDapperExecuteAsyncIDbConnectionWithTransaction();

    }

}