using AtlasX.Engine.Connector.Services; <em>// <-- namespace ของ IDbDataAccessService</em>
using AtlasX.Engine.Extensions; <em>// <-- นำมาใช้แปลง List เป็น DataTable</em>
using CsvHelper; <em>// <-- นำมาช่วยอ่านไฟล์ CSV, เวอร์ชัน 15.0.5</em>
...

namespace MyWebService.Controllers
{
  [Route("api/[controller]")]
  [ApiController]
  public class MyBulkCopyController : ControllerBase
  {
    private readonly IDbDataAccessService _dbDataAccessService;
    private readonly IWebHostEnvironment _hostingEnvironment;

    public MyBulkCopyController(
      IDbDataAccessService dbDataAccessService, <em>// <-- Inject DbDataAccessService</em>
      IWebHostEnvironment hostingEnvironment
    )
    {
      _dbDataAccessService = dbDataAccessService;
      _hostingEnvironment = hostingEnvironment;
    }
  }

  ...

}

using AtlasX.Engine.Connector.Services; <em>// <-- namespace ของ IDbDataAccessService</em>
using AtlasX.Engine.Extensions; <em>// <-- นำมาใช้แปลง List เป็น DataTable</em>
using CsvHelper; <em>// <-- นำมาช่วยอ่านไฟล์ CSV, เวอร์ชัน 15.0.5</em>
...

namespace MyWebService.Controllers
{
  [Route("api/[controller]")]
  [ApiController]
  public class MyBulkCopyController : ControllerBase
  {
    private readonly IDbDataAccessService _dbDataAccessService;
    private readonly IWebHostEnvironment _hostingEnvironment;

    public MyBulkCopyController(
      IDbDataAccessService dbDataAccessService, <em>// <-- Inject DbDataAccessService</em>
      IWebHostEnvironment hostingEnvironment
    )
    {
      _dbDataAccessService = dbDataAccessService;
      _hostingEnvironment = hostingEnvironment;
    }
  }

  ...

}

// สร้างพาทของไฟล์ CSV ที่มีข้อมูล 100,000 รายการ
string filePath = _hostingEnvironment.ContentRootPath;
filePath = Path.Join(filePath, "Data", "yellow_tripdata_2019-12_100000.csv");

List<YellowTripData> csvData;
DataTable dataTable = null;


using (var reader = new StreamReader(filePath, Encoding.UTF8))
using (var csv = new CsvReader(reader, CultureInfo.InvariantCulture))
{
  // อ่านข้อมูลในไฟล์ CSV แล้วสร้างเป็น List
  csvData = csv.GetRecords<YellowTripData>().ToList();
  // แปลง List เป็น DataTable
  dataTable = csvData.ToDataTable<YellowTripData>();
}

// สร้างพาทของไฟล์ CSV ที่มีข้อมูล 100,000 รายการ
string filePath = _hostingEnvironment.ContentRootPath;
filePath = Path.Join(filePath, "Data", "yellow_tripdata_2019-12_100000.csv");

List<YellowTripData> csvData;
DataTable dataTable = null;


using (var reader = new StreamReader(filePath, Encoding.UTF8))
using (var csv = new CsvReader(reader, CultureInfo.InvariantCulture))
{
  // อ่านข้อมูลในไฟล์ CSV แล้วสร้างเป็น List
  csvData = csv.GetRecords<YellowTripData>().ToList();
  // แปลง List เป็น DataTable
  dataTable = csvData.ToDataTable<YellowTripData>();
}

string destinationTableName = "TEST_BULK_COPY";
_dbDataAccessService.BulkCopy(destinationTableName, dataTable);

string destinationTableName = "TEST_BULK_COPY";
_dbDataAccessService.BulkCopy(destinationTableName, dataTable);