ThomasDataAdapter.SqlServer 1.2.0

ThomasDataAdapter

Simple strong typed library to get data from Database SQL Server especially high load and low memory consum.

It Works matching class fields vs result set returned by database query. There are simples configurations for general purpose as high load work.

Nuget : https://www.nuget.org/packages/ThomasDataAdapter.SqlServer/

Basic configuration in startup.cs :

using Thomas.Database.SqlServer;
.
.
.
serviceCollection.AddThomasSqlDatabase((options) => new ThomasDbStrategyOptions()
{
    StringConnection = @"Data Source={SourceName};Initial Catalog={database};User ID={User};Password={Pass}"
});

Custom configuration :

using Thomas.Database.SqlServer;
.
.
.
serviceCollection.AddThomasSqlDatabase((options) => new ThomasDbStrategyOptions()
{
    StringConnection = @"Data Source={SourceName};Initial Catalog={database};User ID={User};Password={Pass}",
    DetailErrorMessage = true,
    MaxDegreeOfParallelism = 4,
    ConnectionTimeout = 300,
    SensitiveDataLog = true
});

Inject IThomasDb interface in your component:

public class MyComponent
{
    private readonly IThomasDb _db;

    public MyComponent(IThomasDb db)
    {
        _db = db;
    }

    public IList<Person> GetPeople()
    {
        var response = _db.ToListOp<Person>("dbo.GetPeople");

        if(response.Success)
        {
            return response.Result;
        }
        else
        {
            Log.WriteLog(response.ErrorMessage);
        }
    }

    public void SavePeople(Person person)
    {
        var response = _db.ExecuteOp(person, "dbo.SavePerson");

        if(response.Success)
        {
            .
            .
            .
        }
        else
        {
            Log.WriteLog(response.ErrorMessage);
        }
    }

    public void UpdateAge(string name, int age)
    {
        var response = _db.ExecuteOp(new { vcName = name, nbAge = age}, "dbo.UpdateAge");

        if(response.Success)
        {
            .
            .
            .
        }
        else
        {
            Log.WriteLog(response.ErrorMessage);
        }
    }

    public void ProcessData()
    {
        var response = _db.ToTupleOp<Person, Office>("dbo.GetDataForProcess");

        if(response.Success)
        {
            IReadOnlyList<Person> persons = response.Result.Item1;
            IReadOnlyList<Office> offices = response.Result.Item2;
            .
            .
            .
        }
        else
        {
            Log.WriteLog(response.ErrorMessage);
        }
    }

    public void ManyFormsToGetData()
    {
        Person person = _db.ToSingle<Person>("SELECT * FROM Person WHERE Id = 43");

        IReadOnlyList<Person> people = _db.ToList<Person>("SELECT * FROM Person WHERE name like '%jhon%'");

        Tuple<IReadOnlyList<Person>, IReadOnlyList<Office>> peopleOffice = _db.Tuple<Person, Office>("SELECT * FROM Person WHERE name like '%jhon%'; SELECT * FROM Office WHERE name like '%US_%");
    }
}

More options to configure:

• Culture: Default 'en-US' (resource : https://docs.microsoft.com/en-us/openspecs/windows_protocols/ms-lcid/a9eac961-e77d-41a6-90a5-ce1a8b0cdb9c)
• User: Username for string connection.
• Password: Password for string connection. (type SecureString)
• StringConnection: This can be combine optionally with User and Password.
• DetailErrorMessage: Default false, return detail information when errors ocurrs and also parameters values.
• SensitiveDataLog: Default false, hide Parameters values.
• StrictMode: Default false, all columns returned from database query must be match with fields in the class.
• MaxDegreeOfParallelism: Default 1, useful when you need retrieve high volume of data and maintain original order. Depends on amount of logical processors you have
• ConnectionTimeout : Default 0, time out for database request.

Perfomance

The benchmark is in project Thomas.Tests.Performance

dotnet run -p .\Thomas.Tests.Performance\ -c Release -f net5.0 -- -f * --join

BenchmarkDotNet=v0.13.0, OS=Windows 10.0.19042.1466 (20H2/October2020Update)
Intel Core i7-8550U CPU 1.80GHz (Kaby Lake R), 1 CPU, 8 logical and 4 physical cores
.NET SDK=5.0.404
  [Host]     : .NET Core 3.1.22 (CoreCLR 4.700.21.56803, CoreFX 4.700.21.57101), X64 RyuJIT
  ShortRun   : .NET Core 3.1.22 (CoreCLR 4.700.21.56803, CoreFX 4.700.21.57101), X64 RyuJIT
  Job-QAXZEQ : .NET Core 3.1.22 (CoreCLR 4.700.21.56803, CoreFX 4.700.21.57101), X64 RyuJIT

Namespace=Thomas.Tests.Performance.Benchmark  Type=ThomasDataAdapterBenckmark