using System;
using AIR.Services.Common.Data;
using AIR.Services.DataImport.Api;
using AIR.Services.DataImport.Data;
class SnippetSubmitImportCsvRequest
{
private static void ImportExpressCSV(int businessUnitSid, int sqlInstanceSid, int dataSourceSid, int exposureSetSid, int mappingSetSid,
string contractsFilePath, string locationsFilePath)
{
DataImportServiceClient importClient = new DataImportServiceClient();
SubmitImportCsvRequest request = new SubmitImportCsvRequest();
request.BusinessUnitSid = businessUnitSid;
request.SqlInstanceSid = sqlInstanceSid;
request.ImportOptions = new ImportOptionsCsv()
{
Currency = "USD",
CurrencyExchangeRateSid = 1,
DataSourceSid = dataSourceSid,
ExposureSetSid = exposureSetSid,
MappingSetSid = mappingSetSid,
ContractsFilePath = contractsFilePath,
LocationsFilePath = locationsFilePath,
DateTimeFormat = "MM/DD/YYYY",
HasHeaders = true,
Delimiter = ',',
TextQualifier = AIR.Services.DataImport.Data.TextQualifier.DoubleQuote,
DuplicateContractBehaviour = DuplicateContractsOption.Replace,
Geocoder = BaseGeocoder.AIRGeocoder,
PreserveGeocode = true,
VerifyOnly = false
};
AIR.Services.DataImport.Api.SubmitImportCsvResponse response = importClient.SubmitImportCsv(request);
if (response.Status.Code == StatusCode.Success)
{
Console.WriteLine("Submitted successfully to HPC with Activity SID: " + response.ActivitySid);
}
}
}