C#:如何将我的工作单元代码包装在我的存储库类中

请参阅我的存储库代码

public abstract class AdoRepository<T> where T : class
    {
        private static SqlConnection _connection;
        public AdoRepository(string connectionString)
        {
            _connection = new SqlConnection(connectionString);
        }
        public virtual T PopulateRecord(SqlDataReader reader)
        {
            return null;
        }
        public virtual void GetDataCount(int count)
        {
        }
        protected IEnumerable<T> GetRecords(SqlCommand command)
        {
            var list = new List<T>();
            command.Connection = _connection;
            _connection.Open();
            try
            {
                var reader = command.ExecuteReader();
                try
                {
                    while (reader.Read())
                    {
                        list.Add(PopulateRecord(reader));
                    }
                    reader.NextResult();
                    if (reader.HasRows)
                    {
                        while (reader.Read())
                        {
                            GetDataCount(Convert.ToInt32(reader["Count"].ToString()));
                        }
                    }
                }
                finally
                {
                    // Always call Close when done reading.
                    reader.Close();
                }
            }
            catch(Exception ex)
            {
                string Msg = ex.Message;
            }
            finally
            {
                _connection.Close();
            }
            return list;
        }
        protected T GetRecord(SqlCommand command)
        {
            T record = null;
            command.Connection = _connection;
            _connection.Open();
            try
            {
                var reader = command.ExecuteReader();
                try
                {
                    while (reader.Read())
                    {
                        record = PopulateRecord(reader);
                        break;
                    }
                }
                finally
                {
                    // Always call Close when done reading.
                    reader.Close();
                }
            }
            finally
            {
                _connection.Close();
            }
            return record;
        }
        protected IEnumerable<T> ExecuteStoredProc(SqlCommand command)
        {
            var list = new List<T>();
            command.Connection = _connection;
            command.CommandType = CommandType.StoredProcedure;
            _connection.Open();
            try
            {
                var reader = command.ExecuteReader();
                try
                {
                    while (reader.Read())
                    {
                        var record = PopulateRecord(reader);
                        if (record != null) list.Add(record);
                    }
                }
                finally
                {
                    // Always call Close when done reading.
                    reader.Close();
                }
            }
            finally
            {
                _connection.Close();
            }
            return list;
        }
    }
   public class StudentRepository : AdoRepository<Student>
    {
        public int DataCounter { get; set; }
        public StudentRepository(string connectionString)
            : base(connectionString)
        {
        }
        public IEnumerable<Student> GetAll()
        {
            // DBAs across the country are having strokes 
            //  over this next command!
            using (var command = new SqlCommand("SELECT ID, FirstName,LastName,IsActive,StateName,CityName FROM vwListStudents"))
            {
                return GetRecords(command);
            }
        }
        public Student GetById(string id)
        {
            // PARAMETERIZED QUERIES!
            using (var command = new SqlCommand("SELECT ID, FirstName,LastName,IsActive,StateName,CityName FROM vwListStudents WHERE Id = @id"))
            {
                command.Parameters.Add(new ObjectParameter("id", id));
                return GetRecord(command);
            }
        }
        public IEnumerable<Student> GetStudents(int StartIndex, int EndIndex, string sortCol, string sortOrder)
        {
            string strSQL = "SELECT * FROM vwListStudents WHERE ID >=" + StartIndex + " AND ID <=" + EndIndex;
            strSQL += " ORDER BY " + sortCol + " " + sortOrder;
            strSQL += ";SELECT COUNT(*) AS Count FROM vwListStudents";
            var command = new SqlCommand(strSQL);
            return GetRecords(command);
        }
        public override Student PopulateRecord(SqlDataReader reader)
        {
            return new Student
            {
                ID = Convert.ToInt32(reader["ID"].ToString()),
                FirstName = reader["FirstName"].ToString(),
                LastName = reader["LastName"].ToString(),
                IsActive = Convert.ToBoolean(reader["IsActive"]),
                StateName = reader["StateName"].ToString(),
                CityName = reader["CityName"].ToString()
            };
        }
        public override void GetDataCount(int count)
        {
            DataCounter = count;
        }
    }

这样添加工作单元代码

public class UnitOfWorkFactory
{
    public static IUnitOfWork Create()
    {
        var connection = new SqlConnection(ConfigurationManager.ConnectionStrings("MyDb").ConnectionString);
        connection.Open();
        return new AdoNetUnitOfWork(connection, true);
    }
}
public class AdoNetUnitOfWork : IUnitOfWork
{
    public AdoNetUnitOfWork(IDbConnection connection, bool ownsConnection)
    {
        _connection = connection;
        _ownsConnection=ownsConnection;
        _transaction = connection.BeginTransaction();
    }
    public IDbCommand CreateCommand()
    {
        var command = _connection.CreateCommand();
        command.Transaction = _transaction;
        return command;
    }
    public void SaveChanges()
    {
        if (_transaction == null)
            throw new InvalidOperationException("Transaction have already been commited. Check your transaction handling.");
        _transaction.Commit();
        _transaction = null;
    }
    public void Dispose()
    {
        if (_transaction != null)
        {
            _transaction.Rollback();
            _transaction = null;
        }
        if (_connection != null && _ownsConnection)
        {
            _connection.Close();
            _connection = null;
        }
    }
}
using (var uow = UnitOfWorkFactory.Create())
{
    var repos = new UserRepository(uow);
    uow.SaveChanges();
}
public class UserRepository
{
    private AdoNetUnitOfWork _unitOfWork;
    public UserRepository(IUnitOfWork uow)
    {
        if (uow == null)
            throw new ArgumentNullException("uow");
        _unitOfWork = uow as AdoNetUnitOfWork;
        if (_unitOfWork == null)
            throw new NotSupportedException("Ohh my, change that UnitOfWorkFactory, will you?");
    }
    public User Get(Guid id)
    {
        using (var cmd = _unitOfWork.CreateCommand())
        {
            cmd.CommandText = "SELECT * FROM Users WHERE Id = @id");
            cmd.AddParameter("id", id);
            // uses an extension method which I will demonstrate in a 
            // blog post in a couple of days
            return cmd.FirstOrDefault<User>();
        }
    }
}

但是我想在我的存储库类中添加工作单元代码。 可能属于AdoRepository类或StudentRepository类 因此，我不必一次又一次地编写以下代码。

using (var uow = UnitOfWorkFactory.Create())
{
    var repos = new UserRepository(uow);
    uow.SaveChanges();
}

因此，当我使用像UserRepository这样的任何存储库时，我必须一次又一次地重复这行代码UnitOfWorkFactory.Create()我不想要的，而是我正在寻找一种方法将工作单元代码嵌入到一些集中的地方，因此我可以减少重复的代码。

所以寻找想法和建议。 如果可能的话，给我修改后的代码版本。

谢谢