kCura.WinEDDS.BulkLoadFileImporter

BulkLoadFileImporter

public class BulkLoadFileImporter : LoadFileBase, IImportJob, IDisposable

Documentation

public sealed delegate DataSourcePrepEventEventHandler : MulticastDelegate

public sealed delegate EndFileImportEventHandler : MulticastDelegate

public class ExtractedTextFileNotFoundException : ImporterException

The exception thrown when the extracted text file does not exist.

public class ExtractedTextTooLargeException : ImporterException

The exception thrown when the extracted text file length exceeds the max extracted text length. When the encoding is not specified or is UTF8, the max length is 1GB otherwise, the max length is MaxValue.

public sealed delegate FatalErrorEventEventHandler : MulticastDelegate

public sealed delegate FieldMappedEventHandler : MulticastDelegate

public class IdentityValueNotSetException : ImporterException

The exception thrown when the identity field value is null or empty.

public sealed delegate ReportErrorEventEventHandler : MulticastDelegate

public sealed delegate StartFileImportEventHandler : MulticastDelegate

public sealed delegate StatusMessageEventHandler : MulticastDelegate

public static readonly string CancelEventMsg

public const string DATA_GRID_ID_FIELD_NAME = "DataGridID"

public const string ERROR_MESSAGE_FOLDER_NAME_TOO_LONG = "Error occurred when importing the document. The folder name is longer than 255 characters."

public static readonly string RestartTimeEventMsg

protected int _batchCounter

protected IAuditManager AuditManager

protected string BulkLoadFileFieldDelimiter

protected int DestinationFolderColumnIndex

protected bool FirstTimeThrough

protected FolderCache FolderCache

public int MaxNumberOfErrorsInGrid

protected int Offset

protected OutputFileWriter OutputFileWriter

protected int OverlayArtifactId

protected ImportOverwriteType Overwrite

protected long RecordCount

protected IRelativityManager RelativityManager

public Field[] this[int artifactTypeID] { get; }

public ImportAuditLevel AuditLevel { get; set; }

protected virtual bool BatchResizeEnabled { get; }

public List<int> BatchSizeHistoryList { get; }

public int CodesCreated { get; }

protected virtual ProcessContext Context { get; protected set; }

public bool DisableNativeValidation { get; set; }

public bool DisableUserSecurityCheck { get; set; }

public Field[] DocumentFieldsForCreate { get; }

public Field this[int artifactTypeID] { get; }

public int FoldersCreated { get; }

public Field this[int artifactTypeID] { get; }

public virtual bool HasErrors { get; }

protected int ImportBatchSize { get; protected set; }

protected int ImportBatchVolume { get; protected set; }

protected int JobCompleteBatchSize { get; protected set; }

protected bool LinkDataGridRecords { get; protected set; }

protected virtual int MinimumBatchSize { get; protected set; }

protected virtual int NumberOfRetries { get; }

protected virtual int ParentArtifactTypeID { get; }

public string RunId { get; }

public ITimeKeeperManager Timekeeper { get; set; }

public ArrayList UnmappedRelationalFields { get; }

public TapiClient UploadConnection { get; }

protected virtual int WaitTimeBetweenRetryAttempts { get; }

public event DataSourcePrepEventEventHandler DataSourcePrepEvent

public event EndFileImportEventHandler EndFileImport

public event FatalErrorEventEventHandler FatalErrorEvent

public event FieldMappedEventHandler FieldMapped

public event ReportErrorEventEventHandler ReportErrorEvent

public event StartFileImportEventHandler StartFileImport

public event StatusMessageEventHandler StatusMessage

public BulkLoadFileImporter(LoadFile args, ProcessContext context, IIoReporter reporter, ILog logger, int timeZoneOffset, bool initializeUploaders, Guid processID, bool doRetryLogic, string bulkLoadFileFieldDelimiter, CancellationTokenSource tokenSource, Func<string> correlationIdFunc, IRunningContext runningContext = null)

Constructs a new importer that will prepare a bulk load file from a provided file.

public BulkLoadFileImporter(LoadFile args, ProcessContext context, IIoReporter reporter, ILog logger, int timeZoneOffset, bool autoDetect, bool initializeUploaders, Guid processID, bool doRetryLogic, string bulkLoadFileFieldDelimiter, CancellationTokenSource tokenSource, Func<string> correlationIdFunc, IRunningContext runningContext = null)

Constructs a new importer that will prepare a bulk load file from a provided file.

public BulkLoadFileImporter(LoadFile args, ProcessContext context, IIoReporter reporter, ILog logger, int timeZoneOffset, bool autoDetect, bool initializeUploaders, Guid processID, bool doRetryLogic, string bulkLoadFileFieldDelimiter, CancellationTokenSource tokenSource, bool initializeArtifactReader, Func<string> correlationIdFunc, IRunningContext runningContext = null)

Constructs a new importer that will prepare a bulk load file from a provided file.

public static string CleanDestinationFolderPath(string path)

public static bool InnerRelativityFolderPathsAreTooLarge(string cleanFolderPath)

protected virtual void _processContext_ExportServerErrors(object sender, ExportErrorEventArgs e)

protected virtual void _processContext_HaltProcessEvent(object sender, CancellationRequestEventArgs e)

protected MassImportResults BulkImport(NativeLoadInfo settings, bool includeExtractedTextEncoding)

protected void CleanupTempTables()

protected void CloseFileWriters()

protected virtual void CreateUploaders(LoadFile args)

public void DeleteTempLoadFiles()

Safely deletes all temporary load files that are auto-generated when this object is created.

public virtual void Dispose()

public string[] GetColumnNames(object args)

public FieldInfo[] GetMappedFields(int artifactTypeId, IList<int> ObjectFieldIdListContainsArtifactId)

protected OverlayBehavior GetMassImportOverlayBehavior(FieldOverlayBehavior? inputOverlayType)

protected void InitializeFolderManagement()

protected virtual void LowerBatchLimits()

protected void ManageDocumentLine(MetaDocument mdoc)

protected void OnDataSourcePrepEvent(DataSourcePrepEventArgs args)

protected void OnEndFileImport(string runID)

protected void OnFatalError(string message, Exception ex, string runID)

protected void OnFieldMapped(string sourceField, string workspaceField)

protected void OnReportErrorEvent(IDictionary row)

public virtual void OnSettingsObjectCreate(NativeLoadInfo settings)

protected void OnStartFileImport()

protected void OnStatusMessage(StatusEventArgs args)

protected void OpenFileWriters()

protected string PrepareFieldCollectionAndExtractIdentityValue(ArtifactFieldCollection record, int CurrentLineNumber)

protected void PushNativeBatch(string outputNativePath, bool shouldCompleteJob, bool lastRun)

public virtual object ReadFile(string path)

Loads all the documents in a load file

public void WriteCodeLineToTempFile(string documentIdentifier, int codeArtifactID, int codeTypeID)

public void WriteObjectLineToTempFile(string ownerIdentifier, string objectName, int artifactID, int objectTypeArtifactID, int fieldID)

protected void WriteStatusLine(EventType2 et, string line)

protected void WriteWarning(string line)