Faactory.DbContext.Npgsql
0.7.2
dotnet add package Faactory.DbContext.Npgsql --version 0.7.2
NuGet\Install-Package Faactory.DbContext.Npgsql -Version 0.7.2
<PackageReference Include="Faactory.DbContext.Npgsql" Version="0.7.2" />
paket add Faactory.DbContext.Npgsql --version 0.7.2
#r "nuget: Faactory.DbContext.Npgsql, 0.7.2"
// Install Faactory.DbContext.Npgsql as a Cake Addin #addin nuget:?package=Faactory.DbContext.Npgsql&version=0.7.2 // Install Faactory.DbContext.Npgsql as a Cake Tool #tool nuget:?package=Faactory.DbContext.Npgsql&version=0.7.2
ADO.NET Extensions
This project contains a set of extensions to help with managing multiple data sources, more specifically, inside a DI scenario.
Getting started
Before we can use the extensions, we need to register the context provider with our DI container. We'll have to install the appropriate package, depending on the provider we want to use; the following are currently supported
Provider | Package | Description |
---|---|---|
PostgreSql | Faactory.DbContext.Npgsql | PostgreSQL driver; uses Npgsql |
SqlServer | Faactory.DbContext.SqlClient | SQL Server driver; uses Microsoft.Data.SqlClient |
Sqlite | Faactory.DbContext.Sqlite | SQLite driver; uses Microsoft.Data.Sqlite |
SqlServer | Faactory.DbContext.RestSql | SQL Server via restSQL; still experimental |
We'll use SqlServer as an example
dotnet add package Faactory.DbContext.SqlClient
We'll then register the provider and configure our databases; we can add as many contexts as we need.
IServiceCollection services = ...;
services.AddSqlDbContextProvider()
.AddDbContext( "my-db", "connection_string" )
.AddDbContext( "my-other-db", "connection_string" );
Wherever we need to get access to our database context, we'll use the injected IDbContextFactory
instance to retrieve an IDbContext
instance.
public class Example
{
private readonly IDbContext mydb;
public Example( IDbContextFactory dbContextFactory )
{
mydb = dbContextFactory.GetDbContext( "my-db" );
}
// ...
}
To construct a new connection, we'll retrieve it from the IDbContext
instance.
public class Example
{
private readonly IDbContext mydb;
// ...
public async Task DoSomethingAsync()
{
using ( var connection = mydb.GetDbConnection() )
{
await connection.OpenAsync();
// ...
}
}
}
We can also construct the connection and open it all in one go.
public async Task DoSomethingAsync()
{
using ( var connection = await mydb.OpenAsync() )
{
// ...
}
}
From this point forward, we'll have a DbConnection
instance ready to use. Please note that all DbConnection
instances should be properly disposed after use. Most of the ADO implementations will pool connections and not properly disposing them can lead to exceeding the number of open connections (connection leaks).
NOTICE: Starting with version 0.6, the library has switched to use the
DbConnection
class instead of theIDbConnection
interface. This was done mostly because the interface doesn't expose the async methods. SinceDbConnection
should be the base class for most (if not all) ADO.NET providers, this transition shouldn't cause any braking changes. Nonetheless, if you're using theIDbConnection
interface, you'll have to update your code to use theDbConnection
class instead.
Transactions
As an alternative to the DbConnection.BeginTransaction[Async]
methods, there are extensions available to shorten the amount of code written. The UseTransaction[Async]
methods take care of opening/reusing a connection, creating a transaction and gracefully disposing of it all when finished.
public async Task DoSomethingAsync()
{
await mydb.UseTransactionAsync( async t =>
{
var sqlCommand = t.Connection.CreateCommand();
// ...
await t.CommitAsync();
} );
}
If an exception is thrown, the transaction is automatically rolled back. We can also provide additional behaviour to when this happens.
public async Task DoSomethingAsync()
{
await mydb.UseTransactionAsync( async t =>
{
var sqlCommand = t.Connection.CreateCommand();
// ...
await t.CommitAsync();
}, ex =>
{
// handle exception
} );
}
Health checks
The library also provides a set of health checks that verify the status of the database contexts. These health checks can be used with the ASP.NET Core health checks middleware.
IServiceCollection services = ...;
services.AddHealthChecks()
.AddDbContext( "my-db" )
.AddDbContext( "my-other-db" );
Command builder
The command builder is a helper class that can be used to build SQL commands. It provides a fluent interface to build a DbCommand
instance. The builder can be accessed by calling the BuildCommand
extension method on IDbContext
or DbConnection
instances.
private readonly IDbContext mydb;
// ...
/*
This example creates a command builder from the connection instance.
This is the most straightforward way to use the builder.
*/
public async Task UseBuilderFromConnectionAsync()
{
using ( var connection = await mydb.OpenAsync() )
{
var command = connection.BuildCommand()
.SetText( "SELECT * FROM table WHERE id = @id" )
.AddParameter( "@id", 1 )
.Build();
using ( var reader = await command.ExecuteReaderAsync() )
{
// ...
}
}
}
/*
This example creates a command builder directly from the context instance.
Please note that in this caase, the command builder will ask for a connection
instance from the context that you'll have to properly dispose of it after use.
You'll also have to open the connection before using it.
*/
public async Task UseBuilderFromContextAsync()
{
var command = mydb.BuildCommand()
.SetText( "SELECT * FROM table WHERE id = @id" )
.AddParameter( "@id", 1 )
.Build();
// ensure that the connection is properly disposed of after use
using ( command.Connection )
{
// we are responsible for opening the connection before using it
await command.Connection.OpenAsync();
using ( var reader = await command.ExecuteReaderAsync() )
{
// ...
}
}
}
Compatibility with Object Mappers
The library is fully compatible with most object mappers that use DbConnection
or IDbConnection
instances, such as Dapper, PetaPoco or Norm.net.
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net6.0 is compatible. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 is compatible. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 is compatible. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. |
-
net6.0
- Faactory.DbContext.Core (>= 0.7.2)
- Microsoft.Extensions.Options (>= 8.0.2)
- Npgsql (>= 8.0.3)
-
net7.0
- Faactory.DbContext.Core (>= 0.7.2)
- Microsoft.Extensions.Options (>= 8.0.2)
- Npgsql (>= 8.0.3)
-
net8.0
- Faactory.DbContext.Core (>= 0.7.2)
- Microsoft.Extensions.Options (>= 8.0.2)
- Npgsql (>= 8.0.3)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.
Version | Downloads | Last updated |
---|---|---|
0.7.2 | 102 | 8/27/2024 |
0.7.1 | 92 | 8/27/2024 |
0.7.0 | 116 | 5/31/2024 |
0.6.1 | 117 | 3/8/2024 |
0.6.0 | 260 | 10/23/2023 |
0.6.0-preview-1 | 98 | 9/27/2023 |
0.5.2-preview-2 | 120 | 9/26/2023 |
0.5.2-preview-1 | 110 | 9/25/2023 |
0.5.1 | 193 | 7/7/2023 |
0.5.0 | 175 | 4/27/2023 |
0.4.0 | 403 | 8/9/2022 |
0.3.5 | 438 | 3/23/2022 |
0.3.4 | 413 | 3/18/2022 |
0.3.3 | 406 | 3/18/2022 |
0.3.2 | 408 | 3/18/2022 |
0.3.1 | 412 | 3/18/2022 |
0.3.0 | 430 | 3/17/2022 |
0.2.2 | 431 | 3/16/2022 |
0.2.1 | 322 | 10/4/2021 |
0.1.0 | 329 | 9/29/2021 |