Generic repository based on dapper exposes most common repository methods as well as providing some additional functionality.
Here is the complete interface that is exposed:
public interface IGenericRepository<T> where T: class
{
Task<IEnumerable<T>> GetAllAsync(CancellationToken cancellationToken = default);
Task<T> GetAsync(object id,CancellationToken cancellationToken = default);
Task InsertAsync(T t,CancellationToken cancellationToken = default);
void InsertBulk(IEnumerable<T> items);
Task UpdateAsync(T t, CancellationToken cancellationToken = default);
Task DeleteAsync(object id, CancellationToken cancellationToken = default);
Task InsertRangeAsync(IEnumerable<T> t, CancellationToken cancellationToken = default);
}Create Model class for example:
public class MainTable
{
public int Id { get; set; }
public string Data { get; set; }
public DateTime UpdatedDate { get; set; }
}Create new class which inherits from GenericRepository and pass model as type:
public class MainTableRepository: GenericRepository<MainTable>
{
public MainTableRepository(string connectionString, string tableName) : base(connectionString, tableName)
{
}
}Thats it, repository is now ready to be used like so:
await mainTableRepository.InsertAsync(new MainTable()
{
Data = data,
UpdatedDate = DateTime.Now
});Each async method also supports cancellation token except for InsertBulk which is not async and is using SqlBulkCopy for efficient insert large number of records without a transaction.
Repository generates queries based on provided generic type T and usage is pretty straightforward. Examples can be found in Tests project.
Please note: For inserting large number of records use InsertBulk for inserting large number of records with the transaction use InsertRangeAsync.
A few dapper extension that can help in everyday use
Dapper can be used the same way. If you want to pass token to the method with the same name as dapperWithToken(). Example:
public async Task<IEnumerable<T>> GetAllAsync(CancellationToken cancellationToken)
{
using (var connection = CreateConnection())
{
return await connection.QueryAsyncWithToken<T>($"SELECT * FROM {_tableName}", cancellationToken: cancellationToken);
}
}