Skip to content

UnitOfWork with RepositoryFactory #148

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
noufionline wants to merge 2 commits into from
Closed

UnitOfWork with RepositoryFactory #148

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
3657336
UnitOfWork with RepositoryFactory
noufionline Sep 28, 2016
484f3c9
Update UnitOfWork
noufionline Sep 28, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
99 changes: 99 additions & 0 deletions Source/TrackableEntities.Patterns.EF.6/UnitOfWork
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,99 @@
using System;
using System.Threading;
using System.Threading.Tasks;

/// <summary>
/// General unit of work for committing changes across one or more repositories.
/// Inherit from this class to supply a specific DbContext.
/// Add a property for each respository for which unit of work must be done.
/// </summary>
public abstract class UnitOfWork : IUnitOfWork, IUnitOfWorkAsync, IDisposable
{
private readonly IRepositoryFactory _repositoryFactory;
private bool _disposed;

/// <summary>
/// Constructs a new general unit of work.
/// </summary>
protected UnitOfWork() { }

/// <summary>
/// Constructs a new general unit of work.
/// </summary>
/// <param name="context">Entity Framework DbContext-derived class.</param>
protected UnitOfWork(DbContext context, IRepositoryFactory repositoryFactory)
{
_repositoryFactory = repositoryFactory;
Context = context;
}

/// <summary>
/// Gets the DbContext for the unit of work.
/// </summary>
protected DbContext Context { get; set; }

/// <summary>
/// Disposes the DbContext.
/// </summary>
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}

protected T GetRepository<T>()
{
return _repositoryFactory.GetRepository<T>();
}

/// <summary>
/// Disposes the DbContext.
/// </summary>
/// <param name="disposing">True to release both managed and unmanaged resources; false to release only unmanaged resources.</param>
protected virtual void Dispose(bool disposing)
{
if (_disposed) return;
if (disposing) Context.Dispose();
_disposed = true;
}

/// <summary>
/// Saves changes made to one or more repositories.
/// </summary>
/// <returns>The number of objects saved.</returns>
public virtual int SaveChanges()
{
if (_disposed)
throw new ObjectDisposedException("UnitOfWork");
return Context.SaveChanges();
}

/// <summary>
/// Saves changes made to one or more repositories.
/// </summary>
/// <returns>A task that represents the asynchronous save operation. The task result contains the number of objects saved.</returns>
public virtual async Task<int> SaveChangesAsync()
{
if (_disposed)
throw new ObjectDisposedException("UnitOfWork");
return await SaveChangesAsync(CancellationToken.None);
}

/// <summary>
/// Saves changes made to one or more repositories.
/// </summary>
/// <param name="cancellationToken">A CancellationToken to observe while waiting for the task to complete.</param>
/// <returns>A task that represents the asynchronous save operation. The task result contains the number of objects saved.</returns>
public virtual async Task<int> SaveChangesAsync(CancellationToken cancellationToken)
{
if (_disposed)
throw new ObjectDisposedException("UnitOfWork");
return await Context.SaveChangesAsync(cancellationToken);
}
}


public interface IRepositoryFactory
{
T GetRepository<T>();
}