microservice.toolkit.connectionmanager 0.7.0

Connection Manager

The library is a work in progress. It is not yet considered production-ready.

Common interface to simplify the access to a SQL database.

How to install

Package Manager

Install-Package microservice.toolkit.connectionmanager -Version 0.7.0

.NET CLI

dotnet add package microservice.toolkit.connectionmanager --version 0.7.0

Package Reference

<PackageReference Include="microservice.toolkit.connectionmanager" Version="0.7.0" />

Available extensions methods

Execute<T>(Func<DbCommand, T>)

T Execute<T>(Func<DbCommand, T> lambda);

Execute<T>(string, Func<DbDataReader, T>, Dictionary<string, object>)

List<T> Execute<T>(string sql, Func<DbDataReader, T> lambda, Dictionary<string, object> parameters = null);

ExecuteFirst<T>(string, Func<DbDataReader, T>, Dictionary<string, object>)

T ExecuteFirst<T>(string sql, Func<DbDataReader, T> lambda, Dictionary<string, object> parameters = null);

ExecuteAsync<T>(Func<DbCommand, Task<T>>)

Task<T> ExecuteAsync<T>(Func<DbCommand, Task<T>> lambda);

ExecuteAsync<T>(string, Func<DbDataReader, T>, Dictionary<string, object>)

Task<List<T>> ExecuteAsync<T>(string sql, Func<DbDataReader, T> lambda, Dictionary<string, object> parameters = null);

ExecuteFirstAsync<T>(string, Func<DbDataReader, T>, Dictionary<string, object>);

Task<T> ExecuteFirstAsync<T>(string sql, Func<DbDataReader, T> lambda, Dictionary<string, object> parameters = null);

ExecuteNonQueryAsync(string, Dictionary<string, object>)

Task<int> ExecuteNonQueryAsync(string query, Dictionary<string, object> parameters);

Executes the query using parameters

GetCommand()

DbCommand GetCommand();

Creates a DbCommand for the current connection.

SafeOpen()

void SafeOpen();

Opens a connection to the database if it is not already opened.

SafeOpenAsync()

Task SafeOpenAsync();

Opens a connection to the database if it is not already opened.

SafeClose()

void SafeClose();

Closes a connection to the database if it is not already closed.

SafeCloseAsync()

Task SafeCloseAsync();

Closes a connection to the database if it is not already closed.