Как получить результаты пакетного чтения Npgsql в несколько объектов ViewModel вызывающего абонента? ⇐ C#

[Anonymous]

В настоящее время я разрабатываю приложение C# WinUI, которое получает большой объем данных из базы данных Postgresql. Я использую адаптер базы данных Npgsql и могу без проблем просто читать каждую ViewModel/DataModel отдельно из базы данных, но это создает много отдельных операций чтения из базы данных.
Npgsql теперь обеспечивает пакетную обработку для уменьшения количество обращений к серверу туда и обратно. Добавить команду NpgsqlBatch и выполнить ее в базе данных легко.
Я не могу понять, как вернуть результаты в ViewModels объектно-ориентированным способом.< /p>
В качестве примера.
У меня есть модель представления/данных контакта:

Код: Выделить всё

Public Class ContactViewModel
{
private Guid _contactID;
private Guid _companyID;
private Guid _personID;
private CompanyViewModel _company;
private PersonViewModel _person;
private const int _readBatchSize = 8;
// REadBatchSize is determined from the number of model objects, including sub objects.

private ObserverableCollection Roles;

public ContactViewModel GetContact(contactID)
{
postgresDataSource pgDatabase = myNpgsqlWrapper.getDatabase;
Guid batchGuid = pgDatabase.StartNewBatch();

_company = CompanyViewModel.GetCompany(_companyID, batchGuid);
_person = PersonViewModel.GetPerson(_personID, batchGuid);

foreach(role in await RolesViewModel.GetRoles(_contactID, batchGuid)
{
Roles.add(role)
}
}
}

Тогда, например, модель представления компании включает следующее:

Код: Выделить всё

public CompanyViewModel
{
private Guid _companyID;
private string _companyName;
private string _companyRegistrationNumber;

public ObservableCollection Offices;

public GetCompany(Guid companyID, Guid batchGuid)
{
var batchCommand = new NpgsqlBatchCommand("SELECT companyid, companyname,registrationnumber from company where companyid = ($1)");
batchCommand.Parrameters.Add(new {Value = companyID});

NpgsqlDataReader reader = myNpgsqlWrapper.AddCommandToBatch(batchCommand, batchGuid)
if(reader.HasRows)
{
while (await reader.ReadAsync())
{
CompanyDataModel company = new();
if (!reader.IsDBNull(0)) _companyID = reader.GetGuid(0);
if (!reader.IsDBNull(1)) _companyName = reader.GetString(1);
if (!reader.IsDBNull(2)) _companyRegistrationNumber = reader.GetString(2);
}
}
foreach(office in CompanyOffice.GetOffices(companyid, Guid batchGuid)
{
Offices.Add(office);
}
}
}

Небольшой вспомогательный класс/структура

Код: Выделить всё

public class PostgresqlBatchCallbackManager
{
public int BatchSize;
public Guid BatchID;
public NpgsqlBatch Batch;
}

Наконец, в классе myNpgsqlWrapper у меня есть вспомогательный класс и два соответствующих метода.

Код: Выделить всё

public class myNpgsqlWrapper
{
private static NpgsqlDataSource dataSource;
private Dictionary batchDict = new();

public static Guid StartNewBatch(int batchSize)
{
Guid batchID = Guid.NewGuid();
PostgresqlBatchCallbackManager manager = new()
manager.BatchSize = batchSize;
manager.BatchID = batchID;
manager.Batch = dataSource.CreateBatch();
return batchID;
}

public static async Task AddCommandToReadBatch(Guid batchID, NpgsqlBatchCommand batchCommand)
{
PostgresqlBatchManager batchManager = batchDict[batchID];
batchManager.BatchCommands.Add(batchCommand);

if(batchManager.Batch.BatchCommands.Count == batchManager.BatchSize)
{
await batchMAnager.Batch.PrepareAsync();
await using var reader = await batchManager.Batch.ExecuteReaderAsync();
do
{
while (await reader.ReadAsync())

// Need to pass the Reader back to the caller ViewModels?

} while (await reader.NextResultAsync());

}

}
}

Я знаю, что мне нужно реализовать какую-то систему асинхронного обратного вызова, но не знаю, как это сделать?

Подробнее здесь: https://stackoverflow.com/questions/783 ... el-objects