ADO Query Class

Query.cs

  public class Query
    {
        private readonly string _connectionString;

        public Query(string connectionString)
        {
            this._connectionString = connectionString;
        }

        public async Task<T> UsingConnectionAsync<T>(Func<SqlConnection, Task<T>> func)
        {
            using (SqlConnection con = new SqlConnection(this._connectionString))
            {
                await con.OpenAsync();
                return await func(con);
            }
        }

        public async Task<T> UsingTransactionAsync<T>(Func<SqlConnection, SqlTransaction, Task<T>> func)
        {
            return await UsingConnectionAsync(
                async con =>
                {
                    using(SqlTransaction trans = con.BeginTransaction())
                    {
                        var result = await func(con, trans);
                        trans.Commit();
                        return result;
                    }                   
                }
            );
        }
    }