Uzyskaj identyfikator _id wstawionego dokumentu w bazie danych Mongo w NodeJS

Używam NodeJS do wstawiania dokumentów do MongoDB. Używając collection.insertI mogę wstawić dokument do bazy danych jak w tym kodzie:

// ...
collection.insert(objectToInsert, function(err){
   if (err) return;
   // Object inserted successfully.
   var objectId; // = ???
});
// ...

Jak mogę uzyskać _idwstawiony obiekt?

Czy jest jakiś sposób na pobranie _idbez wstawiania najnowszego obiektu _id?

Zakładając, że w tym samym czasie wiele osób uzyskuje dostęp do bazy danych, nie mogę być pewien, czy najnowszy identyfikator to identyfikator wstawionego obiektu.

Istnieje drugi parametr wywołania zwrotnego collection.insert, który zwróci wstawiony dokument lub dokumenty, które powinny mieć _ids.

Próbować:

collection.insert(objectToInsert, function(err,docsInserted){
    console.log(docsInserted);
});

i sprawdź w konsoli, co mam na myśli.

Krótszym sposobem niż użycie drugiego parametru dla wywołania zwrotnego collection.insertbyłoby użycie, objectToInsert._idktóry zwraca_id (wewnątrz funkcji zwrotnej, zakładając, że była to operacja pomyślna).

Sterownik Mongo dla NodeJS dołącza _idpole do oryginalnego odniesienia do obiektu, więc łatwo jest uzyskać wstawiony identyfikator przy użyciu oryginalnego obiektu:

collection.insert(objectToInsert, function(err){
   if (err) return;
   // Object inserted successfully.
   var objectId = objectToInsert._id; // this will return the id of object inserted
});

Jak powiedział ktretyak, najlepszym sposobem uzyskania identyfikatora wstawionego dokumentu jest użycie właściwości insertId na obiekcie wynikowym. W moim przypadku result._id nie działał, więc musiałem użyć następującego:

db.collection("collection-name")
  .insertOne(document)
  .then(result => {
    console.log(result.insertedId);
  })
  .catch(err => {
    // handle error
  });

To samo dotyczy wywołań zwrotnych.

Właściwie zrobiłem console.log () dla drugiego parametru w funkcji zwrotnej dla wstawiania. W rzeczywistości zwracanych jest wiele informacji poza samym wstawionym obiektem. Poniższy kod wyjaśnia, jak uzyskać dostęp do jego identyfikatora.

collection.insert(objToInsert, function (err, result){
    if(err)console.log(err);
    else {
        console.log(result["ops"][0]["_id"]);
        // The above statement will output the id of the 
        // inserted object
       }
});

Mongo wysyła cały dokument jako obiekt wywołania zwrotnego, więc możesz go po prostu pobrać tylko stamtąd.

na przykład

collection.save(function(err,room){
  var newRoomId = room._id;
  });

Teraz możesz użyć metody insertOne i wyniku promise .insertedId

@JSideris, przykładowy kod do pobierania insertId.

db.collection(COLLECTION).insertOne(data, (err, result) => {
    if (err) 
      return err;
    else 
      return result.insertedId;
  });

jeśli chcesz wziąć „_id”, użyj prostego

result.insertedId.toString() 

// toString skonwertuje z hex

Możesz użyć funkcji asynchronicznych, aby automatycznie uzyskać pole _id bez manipulowania obiektem danych:

async function save() {
  const data = {
    name: "John"
  }

  await db.collection('users', data )

  return data
}

Zwraca dane:

{
  _id: '5dbff150b407cc129ab571ca',
  name: 'John'
}

Inny sposób na zrobienie tego w funkcji asynchronicznej:

const express = require('express')
const path = require('path')
const db = require(path.join(__dirname, '../database/config')).db;
const router = express.Router()

// Create.R.U.D
router.post('/new-order', async function (req, res, next) {

    // security check
    if (Object.keys(req.body).length === 0) {
        res.status(404).send({
            msg: "Error",
            code: 404
        });
        return;
    }

    try {

        // operations
        let orderNumber = await db.collection('orders').countDocuments()
        let number = orderNumber + 1
        let order = {
            number: number,
            customer: req.body.customer,
            products: req.body.products,
            totalProducts: req.body.totalProducts,
            totalCost: req.body.totalCost,
            type: req.body.type,
            time: req.body.time,
            date: req.body.date,
            timeStamp: Date.now(),

        }

        if (req.body.direction) {
            order.direction = req.body.direction
        }

        if (req.body.specialRequests) {
            order.specialRequests = req.body.specialRequests
        }

        // Here newOrder will store some informations in result of this process.
        // You can find the inserted id and some informations there too.
        
        let newOrder = await db.collection('orders').insertOne({...order})

        if (newOrder) {

            // MARK: Server response
            res.status(201).send({
                msg: `Order N°${number} created : id[${newOrder.insertedId}]`,
                code: 201
            });

        } else {

            // MARK: Server response
            res.status(404).send({
                msg: `Order N°${number} not created`,
                code: 404
            });

        }

    } catch (e) {
        print(e)
        return
    }

})

// C.Read.U.D


// C.R.Update.D


// C.R.U.Delete



module.exports = router;