MCPcopy Create free account
hub / github.com/IceClusters/icmysql / MongoBulkWrite

Function MongoBulkWrite

src/db/mongo/Query.js:223–236  ·  view source on GitHub ↗
(dbId, params, callback)

Source from the content-addressed store, hash-verified

221}
222
223async function MongoBulkWrite(dbId, params, callback) {
224 try {
225 if (typeof callback !== "function") callback = null;
226 if (typeof params !== "object") return null;
227 if (typeof params.collection !== "string") return null;
228 if (typeof params.operations !== "object") return null;
229 const collection = global.MongoConnections[dbId].collection(params.collection)
230 const result = await collection.bulkWrite(params.operations);
231 return callback ? callback(result) : result;
232 } catch (error) {
233 ParseError("MongoDB bulk write error catched:", error.message);
234 return callback ? callback(null) : null;
235 }
236}
237
238async function MongoReplaceOne(dbId, params, callback) {
239 try {

Callers

nothing calls this directly

Calls 1

ParseErrorFunction · 0.85

Tested by

no test coverage detected