1
2
3
4
5
6
7
8
9
10
11
var query = conn.query("SELECT Name, Type, BillingState, BillingCity, BillingStreet FROM Account limit 3");
var job = conn2.bulk.createJob("Account", "insert");
var batch = job.createBatch();
query.pipe(batch);
batch.on('queue', function() {
  jobId = job.id;
  batchId = batch.id;
  console.log(job.id);
  console.log(batch.id);
  //...
});

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
var query = conn.query("SELECT Name, Type, BillingState, BillingCity, BillingStreet FROM Account limit 3", function(err, result) {
  if (err) { return console.error(err); }
  console.log("total : " + result.totalSize);
  console.log("fetched : " + result.records.length);


  var job = conn2.bulk.createJob("Account", "insert");
  var batch = job.createBatch();
    batch.execute(result.records);
    // listen for events
  batch.on("error", function(batchInfo) { // fired when batch request is queued in server.
    console.log('Error, batchInfo:', batchInfo);
  });
  batch.on("queue", function(batchInfo) { // fired when batch request is queued in server.
    console.log('queue, batchInfo:', batchInfo);
    batch.poll(1000 /* interval(ms) */, 20000 /* timeout(ms) */); // start polling - Do not poll until the batch has started
  });
  batch.on("response", function(rets) { // fired when batch finished and result retrieved
    for (var i=0; i < rets.length; i++) {
      if (rets[i].success) {
        console.log("#" + (i+1) + " loaded successfully, id = " + rets[i].id);
      } else {
        console.log("#" + (i+1) + " error occurred, message = " + rets[i].errors.join(', '));
      }
    }
    // ...
  });

});

1
2
3
4
var query = conn.query("SELECT Name, Type, BillingState, BillingCity, BillingStreet FROM Account limit 3");
query.pipe(jsforce.RecordStream.map(function(r) {
     console.log(r);
   }));