如何使用 Bluemix 上的节点 js 应用程序获取插入到 Mongo db 集合中的 json 数据的 id

Question

我有一个 json 数据，我想将该 JSON 数据传递给 Mongo db 集合。 json数据是，

json=
{
"customerdetails" : {
    "organId" : "sample",
    "address" : {
        "addressLine1" : "123213",
        "postcode" : "RG16QX"
    },
    "customerName" : "don",
    "dob" : "sample"
},
"transactiondetails" : {
    "bankDetails" : {
        "accountName" : "john",
        "bankAddress" : "sample"
    },
 "brokerId" : "12345"
  }
  }

我只想将 customerdetails 详细信息 json 部分存储在一个集合中。然后我想获取插入的 json 的 id(_id":"nFNBY4GN6m6jjpNEY")..然后我想在客户详细信息值中替换此 id并将这个 json 插入另一个集合中。

{
"customerdetails" :{ "_id":"nFNBY4GN6m6jjpNEY"},

"transactiondetails" : {
"bankDetails" : {
    "accountName" : "john",
    "bankAddress" : "sample"
},
"brokerId" : "12345"
}
}

我使用的代码是

var jsondata=JSON.parse(json);
 var mongodb = require('mongodb');
var MongoClient = mongodb.MongoClient;
 mongourl="*******";
 MongoClient.connect(mongourl, function (err, db) {
      console.log("inside mongo client");

   if (err) {
    console.log('Unable to connect to the mongoDB server. Error:', err);
   } else {
var collection = db.collection('customerdetails');
collection.insert(jsondata.customerDetails, {safe:true},function (err, result) {
  if (err) {
      console.log("got error");
   console.log(err);
  } else {
    var collectionid=result._id;
    console.log("*********"+collectionid);
      console.log("collection"+collection);
   console.log('Inserted documents ");
  }
  });
  }

但我无法插入到收藏中.. 而且，如果它被插入，我如何从集合中获取插入数据的 _id 并将其替换为键值并将剩余的 JSON 传递给另一个集合.. 有人可以提出任何想法。 顺便说一句，我在 bluemix 上使用 nodeapp 和 mongodb 服务。 谢谢

Answer 1

您的代码中有 2 个问题，我们知道 javascript 区分大小写，您使用的是 jsondata.customerDetails，而您应该使用 json.customerdetails，并且您必须了解 insert 回调函数的参数。

您不需要使用JSON.parse(json);，因为您的变量json 已经是对象。这是代码

var json = {
    "customerdetails" : {
        "organId" : "sample",
        "address" : {
            "addressLine1" : "123213",
            "postcode" : "RG16QX"
        },
        "customerName" : "don",
        "dob" : "sample"
    },
    "transactiondetails" : {
        "bankDetails" : {
            "accountName" : "john",
            "bankAddress" : "sample"
        },
     "brokerId" : "12345"
  }
}

var mongodb = require('mongodb');
var MongoClient = mongodb.MongoClient;
var mongourl = 'mongodb://localhost:27017/stackoverflow';

MongoClient.connect(mongourl, function (err, db) {
    console.log("inside mongo client");
    if (err) {
        console.log('Unable to connect to the mongoDB server. Error:', err);
    } else {
        var collection = db.collection('customerdetails');
        collection.insert(json.customerdetails, {safe:true},function (err, result) {
            if (err) {
              console.log("got error");
              console.log(err);
            } else {
              json.customerdetails = {
                  "_id": result.insertedIds[0]
              }
              console.log("********* Here is updated josn ***************");
              console.log(json)
              console.log('Inserted documents ');
            }
        });
    }
});