如何在 Cochbase 和节点 js 中使用不同的键批量插入

Question

我想导入一些更改的 MySQL 数据。像json里面的join和json。 我可以一一插入它。但这需要很多时间。 我通过以下代码来做到这一点。这个代码在for循环中

config.bucket.insert('User|'+page._id, JSON.stringify(page), function(err, res) {

                    if (err) {
                     console.log('User|'+page._id+' operation failed  '+ err);
                      return;
                    }
                    console.log('User|'+page._id);

                });

所以，我需要。 如何在 Cochbase 和 node js 中使用不同的键进行批量插入？？

page._id 是不同的键。我在插入 json 中也需要它

Answer 1

我很确定这就是您正在寻找的： https://github.com/couchbaselabs/devguide-examples/blob/master/nodejs/bulkES6.js

function bulkUpdateAsyncPattern(){
  return new Promise(
      (resolve, reject) => {

          var completed = 0;
          var runFlag = false;
          var startTime = process.hrtime();

          // Function for modify one document, during bulk loop.  Notice,
          // this is only in scope for bulkUpdateAsyncPattern
          function modifyOne() {

              // First Check if the bulk pattern loop is done
              if (completed >= totalDocs && !runFlag) {
                  runFlag = true;
                  var time = process.hrtime(startTime);
                  console.log("====");
                  console.log("  Bulk Pattern Processing Loop Took: " + parseInt((time[0] * 1000) +
                          (time[1] / 1000000)) + " ms for: " + getMultiArray.length +
                      " items");
                  resolve();
              } else {
                  if (completed <= totalDocs) {

                      // Modify One Document
                      bucket.mutateIn('test' + completed, 0, 0)
                      .counter('rev', 1, false)
                      .execute( function(err, res) {
                          if (err) console.log("  Error modifying:", err.message);

                          // This will fire WHEN and only WHEN a callback is received.
                          if (res) {
                              // Increment completed count
                              completed++;

                              // Recursive call to modify
                              modifyOne();
                          }
                      });
                  }
              }
          }
          // The loop that sets up a "buffer" of queued operations
          // This sets up a number of requests always in the buffer waiting to execute
          for (var i = 0; i < opsGroup; ++i) {
              modifyOne();
          }
      });
}