Язык программирования C#9 и платформа .NET5

Часть 403 из 642 Информация о книге
  Исследование класса SqlBulkCopy
 Класс 
SqlBulkCopy
 имеет один метод, WriteToServer()
 (и его асинхронную версию WriteToServerAsync()
), который обрабатывает список записей и помещает данные в базу более эффективно, чем последовательность операторов Insert
, выполненная с помощью объектов команд. Метод WriteToServer()
 перегружен, чтобы принимать объект DataTable
, объект DataReader
 или массив объектов DataRow
. Придерживаясь тематики главы, мы собираемся использовать версию WriteToServer()
, которая принимает DataReader
, так что необходимо создать специальный класс чтения данных.
  Создание специального класса чтения данных
 Желательно, чтобы специальный класс чтения данных был обобщенным и содержал список моделей, которые нужно импортировать. Создайте в проекте 
AutoLot.DAL
 новую папку по имени BulkImport
, a в ней — новый файл интерфейса IMyDataReader.cs
, реализующего IDataReader
, со следующим кодом:
using System.Collections.Generic;
using System.Data;
namespace AutoLot.Dal.BulkImport
{
  public interface IMyDataReader&lt;T&gt; : IDataReader
  {
    List&lt;T&gt; Records { get; set; }
  }
}
Далее реализуйте специальный класс чтения данных. Как вы уже видели, классы чтения данных содержат много частей, отвечающих за перемещение данных. Хорошая новость в том, что для 
SqlBulkCopy
 придется реализовать лишь несколько из них. Создайте новый файл класса по имени MyDataReader.cs
 и добавьте в него перечисленные ниже операторы using
:
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Reflection;
Сделайте класс открытым и запечатанным и обеспечьте реализацию классом интерфейса 
IMyDataReader
. Добавьте конструктор для принятия записей и установки свойства:
public sealed class MyDataReader&lt;T&gt; : IMyDataReader&lt;T&gt;
{
  public List&lt;T&gt; Records { get; set; }
  public MyDataReader(List&lt;T&gt; records)
  {
    Records = records;
  }
}
Предложите Visual Studio или Visual Studio Code самостоятельно реализовать все методы (либо скопировать их), что даст вам отправную точку для специального класса чтения данных. В рассматриваемом сценарии потребуется реализовать лишь члены, кратко описанные в табл. 21.7.
 
Начните с метода 
Read()
, который возвращает false
, если класс для чтения находится в конце списка, или true
 (с инкрементированием счетчика уровня класса), если конец списка еще не достигнут. Добавьте переменную уровня класса, которая будет хранить текущий индекс List&lt;T&gt;
, и обновите метод Read()
, как показано ниже:
public class MyDataReader&lt;T&gt; : IMyDataReader&lt;T&gt;
{
  ...
  private int _currentIndex = -1;
  public bool Read()
  {
    if (_currentIndex + 1 &gt;= Records.Count)
    {
      return false;
    }
    _currentIndex++;
    return true;
  }
}
Каждый метод 
GetXXX()
 и свойство FieldCount
 требуют знания специфической модели, подлежащей загрузке. Вот как выглядит метод GetValue()
, использующий CarViewModel
:
public object GetValue(int i)
{
  Car currentRecord = Records[_currentIndex] as Car;
  return i switch
  {
    0 =&gt; currentRecord.Id,
    1 =&gt; currentRecord.MakeId,
    2 =&gt; currentRecord.Color,
    3 =&gt; currentRecord.PetName,
    4 =&gt; currentRecord.TimeStamp,
    _ =&gt; string.Empty,
  };
}
База данных содержит только четыре таблицы, но это означает необходимость в наличии четырех вариаций класса чтения данных. А подумайте о реальной производственной базе данных, в которой таблиц гораздо больше!Решить проблему можно более эффективно с применением рефлексии (см. главу 17) и LINQ to Objects (см. главу 13).
Добавьте переменные 
readonly
 для хранения значений PropertyInfo
 модели и словарь, который будет использоваться для хранения местоположения поля и имени таблицы в SQL Server. Модифицируйте конструктор, чтобы он принимал свойства обобщенного типа и инициализировал объект Dictionary
. Ниже показан добавленный код:
Перейти к странице:
Предыдущая страница
Следующая страница