Data Access Layer in C# using Repository and Data Mapper – Part 4

The customer repository inherits the base repository and uses the data mapper instance for object creation. All the CRUD procedures defined in the first post of this series are called in this class. The query for accessing and persisting data in the relational model is formed in the Customer repository.

protected override BaseMapper<Customer, long> Mapper

{

    get

    {

        if (___Mapper == default(CustomerMapper)) ___Mapper = new CustomerMapper("CustomerIntId");

        return ___Mapper;

    }

}

public Customer GetById(long id)

{

    DbCommand command = ___Database.GetStoredProcCommand("usp_GetCustomerById");

    ___Database.AddInParameter(command, "CustomerIntId", DbType.Int64, id);

    return FindOne(command);

}

public void Insert(Customer entity)

{

    DbCommand command = ___Database.GetStoredProcCommand("usp_InsertCustomer");

    ___Database.AddInParameter(command, "FirstName", DbType.String, entity.FirstName);

    ___Database.AddInParameter(command, "LastName", DbType.String, entity.LastName);

    ___Database.AddInParameter(command, "Address", DbType.String, entity.Address);

    ___Database.AddOutParameter(command, "CustomerIntId", DbType.Int64, 8);

    ___Database.ExecuteNonQuery(command);

    Int64 customerIntId = (Int64)(___Database.GetParameterValue(command, "CustomerIntId"));

    entity.Id = customerIntId;

}

public void Remove(long id)

{

    DbCommand command = ___Database.GetStoredProcCommand("usp_DeleteCustomerById");

    ___Database.AddInParameter(command, "CustomerIntId", DbType.Int64, id);

    ___Database.ExecuteNonQuery(command);

}

I have uploaded the source code for the customer repository here.

[TestMethod]

public void can_insert_customers_into_db()

{

    ICustomerRepository repository = new CustomerRepository();

    var customerToInsert = new Customer { FirstName = "Prajeesh", LastName = "Prathap", Address = "BTM 2nd Stage, Bangalore" };

    repository.Insert(customerToInsert);

    var customer = repository.GetById(customerToInsert.Id);

    Assert.IsNotNull(customer);

    Assert.AreEqual<string>(customer.FirstName, "Prajeesh");

    repository.Remove(customer.Id);

}

Our final implementation looks like.