Aplatir le schéma mongoDB

Nouvelle réponse

Imprimer les données

db.test.find().forEach(doc => {
  doc.details = doc.details.map( detail => {
    Object.keys(detail).filter( k => k !== "_id" ).forEach( k => {
      detail[k].forEach( item => {
        Object.keys(item).filter(i => i !== "_id" ).forEach( inner => {
          detail[k + inner.charAt(0).toUpperCase() + inner.substr(1)]
            = item[inner];
        })
      });
      delete detail[k];
    });
    return detail;
  });
  printjson(doc);
});

Mettre à jour les données

db.test.find().forEach(doc => {
  doc.details = doc.details.map( detail => {
    Object.keys(detail).filter( k => k !== "_id" ).forEach( k => {
      detail[k].forEach( item => {
        Object.keys(item).filter(i => i !== "_id" ).forEach( inner => {
          detail[k + inner.charAt(0).toUpperCase() + inner.substr(1)]
            = item[inner];
        })
      });
      delete detail[k];
    });
    return detail;
  });

  ops = [
    ...ops,
    { "updateOne": {
      "filter": { "_id": doc._id },
      "update": { "$set": { "doc.details": doc.details } }
    }}
  ];

  if ( ops.length >= 500 ) {
    db.test.bulkWrite(ops);
    ops = [];
  }
});

if ( ops.length > 0 ) {
  db.test.bulkWrite(ops);
  ops = [];
}

Formulaire de sortie

{
    "_id" : ObjectId("58e574a768afb6085ec3a388"),
    "details" : [
        {
          "_id" : ObjectId("58e55f0f68afb6085ec3a2cc"),
          "aUnit" : "08",
          "aSize" : "5",
          "aPos" : "Far",
          "bUnit" : "08",
          "bSize" : "5",
          "bPos" : "Far",
          "cUnit" : "08",
          "cSize" : "3",
          "cPos" : "Far",
          "dUnit" : "08",
          "dSize" : "5",
          "dPos" : "Far"
        }
    ]
}

Données d'origine

{
    "_id" : ObjectId("58e574a768afb6085ec3a388"),
    "tests" : [
      {
        "_id" : ObjectId("58e542fb68afb6085ec3a1d2"),
        "details" : [
          {
            "a" : [
              {
                "unit" : "08",
                "size" : "5",
                "pos" : "Far",
                "_id" : ObjectId("58e542fb68afb6085ec3a1d6")
              }
            ]
          },
          {
            "b" : [
              {
                "pos" : "Drive Side Far",
                "size" : "5",
                "unit" : "08",
                "_id" : ObjectId("58e542fb68afb6085ec3a1d3")
              }
            ]
          },
          {
            "c" : [
              {
                "pos" : "Far",
                "size" : "3",
                "unit" : "08",
                "_id" : ObjectId("58e542fb68afb6085ec3a1d4")
              }
            ]
          },
          {
            "d" : [
              {
                "pos" : "Far",
                "size" : "5",
                "unit" : "08",
                "_id" : ObjectId("58e542fb68afb6085ec3a1d5")
              }
            ]
          }
        ]
      }
    ]
}

Réponse originale

Si vous essayez de "mettre à jour" vos données, cela implique beaucoup plus que ce que vous essayez. Vous avez plusieurs tableaux et vous devez réellement "parcourir" les éléments du tableau plutôt que d'essayer d'y accéder directement.

Voici juste un exemple pour "imprimer" les données "aplaties" :

db.test.find().forEach(doc => {
  doc.tests = doc.tests.map( test => {
    test.details.forEach( detail => {
      Object.keys(detail).forEach( key => {
        detail[key].forEach( item => {
          Object.keys(item).forEach( inner => {
            if ( inner !== '_id' ) {
              test[key + inner.charAt(0).toUpperCase() + inner.substr(1)]
                = item[inner];
            }
          });
        });
      });
    });
    delete test.details;
    return test;
  });
  printjson(doc);
})

Ce qui, je crois, donne la structure que vous recherchez :

{
    "_id" : ObjectId("58e574a768afb6085ec3a388"),
    "tests" : [
        {
            "_id" : ObjectId("58e542fb68afb6085ec3a1d2"),
            "aUnit" : "08",
            "aSize" : "5",
            "aPos" : "Far",
            "bPos" : "Drive Side Far",
            "bSize" : "5",
            "bUnit" : "08",
            "cPos" : "Far",
            "cSize" : "3",
            "cUnit" : "08",
            "dPos" : "Far",
            "dSize" : "5",
            "dUnit" : "08"
        }
    ]

}

Maintenant, je ne prends en compte aucune possibilité que dans vos "details" tableau les documents avec des clés comme "a" etc pourrait peut-être apparaître plusieurs fois. Donc je considère juste qu'il n'y a qu'un seul document à l'intérieur qui a un "a" ou un "b" etc, et la dernière valeur trouvée correspondant à cette clé est toujours attribuée lors de l'ajout des nouvelles clés au niveau supérieur des "details" documents.

Si votre cas réel varie, vous devrez modifier divers .forEach() boucles à l'intérieur pour utiliser également "l'index" comme paramètre et inclure cette valeur d'index dans le nom de la clé. c'est-à-dire :

"a0Unit": "08",
"a0Size": "05",
"a1Unit": "09",
"a1Size": "06"

Mais c'est un détail que vous devrez régler si nécessaire car cela serait différent de la façon dont les données sont présentées dans la question.

Si toutefois cela correspond parfaitement à ce que vous souhaitez mettre à jour, exécutez simplement la boucle avec .bulkWrite() instructions s'exécutant à intervalles réguliers :

let ops = [];

db.test.find().forEach(doc => {
  doc.tests = doc.tests.map( test => {
    test.details.forEach( detail => {
      Object.keys(detail).forEach( key => {
        detail[key].forEach( item => {
          Object.keys(item).forEach( inner => {
            if ( inner !== '_id' ) {
              test[key + inner.charAt(0).toUpperCase() + inner.substr(1)]
                = item[inner];
            }
          });
        });
      });
    });
    delete test.details;
    return test;
  });

  ops = [
    ...ops,
    { "updateOne": {
      "filter": { "_id": doc._id },
      "update": { "$set": { "tests": doc.tests } }
    }}
  ];

  if ( ops.length >= 500 ) {
    db.test.bulkWrite(ops);
    ops = [];
  }
});

if ( ops.length > 0 ) {
  db.test.bulkWrite(ops);
  ops = [];
}

Il apparaît également à partir du _id champs présents dans chaque document de membre de tableau que vous utilisez mongoose. Donc, quoi que vous fassiez, n'essayez pas d'exécuter le code en utilisant la mangouste elle-même. Il s'agit d'une mise à jour en masse "ponctuelle" de vos données et doit être exécutée directement à partir du shell. Ensuite, bien sûr, vous devrez modifier votre schéma pour l'adapter à la nouvelle structure.

Mais c'est pourquoi vous devriez parcourir vos données dans le shell avec le printjson() méthode d'abord.