Der einzige wirklich zuverlässige Weg, um zu sehen, ob ein Update für so etwas wie einen angewendet wurde $pull
besteht darin, das zurückgegebene Dokument zu überprüfen und zu sehen, ob die Daten, die Sie $pull
noch drin ist oder nicht.
Das gilt für alle "findAndUpdate"
Vielzahl von Aktionen, und dafür gibt es einen triftigen Grund, und es ist auch so, dass ein einfacher .update()
wird Ihnen tatsächlich "zuverlässig" mitteilen, ob die Änderung tatsächlich vorgenommen wurde.
So gehen Sie durch die Fälle:
Überprüfen Sie den zurückgegebenen Inhalt
Dazu gehört im Grunde, das Array im zurückgegebenen Dokument zu betrachten, um zu sehen, ob das, was wir entfernen wollten, tatsächlich vorhanden ist:
var pullId = "5961de06ea264532c684611a";
Office.findByIdAndUpdate(1,
{ "$pull": { "branches": { "_id": pullId } } },
{ "new": true }
).then(office => {
// Check if the supplied value is still in the array
console.log(
"Still there?: %s",
(office.branches.find( b => b._id.toHexString() === pullId))
? true : false
);
}).catch(err => console.error(err))
Wir verwenden .toHexString()
um den tatsächlichen Wert einer ObjectId zu vergleichen da JavaScript einfach keine "Gleichheit" mit "Objekten" macht. Sie würden sowohl "links" als auch "rechts" prüfen, wenn Sie etwas liefern, das bereits in eine ObjectId "umgewandelt" wurde Wert, aber in diesem Fall wissen wir, dass die andere Eingabe eine "Zeichenfolge" ist.
Verwenden Sie einfach .update(), "Es ist zuverlässig"
Der andere hier zu betrachtende Fall stellt in Frage, ob Sie die zurückgegebenen modifizierten Daten sowieso "wirklich brauchen". Denn der .update()
-Methode, gibt zuverlässig ein Ergebnis zurück, das Ihnen mitteilt, ob tatsächlich etwas geändert wurde:
Office.update(
{ "_id": 1 },
{ "$pull": { "branches": { "_id": pullId } } },
).then(result => {
log(result);
}).catch(err => console.error(err))
Wobei Ergebnis hier sieht so aus:
{
"n": 1,
"nModified": 1, // <--- This always tells the truth, and cannot lie!
"opTime": {
"ts": "6440673063762657282",
"t": 4
},
"electionId": "7fffffff0000000000000004",
"ok": 1
}
Und in dem der nModified ist ein "echter" Indikator dafür, ob etwas "tatsächlich aktualisiert" wird. Also wenn es 1 ist dann das $pull hatte tatsächlich einen Effekt, aber wenn 0 es wurde tatsächlich nichts aus dem Array entfernt und nichts geändert.
Dies liegt daran, dass die Methode tatsächlich die aktualisierte API verwendet, die zuverlässige Ergebnisse liefert, die auf tatsächliche Änderungen hinweisen. Dasselbe würde für so etwas wie einen $set
was den Wert nicht wirklich geändert hat, da der gelieferte Wert gleich dem war, der bereits im Dokument vorhanden war.
findandmodify Lügen!
Der andere Fall, an den Sie vielleicht denken, wenn Sie sich die Dokumentation genau ansehen, ist, das "Rohergebnis" tatsächlich zu inspizieren und zu sehen, ob das Dokument geändert wurde oder nicht. Dafür gibt es in der Spezifikation sogar einen Indikator.
Das Problem ist (und erfordert mehr Arbeit mit Promises ), dass das Ergebnis nicht wirklich wahr ist:
var bogusId = "5961de06ea264532c684611a"; // We know this is not there!
Promise((resolve,reject) => {
Office.findByIdAndUpdate(1,
{ "$pull": { "branches": { "_id": bogusId } } },
{ "new": true, "passRawResult" },
(err,result,raw) => { // We cannot pass multiple results to a Promise
if (err) reject(err);
resolve({ result, raw }); // So we wrap it!
}
)
})
.then(response => log(response.raw))
.catch(err => console.error(err));
Das Problem hier ist, dass selbst wenn wir "wissen", dass dies nicht geändert werden sollte, die Antwort etwas anderes sagt:
{
"lastErrorObject": {
"updatedExisting": true,
"n": 1 // <--- LIES! IT'S ALL LIES!!!
},
"value": {
"_id": 1,
"name": "My Office",
"branches": [
{
"address": "Third address",
"isPrincipal": false,
"_id": "5961de06ea264532c6846118"
}
],
"__v": 0
},
"ok": 1,
"_kareemIgnore": true
}
Selbst nach all der Arbeit, um das "dritte" Argument aus der Callback-Antwort herauszubekommen, haben wir immer noch nicht die richtigen Informationen über das Update erhalten.
Abschluss
Wenn Sie dies also "zuverlässig" mit einer einzigen Anfrage tun möchten ( und Sie nicht können tun Sie dies zuverlässig mit mehreren Anfragen, da sich das Dokument ändern könnte zwischen! ) dann sind Ihre beiden Optionen:
-
Überprüfen Sie das zurückgegebene Dokument, um festzustellen, ob die Daten, die Sie entfernen wollten, noch vorhanden sind.
-
Vergessen Sie die Rückgabe eines Dokuments und vertrauen Sie auf
.update()sagt dir immer die "Wahrheit";)
Welche davon Sie verwenden, hängt vom Anwendungsnutzungsmuster ab, aber das sind die zwei verschiedenen Möglichkeiten, ein "zuverlässiges" Ergebnis zurückzugeben.
Kleine Auflistung
Nur um sicherzugehen, ist hier eine Auflistung, die alle Beispiele durchgeht und zeigt, was sie tatsächlich zurückgeben:
const async = require('async'),
mongoose = require('mongoose'),
Schema = mongoose.Schema;
mongoose.Promise = global.Promise;
mongoose.set('debug',true);
mongoose.connect('mongodb://localhost/test');
const branchesSchema = new Schema({
address: String,
isPrincipal: Boolean
});
const officeSchema = new Schema({
_id: Number,
name: String,
branches: [branchesSchema]
},{ _id: false });
const Office = mongoose.model('Office', officeSchema);
function log(data) {
console.log(JSON.stringify(data,undefined,2))
}
const testId = "5961a56d3ffd3d5e19c61610";
async.series(
[
// Clean data
(callback) =>
async.each(mongoose.models,(model,callback) =>
model.remove({},callback),callback),
// Insert some data and pull
(callback) =>
async.waterfall(
[
// Create and demonstrate
(callback) =>
Office.create({
_id: 1,
name: "My Office",
branches: [
{
address: "Some street, that avenue",
isPrincipal: true
},
{
address: "Another address",
isPrincipal: false
},
{
address: "Third address",
isPrincipal: false
}
]
},callback),
// Demo Alternates
(office,callback) =>
async.mapSeries(
[true,false].map((t,i) => ({ t, branch: office.branches[i] })),
(test,callback) =>
(test.t)
? Office.findByIdAndUpdate(office._id,
{ "$pull": { "branches": { "_id": test.branch._id } } },
{ "new": true , "passRawResult": true },
(err,result,raw) => {
if (err) callback(err);
log(result);
log(raw);
callback();
})
: Office.findByIdAndUpdate(office._id,
{ "$pull": { "branches": { "_id": test.branch._id } } },
{ "new": true } // false here
).then(result => {
log(result);
console.log(
"Present %s",
(result.branches.find( b =>
b._id.toHexString() === test.branch._id.toHexString() ))
? true : false
);
callback();
}).catch(err => callback(err)),
callback
)
],
callback
),
// Find and demonstate fails
(callback) =>
async.waterfall(
[
(callback) => Office.findOne({},callback),
(office,callback) =>
async.eachSeries([true,false],(item,callback) =>
(item)
? Office.findByIdAndUpdate(office._id,
{ "$pull": { "branches": { "_id": testId } } },
{ "new": true, "passRawResult": true },
(err,result,raw) => {
if (err) callback(err);
log(result);
log(raw);
callback();
}
)
: Office.findByIdAndUpdate(office._id,
{ "$pull": { "branches": { "_id": testId } } },
{ "new": true }
).then(result => {
console.log(result);
console.log(
"Present %s",
(result.branches.find( b =>
b._id.toHexString() === office.branches[0]._id.toHexString()))
? true : false
);
callback();
})
.catch(err => callback(err)),
callback)
],
callback
),
// Demonstrate update() modified shows 0
(callback) =>
Office.update(
{},
{ "$pull": { "branches": { "_id": testId } } }
).then(result => {
log(result);
callback();
})
.catch(err => callback(err)),
// Demonstrate wrapped promise
(callback) =>
Office.findOne()
.then(office => {
return new Promise((resolve,reject) => {
Office.findByIdAndUpdate(office._id,
{ "$pull": { "branches": { "_id": testId } } },
{ "new": true, "passRawResult": true },
(err,result,raw) => {
if (err) reject(err);
resolve(raw)
}
);
})
})
.then(office => {
log(office);
callback();
})
.catch(err => callback(err))
],
(err) => {
if (err) throw err;
mongoose.disconnect();
}
);
Und die Ausgabe, die es produziert:
Mongoose: offices.remove({}, {})
Mongoose: offices.insert({ _id: 1, name: 'My Office', branches: [ { address: 'Some street, that avenue', isPrincipal: true, _id: ObjectId("5961e5211a73e8331b44d74b") }, { address: 'Another address', isPrincipal: false, _id: ObjectId("5961e5211a73e8331b44d74a") }, { address: 'Third address', isPrincipal: false, _id: ObjectId("5961e5211a73e8331b44d749") } ], __v: 0 })
Mongoose: offices.findAndModify({ _id: 1 }, [], { '$pull': { branches: { _id: ObjectId("5961e5211a73e8331b44d74b") } } }, { new: true, passRawResult: true, upsert: false, remove: false, fields: {} })
{
"_id": 1,
"name": "My Office",
"__v": 0,
"branches": [
{
"address": "Another address",
"isPrincipal": false,
"_id": "5961e5211a73e8331b44d74a"
},
{
"address": "Third address",
"isPrincipal": false,
"_id": "5961e5211a73e8331b44d749"
}
]
}
{
"lastErrorObject": {
"updatedExisting": true,
"n": 1
},
"value": {
"_id": 1,
"name": "My Office",
"branches": [
{
"address": "Another address",
"isPrincipal": false,
"_id": "5961e5211a73e8331b44d74a"
},
{
"address": "Third address",
"isPrincipal": false,
"_id": "5961e5211a73e8331b44d749"
}
],
"__v": 0
},
"ok": 1,
"_kareemIgnore": true
}
Mongoose: offices.findAndModify({ _id: 1 }, [], { '$pull': { branches: { _id: ObjectId("5961e5211a73e8331b44d74a") } } }, { new: true, upsert: false, remove: false, fields: {} })
{
"_id": 1,
"name": "My Office",
"__v": 0,
"branches": [
{
"address": "Third address",
"isPrincipal": false,
"_id": "5961e5211a73e8331b44d749"
}
]
}
Present false
Mongoose: offices.findOne({}, { fields: {} })
Mongoose: offices.findAndModify({ _id: 1 }, [], { '$pull': { branches: { _id: ObjectId("5961a56d3ffd3d5e19c61610") } } }, { new: true, passRawResult: true, upsert: false, remove: false, fields: {} })
{
"_id": 1,
"name": "My Office",
"__v": 0,
"branches": [
{
"address": "Third address",
"isPrincipal": false,
"_id": "5961e5211a73e8331b44d749"
}
]
}
{
"lastErrorObject": {
"updatedExisting": true,
"n": 1
},
"value": {
"_id": 1,
"name": "My Office",
"branches": [
{
"address": "Third address",
"isPrincipal": false,
"_id": "5961e5211a73e8331b44d749"
}
],
"__v": 0
},
"ok": 1,
"_kareemIgnore": true
}
Mongoose: offices.findAndModify({ _id: 1 }, [], { '$pull': { branches: { _id: ObjectId("5961a56d3ffd3d5e19c61610") } } }, { new: true, upsert: false, remove: false, fields: {} })
{ _id: 1,
name: 'My Office',
__v: 0,
branches:
[ { address: 'Third address',
isPrincipal: false,
_id: 5961e5211a73e8331b44d749 } ] }
Present true
Mongoose: offices.update({}, { '$pull': { branches: { _id: ObjectId("5961a56d3ffd3d5e19c61610") } } }, {})
{
"n": 1,
"nModified": 0,
"opTime": {
"ts": "6440680872013201413",
"t": 4
},
"electionId": "7fffffff0000000000000004",
"ok": 1
}
Mongoose: offices.findOne({}, { fields: {} })
Mongoose: offices.findAndModify({ _id: 1 }, [], { '$pull': { branches: { _id: ObjectId("5961a56d3ffd3d5e19c61610") } } }, { new: true, passRawResult: true, upsert: false, remove: false, fields: {} })
{
"lastErrorObject": {
"updatedExisting": true,
"n": 1
},
"value": {
"_id": 1,
"name": "My Office",
"branches": [
{
"address": "Third address",
"isPrincipal": false,
"_id": "5961e5211a73e8331b44d749"
}
],
"__v": 0
},
"ok": 1,
"_kareemIgnore": true
}
