Class RecordBatch

Private Readonly bulkPollInterval

Private Readonly bulkPollTimeout

Private failedCount

Private Readonly insert

Private isExecuting

Private Readonly logger

Private Readonly options

Private processedCount

Private progressReporter

Private recordCount

Private Readonly schemaService

Private Readonly update

Private executeWithBulkApi

• executeWithBulkApi(connection, chunk, cancelToken?): Promise<RecordResult[]>

• Parameters

  • connection: SalesforceConnection

  • chunk: RecordBatchChunk

  • Optional cancelToken: CancellationToken

  Returns Promise<RecordResult[]>

Private executeWithCollectionApi

• executeWithCollectionApi(connection, chunk, cancelToken?): Promise<RecordResult[]>

• Parameters

  • connection: SalesforceConnection

  • chunk: RecordBatchChunk

  • Optional cancelToken: CancellationToken

  Returns Promise<RecordResult[]>

Private getRecords

• getRecords(operation, count?): Promise<undefined | RecordBatchChunk>

• Parameters

  • operation: "all" | RecordOperationType

  • Optional count: number

  Returns Promise<undefined | RecordBatchChunk>

Private reportProgress

• reportProgress(): void

• Returns void

Private validateRecordData

• validateRecordData(sobjectType, values, mode): Promise<{}>

• Validate if the specified record data can be inserted; if not drop any fields that cannot be inserted or updated depending on the mode property specified.

  Parameters

  • sobjectType: string

    SObject type

  • values: object

    Values of the record

  • mode: "insert" | "update"

    Check for update or insert

  Returns Promise<{}>

Private yieldRecords

• yieldRecords(operation, count): AsyncGenerator<RecordBatchChunk, any, unknown>

• Parameters

  • operation: "all" | RecordOperationType

  • count: number

  Returns AsyncGenerator<RecordBatchChunk, any, unknown>