Zarządzanie dokumentem w usłudze Azure Cosmos DB dla bazy danych MongoDB przy użyciu języka JavaScript
DOTYCZY: MongoDB
Zarządzanie dokumentami bazy danych MongoDB przy użyciu możliwości wstawiania, aktualizowania i usuwania dokumentów.
Dokumentacja referencyjna interfejsu API dla bazy danych | MongoDB — pakiet MongoDB (npm)
Wstawianie dokumentu
Wstaw do kolekcji dokument zdefiniowany przy użyciu schematu JSON.
// get database client for database
// if database or collection doesn't exist, it is created
// when the doc is inserted
// insert doc
const doc = { name: `product-${random}` };
const insertOneResult = await client.db("adventureworks").collection("products").insertOne(doc);
console.log(`Insert 1 - ${JSON.stringify(insertOneResult)}`);
// insert docs
const docs = [
{ name: `product-${random}` },
{ name: `product-${random}` }
];
const insertManyResult = await client.db("adventureworks").collection("products").insertMany(docs);
console.log(`Insert many ${JSON.stringify(insertManyResult)}`);
Powyższy fragment kodu wyświetla następujące przykładowe dane wyjściowe konsoli:
Insert 1 - {"acknowledged":true,"insertedId":"62b2394be4042705f00fd790"}
Insert many {"acknowledged":true,"insertedCount":2,"insertedIds":{"0":"62b2394be4042705f00fd791","1":"62b2394be4042705f00fd792"}}
done
Identyfikator dokumentu
Jeśli nie podasz identyfikatora, _id
dla dokumentu zostanie on utworzony jako obiekt BSON. Dostęp do podanego identyfikatora jest uzyskiwany za pomocą metody ObjectId.
Użyj identyfikatora, aby wykonywać zapytania dotyczące dokumentów:
const query = { _id: ObjectId("62b1f43a9446918500c875c5")};
Aktualizowanie dokumentu
Aby zaktualizować dokument, określ zapytanie używane do znalezienia dokumentu wraz z zestawem właściwości dokumentu, które mają zostać zaktualizowane. Możesz zdecydować się na rozszerzenie dokumentu, który wstawia dokument, jeśli jeszcze nie istnieje.
const product = {
category: "gear-surf-surfboards",
name: "Yamba Surfboard 3",
quantity: 15,
sale: true
};
const query = { name: product.name};
const update = { $set: product };
const options = {upsert: true, new: true};
const upsertResult = await client.db("adventureworks").collection('products').updateOne(query, update, options);
console.log(`Upsert result:\t\n${Object.keys(upsertResult).map(key => `\t${key}: ${upsertResult[key]}\n`)}`);
Powyższy fragment kodu wyświetla następujące przykładowe dane wyjściowe konsoli dla wstawiania:
Upsert result:
acknowledged: true
, modifiedCount: 0
, upsertedId: 62b1f492ff69395b30a03169
, upsertedCount: 1
, matchedCount: 0
done
Powyższy fragment kodu wyświetla następujące przykładowe dane wyjściowe konsoli dla aktualizacji:
Upsert result:
acknowledged: true
, modifiedCount: 1
, upsertedId: null
, upsertedCount: 0
, matchedCount: 1
done
Zbiorcze aktualizacje kolekcji
Możesz wykonać kilka operacji jednocześnie za pomocą operacji bulkWrite . Dowiedz się więcej na temat optymalizowania operacji zapisu zbiorczego dla usługi Azure Cosmos DB.
Dostępne są następujące operacje zbiorcze:
MongoClient.Db.Collection.bulkWrite
insertOne
updateOne
updateMany
deleteOne
deleteMany
const doc1 = {
category: "gear-surf-surfboards",
name: "Yamba Surfboard 3",
quantity: 15,
sale: true
};
const doc2={
category: "gear-surf-surfboards",
name: "Yamba Surfboard 7",
quantity: 5,
sale: true
};
// update docs with new property/value
const addNewProperty = {
filter: { "category": "gear-surf-surfboards" },
update: { $set: { discontinued: true } },
upsert: true,
};
// bulkWrite only supports insertOne, updateOne, updateMany, deleteOne, deleteMany
const upsertResult = await client.db("adventureworks").collection('products').bulkWrite([
{ insertOne: {document: doc1}},
{ insertOne: {document: doc2}},
{ updateMany: addNewProperty},
]);
console.log(`${JSON.stringify(upsertResult)}`);
Powyższy fragment kodu wyświetla następujące przykładowe dane wyjściowe konsoli:
{
"ok":1,
"writeErrors":[],
"writeConcernErrors":[],
"insertedIds":[
{"index":0,"_id":"62b23a371a09ed6441e5ee30"},
{"index":1,"_id":"62b23a371a09ed6441e5ee31"}],
"nInserted":2,
"nUpserted":0,
"nMatched":10,
"nModified":10,
"nRemoved":0,
"upserted":[]
}
done
Usuwanie dokumentu
Aby usunąć dokumenty, użyj zapytania, aby zdefiniować sposób znajdowania dokumentów.
const product = {
_id: ObjectId("62b1f43a9446918500c875c5"),
category: "gear-surf-surfboards",
name: "Yamba Surfboard 3",
quantity: 15,
sale: true
};
const query = { name: product.name};
// delete 1 with query for unique document
const delete1Result = await client.db("adventureworks").collection('products').deleteOne(query);
console.log(`Delete 1 result:\t\n${Object.keys(delete1Result).map(key => `\t${key}: ${delete1Result[key]}\n`)}`);
// delete all with empty query {}
const deleteAllResult = await client.db("adventureworks").collection('products').deleteMany({});
console.log(`Delete all result:\t\n${Object.keys(deleteAllResult).map(key => `\t${key}: ${deleteAllResult[key]}\n`)}`);
Powyższy fragment kodu wyświetla następujące przykładowe dane wyjściowe konsoli:
Delete 1 result:
acknowledged: true
, deletedCount: 1
Delete all result:
acknowledged: true
, deletedCount: 27
done