Easy repositories for .Net built on Dapper.
A repository is a service that provides an abstraction data access and persistance. It gives you a central place to construct how you will query your data, and a consistent set of methods for performing all of the CRUD operations against a particular resource stored in a database.
There are two base abstract classes you can implement that operate on a set of generics you provide.
RepositoryBase provides all CRUD (Create Read Update Delete) operations.
ReadOnlyRepositoryBase provides read only operations.
It uses centers around a model as a POCO (Plain Old C# Object) that represents the data / resource to be retrieved and inserted. This is supplied as the first generic you provide to your repository TModel.
It accepts the template for querying / constraining the data it returns as values provided against a template known as a constraint model. In simplest form, your TModel can also serve as your TConstraints, but can either be a limited set of fields (if you don't want to allow your data to be queried by every field available), or by extending the querying capability of your repository with additional properties that you define custom queries for in the form of Custom Constraints (see below). Constraints form the "input" to the repository which ultimately will be used to query the database. This is the second generic you provide to your repository TConstraintsModel. The TConstraintsModel provides a template that can be used to define / map the fields to database columns and data types.
The constraints model is simply a template / map for how to structure the data contained in your database table, view or table function. You will actually supply the values to query in several formats all of which must be matched to fields on your TConstraintsModel.
- A
System.Collections.Hashtable- Most common - A JSON String representation
These are ultimately converted into a list of Constraint objects, which is used to form parameterized queries in the form of a Bindable object which is given to Dapper to execute as a query.
Queries can also be performed with
- Newtonsoft
JObject List<Constraint>Bindable
Create, Update/Insert and delete operations are performed via TModel.
See the following diagram for how input (as represented by the TConstrainsModel as the template / map) are converted into a list of results in the form of your TModel.
Install the nuget package
dotnet add package Formula.SimpleRepo --version 1.0.*Add a connection to your database (appsettings.json)
{
"ConnectionStrings": {
"DefaultConnection": "Server=database.server.com;Database=MyAppDB;User=my_user;Password=my_pw!;MultipleActiveResultSets=true"
}
}For console applications, enable configuration and dependency injection
dotnet add package Microsoft.Extensions.Configuration
dotnet add package Microsoft.Extensions.Configuration.FileExtensions
dotnet add package Microsoft.Extensions.Configuration.Jsonusing Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Configuration.FileExtensions;
using Microsoft.Extensions.Configuration.Json;
using Microsoft.Extensions.DependencyInjection;
...
var config = new ConfigurationBuilder()
.SetBasePath(Directory.GetCurrentDirectory())
.AddJsonFile("appsettings.json", true, true)
.Build();
var services = new ServiceCollection();
services.AddSingleton<IConfiguration>(config)
.BuildServiceProvider();The model represents a single record mapping between a table or view on your datasource and a POCO (plain old c# object) for use within your application.
Annotate your model with the the connection to use from your appSettings, the Table or view to use.
Various other attributes can be used to provide additional mapping assistance (such as Key, Column, GUID). See Dapper.SimpleCRUD for details
using System;
using Dapper;
using Formula.SimpleRepo;
namespace MyApi.Data.Models
{
[ConnectionDetails("DefaultConnection")]
[Table ("Todos")]
public class Todo
{
[Key]
public int Id { get; set; }
public String Details { get; set; }
public Boolean Completed { get; set; }
public int? CategoryId { get; set; }
}
}SqlServer is treated as the default connection type, but you can alter the database used (any IDbConnection implementation), as well as the dialect details in the ConnectionDetails attribute.
[ConnectionDetails("DefaultConnection", typeof(DB2Connection), Dapper.SimpleCRUD.Dialect.PostgreSQL)]
[Table("MY_WEIRD_TABLE", Schema="MY_SCHEMA")]
public class MyNormalModel
{
[Dapper.Key]
[Column("ABC#")]
public int Id { get; set; }
}The models can take a table, a view, or a table function. If you specify a table function you have a few options for providing the data necessary for the table function parameters. You can specify the parameter references within the TableAttribute as follows.
[ConnectionDetails("DefaultConnection", typeof(DB2Connection), Dapper.SimpleCRUD.Dialect.PostgreSQL)]
[Table("TABLE_FUNCTION", Schema="MY_SCHEMA", Parameters=new string[] {"Param1", "Param2"})]
public class TableFunctionModel
{
[Column("COLUMNA")]
public int FriendlyNameA { get; set; }
[Column("COLUMNB")]
public string FriendlyNameB { get; set; }
}These will be translated as parameters in the raw query used against the database.
Select "COLUMNA" as "FriendlyNameA" from Table("MY_SCHEMA"."TABLEFUNCTION"(@Param1, @Param2)) WHERE "COLUMNA" = @FriendlyNameA AND "COLUMNB" = @FriendlyNameBThe values for the parameters can be specified in 1 of two ways. They can be fashioned in such a way that they will be provided by constraints.
[Table("TABLE_FUNCTION", Schema="MY_SCHEMA", Parameters=new string[] {"FriendlyNameA", "FriendlyNameB"})]In a situation like this, nothing futher needs to happen other than to make sure the required constraints are in fact provided to the repository.
Note - When using this method use the friendly name, not the actual column name.
var constraints = new Hashtable() { { "FriendlyNameA", 1234 }, { "FriendlyNameB", "abc" } };
var results = await _repository.GetAsync(constraints);Othewise, you can specify the parameters on the list of repository parameters.
[Table("TABLE_FUNCTION", Schema="MY_SCHEMA", Parameters=new string[] {"Param1", "Param2"})]_repository.AddParameter("Param1", 1234);
_repository.AddParameter("Param2", "abc");
var results = await _repository.GetAsync();Note - In a situation like this, use a unique parameter, otherwise, the parameter you supply to the repository will override any that match the parameter name later.
The repository provides simple CRUD operations ( provided by Dapper.SimpleCRUD ), simple constrainable operations (query by JSON), as well as a single place to wrap business concepts into data fetch / store operations by custom function you provide.
The simplest implementation of a repository to take advantage of simple CRUD and constrainables can be implemented as follows.
using System;
using Microsoft.Extensions.Configuration;
using Formula.SimpleRepo;
using MyApi.Data.Models;
namespace MyApi.Data.Repositories
{
[Repo]
public class TodoRepository : RepositoryBase<Todo, Todo>
{
public TodoRepository(IConfiguration config) : base (config)
{
}
}
}Repositories can be registered into the dependency injection system by implementing a couple steps. In the ConfigureServices section of Startup.cs make sure to make a call to AddRepositoriesInAssembly. Failing to do so will result in controllers depending on these repositories being unable to resolve service for these repository types.
InvalidOperationException: Unable to resolve service for type '...' while attempting to activate '...'.
All repositories in your project, decorated with the [Repo] attribute will be injected.
using Formula.SimpleRepo;
...
services.AddRepositoriesInAssembly();If your repositories exists in a different project / library / assembly, you can either specify the assembly directly;
// var repoAssembly = <some function to determine the assembly>
services.AddRepositoriesInAssembly(repoAssembly);Or you can pass just one example repository, and the rest will be found.
services.AddRepositoryByType(typeof(MyOtherProject.Data.MyRepository));Note - If using these strategies, you do not need to add each new repository, you only have to decorate them with the [Repo] annotation.
Now you can perform all queries and CRUD operations against the models. For dynamic / business defined constrainables see further steps below. But you now have enough to perform basic operations against your data.
Example...
var repo = new TodoRepository(config);
foreach(var item in await repo.GetAsync())
{
Console.WriteLine(item.Details);
}Read Operations
There are async versions of all methods.
*GetAsync- Fetch data*
// Get a single item by it's ID
var record = await repo.GetAsync(21); // Can be number or GUID
// Get all records
var records = await repo.GetAsync();
// Get by specific fields using JSON to define your constraints
records = await repo.GetAsync("{Completed:true}");
// Get by hash table
records = await repo.GetAsync(new Hashtable() { { "Completed", true } });
// Additional methods like fetching via JObject, Bindable (advanced concept), etc..
// Get a list of all the identity columns
var idFields = repo.GetIdFields();
// You also have access to other operations provided by SimpleCRUD via the Basic property
// These do not apply non database / dynamic constrainable concepts described below
records = awai repo.Basic.GetListAsync("where column_name like '%asdf%'");
var pagedData = await repo.Basic.GetListPagedAsync(1, 10, "where column_a = 'asdf'");
var recordCount = repo.Basic.RecordCount("where column_name like '%asdf%'");
// etc...Dapper.SimpleCRUD You still have access to all the dapper SimpleCRUD you are used too.
CRUD Operations
Like above, there are async versions of all methods.
// Delete
repo.DeleteAsync(21); // Can be number or GUID
// Insert
var modelToSave = new Todo() {
Details = "Do a backflip",
Completed = false,
};
var newId = await repo.InsertAsync(modelToSave);
// Update
var modelToSave = new Todo() {
Id = 21,
Details = "Do a backflip",
Completed = true,
};
repo.UpdateAsync(modelToSave);
// Like with the basic query operations, you also still have access to other basic
// operations that don't apply to the constrainable types.
repo.Basic.DeleteListAsync("where yadda yadda...");A constraint is anything you want to be able to expose querying for resources by. By default, you can simply provide the POCO model as the constrainable definition, allowing your repository to support searching by any field modeled out on your model. If you want to limit what fields users of your repository can query by, you can specify a constraint model with less fields available as the output of your repository. Additionally, custom constraints can also be used to extend the search functionality by providing custom / dynamic fields to represent additional concepts to search by that might not be expressed in a single column already on your resource model.
You can now start defining new columns on your repository that don't exist as columns in your database, which represent "concepts". These further allow you to constrain your data.
The implementation of this is explained in implementation details below. For now, try to understand the concept. If you can define additional ways to represent a record / resource, you can then begin querying against it as if it were a column in the database.
Consider that you have a date column, you might want to be able to fetch records that have dates in the past or in the future, or in the past, or other concepts which are hard to express without coding logic (paydays, near me geographically, if certain things exist on file systems, etc..). You can implement concepts that depend on other criteria outside of things which can be expressed in your database.
For things like this, adding custom constraints are the solution.
var records = await repo.GetAsync(new Hashtable() { { "FutureRecords", true } });
...
var records = await repo.GetAsync(new Hashtable() { { "NearMe", true } });
...
var records = await repo.GetAsync(new Hashtable() { { "AtStockPoint", myVariable } });Example..
Suppose we wanted to allow our todo list to be able to be queried by a particular keyword found in the details of the todo.
We can create a class extending the Todo model defining a new constraint called DetailsLike. We first must define this new constraint (by extending Constraint), and we must implement the Bind method that handles building the query for values.
public class DetailsLike : Constraint
{
public override Dictionary<String, Object> Bind(Dapper.SqlBuilder builder)
{
var parameters = new Dictionary<String, Object>();
builder.Where("UPPER(Details) like @DetailsLike");
parameters.Add("DetailsLike", "%" + this.Value.ToString().ToUpper() + "%");
return parameters;
}
}Since we want to allow constraint binding against all of the current properties on our model, we can extend our Todo model and add an additional field called DetailsLike.
public class TodoConstraints : Todo
{
public DetailsLike DetailsLike { get; set; }
}We can now pass our custom constraints (which include our dynamic custom constraint DetailsLike) to our repository as the second template supplied to the RepositoryBase.
public class TodoRepository : RepositoryBase<Todo, TodoConstraints>You might also only want certain records to be returned based on some certain "scope". Scoped constraints, are constraints that get applied automatically with every request. These are applied in addition to (and instead of) any constraints applied that might be present. These are useful for applying default constraints that need to be applied every time, and also as a strategy for limiting the scope of the data returned for security reasons, or other creative business rule purposes. You can also programmatically turn these on and off.
For example, if I want to limit the scope of data, so that users can only see their data based on their user id, I can apply a scoped constraint. This way if a request for all data, is made, the server side can limit the results.
On your repository implementation override the ScopedConstraints function.
The input for this function is all the currently applied constraints that are being applied (which could be useful for various business rule purposes).
The expected output of this function is a list of constraints you want to apply (or override). You can be explicit on the behavior and introduce totally new constraints that have even been created on your model, or you can create a hashtable to match constraints on your model and call the GetConstraints function to have them generated using the design of the model based constraints (or custom constrains you have previously designed).
[Repo]
public class MyRepo : ReadOnlyRepositoryBase<MyOutputModel, MyConstraintsModel>
{
public BusinessTransferRepository(IConfiguration config) : base(config)
{
}
public override List<Formula.SimpleRepo.Constraint> ScopedConstraints(List<Formula.SimpleRepo.Constraint> currentConstraints)
{
var constraints = new Hashtable();
constraints.Add("UserName", this._userId);
return this.GetConstraints(constraints);
}
}Example use;
var constraints = new Hashtable();
constraints.Add("Active", true);
_myRepositoryInstance.Get(constraints);Will result in all active records, assigned to the currently logged in user, because my repository is limiting the scope by logged in user.
If you wish to temporarily disable the scoped constraints you can call the RemoveScopedConstraints on your repository before calling Get.
var constraints = new Hashtable();
constraints.Add("Active", true);
_myRepositoryInstance.RemoveScopedConstraints().Get(constraints);This will result in all active records, regardless of the logged in user.
It is also the case that sometimes there are required constraints that you want to always ensure are in use with your repository. For this you can also leverage the ScopedConstraints method, to enforce certain constraints presence or throw an error if not provided.
The following example will throw an error if your repository is attempted to be used without a required value (BusinessCustomerKey) provided.
public override List<Formula.SimpleRepo.Constraint> ScopedConstraints(List<Formula.SimpleRepo.Constraint> currentConstraints)
{
currentConstraints.EnsureConstraintExists("BusinessCustomerKey");
return null;
}If you wish to implement business logic constraints that will not impact the query, you can use a combination of scoped query constraints and NoQueryConstraint to still be able to receive input from the endpoint, but not have any bindable parameters you wish executed to against the database. An example use case might be, based on a users request, you may want to provide a switch for the request, that may or may not require you to supply certain scoped constraints (If I'm and admin and I want to view everything, allow it, otherwise limit the scope by applying a scoped constraint)
Constraints are treated as "IS NULL" in one of 3 ways.
- Explicitly
- Verbosely
- Implicitly / Assumed
See the
IsNullComparisonfunction inConstriant.csfor implementation.
In each case a constraint that is determined to be null will produce "WHERE x IS NULL".
To explicitly set a constraint to null, leave the value null.
constraints.Add("MyValue", null);To Verbosely set a constraint to null, use the word NULL as a string.
constraints.Add("MyValue", "NULL");The implicitly / assumed null is a programmatic decision within the library. So this is the least desirable means of producing a null constraint.
If a value is considered to be empty for a datatype that doesn't support empty (such as strings), it will be assumed this is to be a null constraint.
constraints.Add("MyValue", ""); // Where MyValue is an int and "" is an empty valueIt's sometimes useful to allow data to be mutated / transformed from one format which is more useful in business logic, to another data format used by the database, by providing a way to transform the data before it is used in a query. The original use case was needing to accept a normal Gregorian date from a user, however the database column didn't support a normal Gregorian date format (represented as a typical c# DateTime example 12/31/2021), but instead used Julian date format (represented as an int same example in Julian is 2021365). Instead of requiring the client to support this unusual date format and prepare constraints as Julian format, the value and even the data type can be changed by overriding the TransformConstraints method on the repository.
[Repo]
public class MyRepo : ReadOnlyRepositoryBase<MyOutputModel, MyConstraintsModel>
{
public BusinessTransferRepository(IConfiguration config) : base(config)
{
}
public override List<Formula.SimpleRepo.Constraint> TransformConstraints(List<Formula.SimpleRepo.Constraint> currentConstraints)
{
// Start Date is actually stored in the database as an int in Julian format
currentConstraints.TransformConstraint("StartDate", (constraint) =>
{
constraint.DataType = System.TypeCode.Int32;
constraint.Value = constraint.Value?.ToString().ToJulianDate();
return constraint;
});
// End Date is actually stored in the database as an int in Julian format
currentConstraints.TransformConstraint("EndDate", (constraint) =>
{
constraint.DataType = System.TypeCode.Int32;
constraint.Value = constraint.Value?.ToString().ToJulianDate();
return constraint;
});
return currentConstraints;
}
}The InsertSuffix attribute can be used to provide a suffix to the insert statement. This is useful for certain databases that require a suffix to be added to the insert statement. For example, in DB2, you might want to add WITH NONE to the end of the insert statement.
[InsertSuffix("WITH NONE")]
public class MyModel
{
public int Id { get; set; }
public string Name { get; set; }
}When doing in insert, the insert statement will be appended with the suffix.
INSERT INTO MY_TABLE (ID, NAME) VALUES (@Id, @Name) WITH NONEThe Formula.SimpleAPI project provides utilities to expose your repository as a RESTful API.
classDiagram
ConstrainableBase <|-- BuilderBase
BuilderBase <|-- ReadOnlyRepositoryBase
ReadOnlyRepositoryBase <|-- RepositoryBase
RepositoryBase <|-- YourRepository
class YourRepository{
}
class RepositoryBase{
<<Abstract>>
+BasicCRUD Basic
InsertAsync()
UpdateAsync()
DeleteAsync()
}
RepositoryBase --> BasicCRUD: Basic
class ReadOnlyRepositoryBase{
<<Abstract>>
+BasicQuery Basic
GetIdFields()
GetAsync()
}
ReadOnlyRepositoryBase --> BasicQuery: Basic
class BuilderBase{
<<Abstract>>
-Dictionary~string,object~ _parameters
ApplyScopedConstraints()
RemoveScopedConstraints()
ScopedConstraints()
TransformConstraints()
MergeConstraints()
AddParameter()
CombineParameters()
Where()
WhereFromJson()
}
TConstraintsModel <|-- ConstrainableBase
TConstraintsModel ..> Constraint : "Properties Become"
class TConstraintsModel{
+string Column1
+string Column2
+int Column3
}
class ConstrainableBase~TConstraintsModel~{
<<Abstract>>
GetDatabaseColumnName(): string
GetConstrainables(): List~Constraint~
GetConstraints(): List~Constraint~
}
Constraint "1..*" --> "1" ConstrainableBase
class Constraint{
+string Column
+string DatabaseColumnName
+object Value
+TypeCode DataType
+bool Nullable
+Comparison Comparison
}
BasicQueryBase <|-- BasicCRUDBase
class BasicQueryBase{
<<Abstract>>
+SimpleCRUD BasicSimpleCRUD
GetAsync()
GetlistAsync()
GetListPagedAsync()
RecordCountAsync()
}
BasicQueryBase --> SimpleCRUD: BasicSimpleCRUD
SimpleCRUD ..> BasicQueryBase : "Resuls as List of TConstraintsModel"
class BasicCRUDBase{
<<Abstract>>
DeleteAsync()
DeleteListAsync()
InsertAsync()
UpdateAsync()
}
BasicCRUDBase <|-- BasicCRUD
class BasicCRUD{
CreateOperations
ReadOperations
UpdateOperations
DeleteOperations
}
BasicQueryBase <|-- BasicQuery
class BasicQuery{
ReadOperations
}
class SimpleCRUD{
Dapper
RawSQL
}