imports/vx/server/daemon/recordimporter.js
/**
     * Iterate over array and perform upsert for each row.
     *
     * @param {object} coll Collection into which records should be upserted.
     * @param {object} uploadStats Upload Stats object.
     * @param {string} taskName Task name for logging.
     * @param {array} insertArray Array to be upserted.
     */
Iterate over array and perform upsert for each row.
@param {object} coll Collection into which records should be upserted.
@param {object} uploadStats Upload Stats object.
@param {string} taskName Task name for logging.
@param {array} insertArray Array to be upserted.
Iterate over array and perform upsert for each row . @param { object } coll Collection into which records should be upserted . @param { object } uploadStats Upload Stats object . @param { string } taskName Task name for logging . @param { array } insertArray Array to be upserted .
performSimpleUpsert(coll, uploadStats, taskName, insertArray) {
        insertArray.forEach(result => {
            OLog.debug(`recordimporter.js performSimpleUpsert domainId=${uploadStats.domain} ` +
                `uploadType=${uploadStats.uploadType} userId=${uploadStats.userId} taskName=${taskName} ` +
                `selector=${OLog.debugString(result.selector)} record=${OLog.debugString(result.record)}`)
            coll.direct.upsert(result.selector, result.record, {bypassCollection2: true})
        })
    }
performSimpleUpsert ( coll , uploadStats , taskName , insertArray ) { insertArray . forEach ( result => { OLog . debug ( ` ${ uploadStats . domain } ` + ` ${ uploadStats . uploadType } ${ uploadStats . userId } ${ taskName } ` + ` ${ OLog . debugString ( result . selector ) } ${ OLog . debugString ( result . record ) } ` ) coll . direct . upsert ( result . selector , result . record , { bypassCollection2 : true } ) } ) }
Iterate over array and perform upsert for each row.
Iterate over array and perform upsert for each row .